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
Anna Geller
will 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")