ExternalVendorCode/sondehub-infra
1
0
Fork 0
mirror of https://github.com/projecthorus/sondehub-infra.git synced 2024-12-19 05:07:55 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

async imrpvoements

Browse Source
This commit is contained in:
xss 2022-03-12 14:16:15 +11:00
parent d7fb710ad3
commit 3d4595131c
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
lambda/predict_updater/__init__.py
View File

@ -32,6 +32,7 @@ LAUNCH_ALLOCATE_RANGE_SCALING = 1.5 # Scaling factor - launch allocation range i
# Do not run predictions if the ascent or descent rate is less than this value # Do not run predictions if the ascent or descent rate is less than this value
ASCENT_RATE_THRESHOLD = 0.5 ASCENT_RATE_THRESHOLD = 0.5
sem = asyncio.Semaphore(20)
def flight_profile_by_type(sonde_type): def flight_profile_by_type(sonde_type):
""" """
@ -676,6 +677,7 @@ async def predict_async(event, context):
async def run_predictions_for_serial(serial, value, reverse_predictions, launch_sites): async def run_predictions_for_serial(serial, value, reverse_predictions, launch_sites):
async with sem:
loop = asyncio.get_event_loop() loop = asyncio.get_event_loop()
# #
# Flight Profile selection # Flight Profile selection
@ -727,14 +729,14 @@ async def run_predictions_for_serial(serial, value, reverse_predictions, launch_
_rev_pred = get_launch_estimate( _rev_pred = await loop.run_in_executor(None, functools.partial(get_launch_estimate,
value['time'], value['time'],
latitude, latitude,
longitude, longitude,
value['alt'], value['alt'],
current_rate=value['rate'], current_rate=value['rate'],
ascent_rate=value['rate'], ascent_rate=value['rate'],
) ))
if _rev_pred: if _rev_pred: