Joshua Grant
12/01/2022, 7:04 PMget_run_context()
from within a flow. MRE in đź§µfrom prefect import flow, task, get_run_logger
from prefect.context import get_run_context
@task
def print_task(obj):
logger = get_run_logger()
<http://logger.info|logger.info>(obj)
@flow
def test_flow():
ctx = get_run_context()
print_task(ctx)
if __name__ == "__main__":
test_flow()
> python sample_flow.py
13:46:36.385 | INFO | prefect.engine - Created flow run 'thankful-seagull' for flow 'test-flow'
This will not finish until Ctrl+CZanie
12/01/2022, 7:07 PMget_run_context
.Joshua Grant
12/01/2022, 7:15 PMZanie
12/01/2022, 7:19 PMJoshua Grant
12/01/2022, 7:22 PMflow_id
by passing ctx.flow_run.flow_id
to the log statement.
14:30:49.797 | INFO | prefect.engine - Created flow run 'sepia-hyena' for flow 'test-flow'
14:30:49.873 | INFO | Flow run 'sepia-hyena' - Created task run 'print_task-3fb05284-0' for task 'print_task'
14:30:49.873 | INFO | Flow run 'sepia-hyena' - Executing 'print_task-3fb05284-0' immediately...
14:30:49.890 | INFO | Task run 'print_task-3fb05284-0' - 5c22623d-9c2e-4610-87c1-8fc6249938f7
14:30:49.900 | INFO | Task run 'print_task-3fb05284-0' - Finished in state Completed()
14:30:49.910 | INFO | Flow run 'sepia-hyena' - Finished in state Completed('All states completed.')
Thanks @ZanieZanie
12/01/2022, 7:38 PMLeon Kozlowski
02/02/2023, 8:56 PMJoshua Grant
02/02/2023, 9:06 PM@flow
def my_flow():
ctx = get_run_context()
flow_id = ctx.flow_run.flow_id
my_task_results = my_task(flow_id)
Leon Kozlowski
02/02/2023, 9:06 PM