Noam polak
02/14/2022, 8:07 AMchild_flow = create_flow_run(
flow_name=CHILD_FLOW,
parameters={
"input_data": input_data,
"run_id": run_id,
},
project_name="default",
)
child_result = get_task_run_result(
child_flow,
task_slug="child_flow-copy",
poll_time=3,
)
I tried to add handler to get_task_run_result but it get error:
child_result = get_task_run_result(
hazarder_flow,
task_slug="child_flow-copy",
poll_time=3,
state_handlers=[post_to_slack_task_handler],
)
TypeError: got an unexpected keyword argument 'state_handler'
So how can I do it?
thanksKevin Kho
from prefect... import get_task_run_result
get_task_run_result.state_handlers=[post_to_slack_task_handler]
to change the state handler of that importNoam polak
02/14/2022, 3:19 PMKevin Kho
with Flow(..) as flow:
create_flow_run(...)
wait_for_flow_run(..., raise_final_state=True)
get_task_run_result(...)
and then you want to modify the state handler for wait_for_flow_run
create_flow_run
will finish before you try to get the resultNoam polak
02/16/2022, 8:07 AMKevin Kho
Noam polak
02/16/2022, 3:15 PM