Leon Kozlowski
coros = [ 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)
@flow(name="insights-generic", task_runner=DaskTaskRunner(), **opsgenie_hooks) async def insights_generic(
Bring your towel and join one of the fastest growing data communities. Welcome to our second-generation open source orchestration platform, a completely rethought approach to dataflow automation.