Haotian Li
Stéphan Taljaard
@task async def is_running_from_deployment() -> bool: task_run_context = get_run_context() flow_run_id = task_run_context.task_run.flow_run_id async with get_client() as client: flow_run = await client.read_flow_run(flow_run_id) return bool(flow_run.deployment_id)
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.