Josh Paulin
09/07/2022, 3:18 PM@task
decorator and run it like a normal function, it works as expected.
Stepping into the engine code I can see it shows a final_state
of NotReady
here.Mason Menges
09/07/2022, 3:50 PMJosh Paulin
09/07/2022, 4:02 PMMason Menges
09/07/2022, 4:05 PMJosh Paulin
09/07/2022, 4:08 PMawait
fine as far as I can tell when stepping throughMason Menges
09/07/2022, 4:44 PMJosh Paulin
09/07/2022, 4:59 PMresults["alerted"] += [
await alerts.send_alert(None, alert_type, env) for run in failed_runs
]
The task executes when expectedMason Menges
09/07/2022, 7:40 PMJosh Paulin
09/07/2022, 8:12 PMfailed_runs
array
All yield the same results.Mason Menges
09/08/2022, 4:07 PMfailed_runs = await orion_api.get_flow_runs_since(
date_time=start_time,
tags=[alert_type.value, env.value],
states=[StateType.FAILED, StateType.CRASHED],
)
Josh Paulin
09/08/2022, 4:29 PMread_flow_runs
from the orion api