mirror of
https://github.com/mewtek/i2ME-Legacy.git
synced 2025-05-11 00:57:31 -05:00
Fix syntax of previous commit
This commit is contained in:
parent
2936a64cff
commit
08da432ea2
@ -74,7 +74,7 @@ async def makeRecord():
|
||||
file = "./.temp/AchesAndPains.gz"
|
||||
command = '<MSG><Exec workRequest="storeData(File={0},QGROUP=__AchesAndPains__,Feed=AchesAndPains)" /><GzipCompressedMsg fname="AchesAndPains" /></MSG>'
|
||||
|
||||
await loop.run_in_executor(bit.sendFile([file], [command], 1, 0))
|
||||
await loop.run_in_executor(None, bit.sendFile([file], [command], 1, 0))
|
||||
|
||||
remove('./.temp/AchesAndPains.i2m')
|
||||
remove('./.temp/AchesAndPains.gz')
|
@ -94,7 +94,7 @@ async def writeData():
|
||||
comand = commands.append('<MSG><Exec workRequest="storeData(File={0},QGROUP=__AirQuality__,Feed=AirQuality)" /><GzipCompressedMsg fname="AirQuality" /></MSG>')
|
||||
numFiles = len(files)
|
||||
|
||||
await loop.run_in_executor(bit.sendFile(files, commands, numFiles, 0))
|
||||
await loop.run_in_executor(None, bit.sendFile(files, commands, numFiles, 0))
|
||||
|
||||
os.remove("./.temp/AirQuality.i2m")
|
||||
os.remove("./.temp/AirQuality.gz")
|
||||
|
@ -94,7 +94,7 @@ async def writeData():
|
||||
comand = commands.append('<MSG><Exec workRequest="storeData(File={0},QGROUP=__AirportDelays__,Feed=AirportDelays)" /><GzipCompressedMsg fname="AirportDelays" /></MSG>')
|
||||
numFiles = len(files)
|
||||
|
||||
await loop.run_in_executor(bit.sendFile(files, commands, numFiles, 0))
|
||||
await loop.run_in_executor(None, bit.sendFile(files, commands, numFiles, 0))
|
||||
|
||||
os.remove("./.temp/AirportDelays.i2m")
|
||||
os.remove("./.temp/AirportDelays.gz")
|
||||
|
@ -86,7 +86,7 @@ async def makeDataFile():
|
||||
command = commands.append('<MSG><Exec workRequest="storeData(File={0},QGROUP=__Breathing__,Feed=Breathing)" /><GzipCompressedMsg fname="Breathing" /></MSG>')
|
||||
numFiles = len(files)
|
||||
|
||||
await loop.run_in_executor(bit.sendFile(files, commands, numFiles, 0))
|
||||
await loop.run_in_executor(None, bit.sendFile(files, commands, numFiles, 0))
|
||||
|
||||
os.remove("./.temp/Breathing.i2m")
|
||||
os.remove("./.temp/Breathing.gz")
|
@ -92,7 +92,7 @@ async def makeDataFile():
|
||||
command = commands.append('<MSG><Exec workRequest="storeData(File={0},QGROUP=__CurrentObservations__,Feed=CurrentObservations)" /><GzipCompressedMsg fname="CurrentObservations" /></MSG>')
|
||||
numFiles = len(files)
|
||||
|
||||
await loop.run_in_executor(await loop.run_in_executor(bit.sendFile(files, commands, numFiles, 0)))
|
||||
await loop.run_in_executor(await loop.run_in_executor(None, bit.sendFile(files, commands, numFiles, 0)))
|
||||
|
||||
os.remove("./.temp/CurrentObservations.i2m")
|
||||
os.remove("./.temp/CurrentObservations.gz")
|
||||
|
@ -87,7 +87,7 @@ async def makeDataFile():
|
||||
command = commands.append('<MSG><Exec workRequest="storeData(File={0},QGROUP=__DailyForecast__,Feed=DailyForecast)" /><GzipCompressedMsg fname="DailyForecast" /></MSG>')
|
||||
numFiles = len(files)
|
||||
|
||||
await loop.run_in_executor(bit.sendFile(files, commands, numFiles, 0))
|
||||
await loop.run_in_executor(None, bit.sendFile(files, commands, numFiles, 0))
|
||||
|
||||
os.remove("./.temp/DailyForecast.i2m")
|
||||
os.remove("./.temp/DailyForecast.gz")
|
@ -74,7 +74,7 @@ async def makeRecord():
|
||||
file = "./.temp/HeatingAndCooling.gz"
|
||||
command = '<MSG><Exec workRequest="storeData(File={0},QGROUP=__HeatingAndCooling__,Feed=HeatingAndCooling)" /><GzipCompressedMsg fname="HeatingAndCooling" /></MSG>'
|
||||
|
||||
await loop.run_in_executor(bit.sendFile([file], [command], 1, 0))
|
||||
await loop.run_in_executor(None, bit.sendFile([file], [command], 1, 0))
|
||||
|
||||
remove('./.temp/HeatingAndCooling.i2m')
|
||||
remove('./.temp/HeatingAndCooling.gz')
|
@ -89,7 +89,7 @@ async def makeDataFile():
|
||||
command = commands.append('<MSG><Exec workRequest="storeData(File={0},QGROUP=__HourlyForecast__,Feed=HourlyForecast)" /><GzipCompressedMsg fname="HourlyForecast" /></MSG>')
|
||||
numFiles = len(files)
|
||||
|
||||
await loop.run_in_executor(bit.sendFile(files, commands, numFiles, 0))
|
||||
await loop.run_in_executor(None, bit.sendFile(files, commands, numFiles, 0))
|
||||
|
||||
os.remove("./.temp/HourlyForecast.i2m")
|
||||
os.remove("./.temp/HourlyForecast.gz")
|
@ -74,7 +74,7 @@ async def makeRecord():
|
||||
file = "./.temp/MosquitoActivity.gz"
|
||||
command = '<MSG><Exec workRequest="storeData(File={0},QGROUP=__MosquitoActivity__,Feed=MosquitoActivity)" /><GzipCompressedMsg fname="MosquitoActivity" /></MSG>'
|
||||
|
||||
await loop.run_in_executor(bit.sendFile([file], [command], 1, 0))
|
||||
await loop.run_in_executor(None, bit.sendFile([file], [command], 1, 0))
|
||||
|
||||
remove('./.temp/MosquitoActivity.i2m')
|
||||
remove('./.temp/MosquitoActivity.gz')
|
@ -86,7 +86,7 @@ async def makeDataFile():
|
||||
command = commands.append('<MSG><Exec workRequest="storeData(File={0},QGROUP=__PollenForecast__,Feed=PollenForecast)" /><GzipCompressedMsg fname="PollenForecast" /></MSG>')
|
||||
numFiles = len(files)
|
||||
|
||||
await loop.run_in_executor(bit.sendFile(files, commands, numFiles, 0))
|
||||
await loop.run_in_executor(None, bit.sendFile(files, commands, numFiles, 0))
|
||||
|
||||
os.remove("./.temp/PollenForecast.i2m")
|
||||
os.remove("./.temp/PollenForecast.gz")
|
@ -83,7 +83,7 @@ async def makeRecord():
|
||||
file = "./.temp/TidesForecast.gz"
|
||||
command = '<MSG><Exec workRequest="storeData(File={0},QGROUP=__TidesForecast__,Feed=TidesForecast)" /><GzipCompressedMsg fname="TidesForecast" /></MSG>'
|
||||
|
||||
await loop.run_in_executor(bit.sendFile([file], [command], 1, 0))
|
||||
await loop.run_in_executor(None, bit.sendFile([file], [command], 1, 0))
|
||||
|
||||
remove('./.temp/TidesForecast.i2m')
|
||||
remove('./.temp/TidesForecast.gz')
|
@ -73,7 +73,7 @@ async def makeRecord():
|
||||
file = "./.temp/WateringNeeds.gz"
|
||||
command = '<MSG><Exec workRequest="storeData(File={0},QGROUP=__WateringNeeds__,Feed=WateringNeeds)" /><GzipCompressedMsg fname="WateringNeeds" /></MSG>'
|
||||
|
||||
await loop.run_in_executor(bit.sendFile([file], [command], 1, 0))
|
||||
await loop.run_in_executor(None, bit.sendFile([file], [command], 1, 0))
|
||||
|
||||
remove('./.temp/WateringNeeds.i2m')
|
||||
remove('./.temp/WateringNeeds.gz')
|
Loading…
x
Reference in New Issue
Block a user