diff --git a/main.py b/main.py index 3520f11..4268849 100644 --- a/main.py +++ b/main.py @@ -38,28 +38,28 @@ l.info("Developed by mewtek32, Floppaa, Goldblaze, and needlenose") async def grabAlertsLoop(): while True: - Alerts.makeRecord() + await Alerts.makeRecord() await asyncio.sleep(60) async def FiveMinUpdaters(): while True: - CurrentObservations.makeDataFile() + await CurrentObservations.makeDataFile() l.debug("Sleeping for 5 minutes...") await asyncio.sleep(5 * 60) async def HourUpdaters(): while True: - DailyForecast.makeDataFile() - HourlyForecast.makeDataFile() - AirQuality.writeData() - PollenForecast.makeDataFile() - AirportDelays.writeData() - Breathing.makeDataFile() - HeatingAndCooling.makeRecord() - WateringNeeds.makeRecord() - MosquitoActivity.makeRecord() - AchesAndPains.makeRecord() - TideForecast.makeRecord() + await DailyForecast.makeDataFile() + await HourlyForecast.makeDataFile() + # AirQuality.writeData() + # PollenForecast.makeDataFile() + # AirportDelays.writeData() + # Breathing.makeDataFile() + # HeatingAndCooling.makeRecord() + # WateringNeeds.makeRecord() + # MosquitoActivity.makeRecord() + # AchesAndPains.makeRecord() + # TideForecast.makeRecord() l.debug("Sleeping for an hour...") await asyncio.sleep(60 * 60) diff --git a/recordGenerators/CurrentObservations.py b/recordGenerators/CurrentObservations.py index 56e8861..f0ca993 100644 --- a/recordGenerators/CurrentObservations.py +++ b/recordGenerators/CurrentObservations.py @@ -78,7 +78,10 @@ async def makeDataFile(): files = [] commands = [] - # This causes blocking but there's not really much we can do about it :( + """ + TODO: This can be ran in a seperate thread using loop.run_in_executor() according to the python discord. + ! This should probably be implemented ASAP. + """ with open("./.temp/CurrentObservations.i2m", 'rb') as f_in: with gzip.open("./.temp/CurrentObservations.gz", 'wb') as f_out: shutil.copyfileobj(f_in, f_out)