William Jamir
07/09/2024, 8:42 AM@flow(log_prints=True)
def myflow(param: str):
print(f'flow executed with param={param}')
I want to schedule 10 runs, and each of them with different values for param1.
Schedule 1: param=1
Schedule 2: param=2
...Neil Horlock
07/11/2024, 9:58 PMNeil Horlock
07/11/2024, 10:00 PMJoel Goncalves
07/13/2024, 5:23 PM@flow
async def parent_flow(params: List[str]):
for param in params:
await my_flow(param=param)
@flow(log_prints=True)
async def my_flow(param: str):
print(f"flow executed with param={param}")
# Deployment
my_flow_deployment = Deployment.build_from_flow(
flow=parent_flow,
parameters={"params": ["1", "2"]},
name="test-deployment"
)