Tobias Schmidt
09/28/2019, 1:57 PMZachary Hughes
09/29/2019, 7:10 PMflow.run()
in a task, but I'm not sure if that's what you're looking for.Dylan
09/30/2019, 11:16 AMTobias Schmidt
09/30/2019, 1:34 PMLuke Orland
09/30/2019, 2:32 PMChris White
09/30/2019, 3:03 PMset_upstream
pattern with reference_tasks
that @Luke Orland is suggesting, coupled with flow.update(other_flow)
might do the trick: https://docs.prefect.io/api/unreleased/core/flow.html#prefect-core-flow-flow-updateMark Koob
09/30/2019, 6:28 PM.update
and .replace
. The result is correct but not entirely satisfying since routing the results correctly requires some a priori knowledge of the task names. It looks like set_upstream
may be a better approach?Tobias Schmidt
10/01/2019, 8:05 AMMark Koob
10/01/2019, 2:06 PMclass FlowTask(prefect.Task)
where the run method is running another flow as @Zachary Hughes suggests works reasonably well. I'm not sure if this hinders optimizations, though.