Matthew Seligson
05/23/2022, 12:46 PMAnna Geller
Matthew Seligson
05/23/2022, 2:35 PMKevin Kho
StartFlowRun
and create_flow_run
just hit the API, but if you hit the same flow run with the same idempotency key, it jsut returns the state. It doesn’t restart it. So you would need to restart the child flow run, and then restart the parent flowMatthew Seligson
05/23/2022, 2:47 PMKevin Kho
StartFlowRun
task just passes an idempotency key for you if you don’t specify one.Matthew Seligson
05/23/2022, 2:53 PMKevin Kho
Matthew Seligson
05/23/2022, 2:54 PMKevin Kho
Matthew Seligson
05/23/2022, 3:07 PMKevin Kho
Matthew Seligson
05/24/2022, 4:35 PMKevin Kho
Matthew Seligson
05/24/2022, 4:42 PMKevin Kho
Matthew Seligson
05/24/2022, 5:58 PMKevin Kho
Matthew Seligson
05/24/2022, 6:34 PMKevin Kho
Matthew Seligson
05/24/2022, 6:52 PMKevin Kho
Matthew Seligson
06/21/2022, 12:51 PMKevin Kho
from prefect import Flow, task
from prefect.tasks.prefect import StartFlowRun
@task
def abc():
raise ValueError()
return 1
with Flow("child") as flow:
abc()
flow.register("databricks")
start = StartFlowRun(flow_name="child", project_name="databricks")
with Flow("parent") as flow2:
start()
flow2.register("databricks")