jack
flow_run.name
from prefect.context import get_run_context get_run_context().flow_run.name
AttributeError: 'TaskRunContext' object has no attribute 'flow_run'
alex
def get_flow_run_id() -> str: run_context = get_run_context() if isinstance(run_context, TaskRunContext): flow_run_id = run_context.task_run.dict().get("flow_run_id") else: flow_run_id = run_context.flow_run.dict().get("id") return str(flow_run_id)
flow_run_name
flow_run_id
import prefect.runtime prefect.runtime.flow_run.name
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.