Joe
10/28/2021, 9:22 PMstart_flow_run.map(...)
to use the same flow, but iterate across some provided parameters. Unfortunately when I set the flow_name=unmapped('webfs')
I get this error when attempting to run the flow: `ValueError: Received both flow_id
and flow_name
. Only one flow identifier can be passed.`Michael Adkins
10/28/2021, 9:23 PMflow_id
too?Joe
10/28/2021, 9:23 PMstorage = create_storage(flow_name=flow_name)
run_config = UniversalRun(labels=['local'])
with Flow(flow_name, storage=storage, run_config=run_config, result=storage.result) as flow:
image = parameter_webfs_image()
command = parameter_container_command()
network = parameter_container_network()
create_host_config = CreateHostConfigWithMount()
create_container = CreateContainer(trigger=not_all_skipped)
start_container = StartContainer()
mongo_volumes = MongoVolumes()
volumes = mongo_volumes()
mapped_flows = create_flow_run.map(
volumes,
flow_name=unmapped('webfs'),
project_name=unmapped(project_name),
)
Michael Adkins
10/28/2021, 9:24 PMvolumes
as a positional argumentflow_id
so you're passing it in there.Joe
10/28/2021, 9:25 PMMichael Adkins
10/28/2021, 9:26 PMmapped_flows = create_flow_run.map(
parameters={"volume": volumes},
flow_name=unmapped('webfs'),
project_name=unmapped(project_name),
)
Joe
10/28/2021, 9:27 PMMichael Adkins
10/28/2021, 9:27 PMunmapped
are mapped over.Joe
10/28/2021, 9:29 PMMichael Adkins
10/28/2021, 9:30 PMKevin Kho
10/28/2021, 9:39 PMJoe
10/28/2021, 11:53 PM