diff --git a/RecordTasks.py b/RecordTasks.py index 93d62c0..d1cf5aa 100644 --- a/RecordTasks.py +++ b/RecordTasks.py @@ -1,11 +1,16 @@ import asyncio -from recordGenerators import CurrentObservations,HourlyForecast,DailyForecast +from recordGenerators import Alerts,CurrentObservations,HourlyForecast,DailyForecast """ This houses the tasks needed to update the data records concurrently I have no idea if this is a messy way to do things, but it will be worked upon if it is. """ +async def alertsTask(): + while True: + await Alerts.makeRecord() + await asyncio.sleep(60) + async def coTask(): while True: await CurrentObservations.makeDataFile() diff --git a/main.py b/main.py index 80781d8..329d58d 100644 --- a/main.py +++ b/main.py @@ -37,11 +37,13 @@ l.info("Starting i2RecordCollector") l.info("Developed by mewtek32, Floppaa, Goldblaze, and needlenose") async def main(): + alertsTask = asyncio.create_task(RecordTasks.alertsTask()) coTask = asyncio.create_task(RecordTasks.coTask()) hfTask = asyncio.create_task(RecordTasks.hfTask()) dfTask = asyncio.create_task(RecordTasks.dfTask()) # In theory, these should all run concurrently without problems + await alertsTask await coTask await hfTask await dfTask