Leon Kozlowski
01/29/2024, 5:58 PMcoros = [
insights_x(
recipient="x",
unload_location=unload_loaction,
configuration=configuration["x"],
start=start,
end=end,
expected_start_time=expected_start_time,
is_test_run=is_test_run,
),
insights_y(
recipient="y",
unload_location=unload_loaction,
configuration=configuration["y"],
start=start,
end=end,
is_test_run=is_test_run,
),
]
await asyncio.gather(*coros)
Leon Kozlowski
01/29/2024, 6:00 PMLeon Kozlowski
01/29/2024, 6:00 PM@flow(name="insights-generic", task_runner=DaskTaskRunner(), **opsgenie_hooks)
async def insights_generic(