Matthew Seligson
05/23/2022, 12:46 PMAnna Geller
05/23/2022, 1:36 PMMatthew Seligson
05/23/2022, 2:35 PMKevin Kho
05/23/2022, 2:37 PMStartFlowRun
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
05/23/2022, 2:51 PMStartFlowRun
task just passes an idempotency key for you if you don’t specify one.Matthew Seligson
05/23/2022, 2:53 PMKevin Kho
05/23/2022, 2:54 PMMatthew Seligson
05/23/2022, 2:54 PMKevin Kho
05/23/2022, 2:59 PMMatthew Seligson
05/23/2022, 3:07 PMKevin Kho
05/23/2022, 3:15 PMMatthew Seligson
05/24/2022, 4:35 PMKevin Kho
05/24/2022, 4:37 PMMatthew Seligson
05/24/2022, 4:42 PMKevin Kho
05/24/2022, 4:43 PMMatthew Seligson
05/24/2022, 5:58 PMKevin Kho
05/24/2022, 6:06 PMMatthew Seligson
05/24/2022, 6:34 PMKevin Kho
05/24/2022, 6:47 PMMatthew Seligson
05/24/2022, 6:52 PMKevin Kho
05/24/2022, 6:55 PMMatthew Seligson
06/21/2022, 12:51 PMKevin Kho
06/21/2022, 1:43 PMfrom 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")