Skip to content

Commit 5b3c871

Browse files
jakekaplanÅsmund Østvold
authored and
Åsmund Østvold
committed
add flow run to task run logging (PrefectHQ#9170)
1 parent a56c7a1 commit 5b3c871

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

src/prefect/engine.py

+2-1
Original file line numberDiff line numberDiff line change
@@ -1444,7 +1444,8 @@ async def orchestrate_task_run(
14441444
Returns:
14451445
The final state of the run
14461446
"""
1447-
logger = task_run_logger(task_run, task=task)
1447+
flow_run = await client.read_flow_run(task_run.flow_run_id)
1448+
logger = task_run_logger(task_run, task=task, flow_run=flow_run)
14481449

14491450
partial_task_run_context = PartialModel(
14501451
TaskRunContext,

0 commit comments

Comments
 (0)