Sumant Agnihotri
05/12/2022, 1:34 PMwith Flow("flow-a") as flow_a:
a()
b()
flow = Flow("flow-a-b", tasks=[a, b])
flow.register(project_name="tester")
Is the code written in function a
and b
saved on the cloud, or does the cloud refers to my system every time it needs to run the flow on an agent? If it does refer to my system, will it make a difference if the agent is running on a different system?Kevin Kho
05/12/2022, 1:44 PMAnna Geller
05/12/2022, 1:45 PMwill it make a difference if the agent is running on a different system?it's the same for all agents lastly, you may actually move the register part into main:
with Flow("flow-a") as flow:
task_a = a()
b(upstream_tasks=[task_a])
if __name__ == "__main__":
flow.register(project_name="tester")