Hello Prefect. I have a question about dealing wit...
# ask-communityf
Felipe Saldana
09/02/2021, 1:54 PMHello Prefect. I have a question about dealing with Flow Parameters. Whats the preferred way to concatenate flow parameters that will be passed into a number of task? Let me type up a simplified example below
Felipe Saldana
09/02/2021, 2:06 PMSay I have the following incoming parameters. I would like to concatenate these to create proper paths/variables such as
lake2_staginglake2_prepublishlake1_publishlake2_publish Copy code
lake1_root_dir = Parameter("lake1_root_dir", required=True)
lake2_root_dir = Parameter("lake2_root_dir", required=True)
publish_dir = Parameter("publish_dir", required=True)
output_dir = Parameter("output_dir", required=True)
staging_dir = Parameter("staging_dir", required=True)
prepublish_dir = Parameter("prepublish_dir", required=True)
source_data_dir = Parameter("source_data_dir", required=True)
lake2_staging = lake2_root_dir + "/" + staging_dir
lake2_prepublish = lake2_root_dir + "/" + prepublish_dir
lake1_publish = lake1_root_dir + "/" + publish_dir + "/" + output_dir
lake2_publish = lake2_root_dir + "/" + publish_dir + "/" + output_dirk
Kevin Kho
09/02/2021, 2:09 PM
Hey @Felipe Saldana, I think you really need to make a task that takes in these and creates the string.
Copy code
@task
def make_path(root, env, output):
return f"{root}/{env}/{output}"f
Felipe Saldana
09/02/2021, 2:11 PMHey @Kevin Kho, thats what I was thinking. Hmmm, almost like a flow property in a sense.
Felipe Saldana
09/02/2021, 2:13 PMAnd then I could pass the result of
make_pathk
Kevin Kho
09/02/2021, 2:15 PM
yes you can
f
Felipe Saldana
09/02/2021, 2:21 PMThanks again @Kevin Kho.... I appreciate the quick response
👍 1
2 Views