varsha Parthasarathy12/07/2022, 7:23 PM
I have another wf B which find out what the inputs should be to wf A and “invokes” it. My current model is as below: Are there better ways to handle this?
@workflow A: @workflow B: result = B(..)
varsha Parthasarathy12/07/2022, 7:44 PM
Babis Kiosidis12/08/2022, 1:50 PM
Workflow X: - task A(): outputs a,b,c - task B(a,b,c)
Workflow A() - ... - ... outputs a,b,c Workflow B(a,b,c) ... Workflow X: - workflow A(): outputs a,b,c - workflow B(a,b,c)
varsha Parthasarathy12/08/2022, 4:49 PM
varsha Parthasarathy12/13/2022, 2:06 AM
Dynamic tasks calls a launch plan.
ground_truth_workflow = flytekit.LaunchPlan.get_or_create( name="ground_truth_workflow", workflow=GroundTruthOfflinePCPWorkFlow, )
@flytekit.dynamic def run: # Figures out number of iterations # ground_truth_workflow(..)
varsha Parthasarathy12/13/2022, 2:12 AM
the launch plan that you call will have its own parallelism settingOh nice, that’s great! 😅