mirror of
https://github.com/mewtek/i2ME-Legacy.git
synced 2025-06-10 05:30:00 -05:00
Make tasks for updating from the radar server
This commit is contained in:
@@ -1,12 +1,34 @@
|
||||
import asyncio
|
||||
from recordGenerators import Alerts,CurrentObservations,HourlyForecast,DailyForecast, AirQuality, AirportDelays, AchesAndPains, Breathing, HeatingAndCooling, MosquitoActivity, PollenForecast, TideForecast, WateringNeeds
|
||||
from radar import TWCRadarCollector
|
||||
from datetime import datetime
|
||||
|
||||
|
||||
""" 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 updateMosaicTask():
|
||||
mosaicUpdateIntervals = [0, 5, 10, 15, 20, 25, 30, 35, 40, 45, 50, 55]
|
||||
|
||||
while True:
|
||||
# Server takes ~15 - 35 seconds to fully generate a frame, so use 40 seconds to ensure it's fully generated.
|
||||
if datetime.now().minute in mosaicUpdateIntervals and datetime.now().second == 40:
|
||||
await TWCRadarCollector.collect("radarmosaic")
|
||||
|
||||
await asyncio.sleep(1)
|
||||
|
||||
async def updateSatradTask():
|
||||
satradUpdateIntervals = [0, 10, 20, 30, 40, 50]
|
||||
|
||||
while True:
|
||||
# Server takes ~15 - 35 seconds to fully generate a frame, so use 40 seconds to ensure it's fully generated.
|
||||
if datetime.now().minute in satradUpdateIntervals and datetime.now().second == 40:
|
||||
await TWCRadarCollector.collect("satrad")
|
||||
|
||||
await asyncio.sleep(1)
|
||||
|
||||
|
||||
async def alertsTask():
|
||||
while True:
|
||||
await Alerts.makeRecord()
|
||||
|
||||
Reference in New Issue
Block a user