Franco Bocci
09/05/2023, 1:56 PMdef create_wf(name: str):
@workflow
def _create_wf():
task_a() >> task_b()
_create_wf.__name__ = name
return _create_wf
wf_a = create_wf("a")
wf_b = create_wf("b")
But it’s not being recognized when I register workflows in my packagedef create_wf(name: str):
wf = ImperativeWorkflow(name=name)
wf.add_task(task_a)
wf.add_task(task_b)
return wf
But never used ImperativeWorkflow
before. Would appreciate a confirmation on whether this makes sense whenever you have timeKevin Su
09/05/2023, 2:23 PMFranco Bocci
09/05/2023, 2:34 PMSamhita Alla
Franco Bocci
09/06/2023, 6:36 AMSamhita Alla
Franco Bocci
09/06/2023, 7:36 AM