Mohamed Hatem Diabi
07/15/2022, 12:13 AM@task(log_stdout=True)
def create_subflows(list_of_elements):
   list_param= []
   for element in list_of_elements:
        list_param.append(
            {
                "pr": element,
            }
        )
   mapped_flows = create_flow_run.map(
        flow_name=unmapped("Subflow"),
        parameters=list_param,
    )
with Flow("Parent Flow") as flow:
   list_of_elements = [1,2,3]
   create_subflows(list_of_elements)create_flow_run.run(...)Anna Geller
@Task@taskMohamed Hatem Diabi
07/15/2022, 3:45 AMAnna Geller
