Hi, I'm running Prefect V1 and I'm having problems with passing in parameter. I'm trying to pass in Parameter to flow and use that parameter to concat a

command

for

ShellTask

. But the problem is that I'm not using the

Parameter

directly and it's not showing up in the UI when I register the flow. Is there any way to get around it? Thank you in advance!

In prefect v1 it is not possible to directly create the command string inside the flow. You need to wrap it inside a task which generates the string. I am not familiar with mapping the ShellTask, but would instead provide the command directly

@task
def create_command(param: str) -> str:
    return f"yarn ... --name {param}"

with Flow("My Flow") as flow:
    param = Parameter("parameter", default="nace")
    command = create_command(param)
    
    ShellTask(
        command=command,
        ...
    )

Thanks, that worked! The only issue now is that I have multiple commands passed as a list into

ShellTask

and all of them still run even if the first one fails. Is there a way to configure

ShellTask

so that it stops as soon as one of the commands fails?

So you are using map to run multiple ShellTasks at the same time and want to stop all of them directly when one of them fails?

Almost, they are run in sequence

Hey @Nace Plesko you should be able to set an all successful trigger on the task which should require all upstream mapped tasks to be successful before they are triggered more on that here https://docs-v1.prefect.io/core/concepts/mapping.html#state-behavior-with-mapped-tasks

I'll give this a try, thanks! I think I misunderstood how that works, but maybe it works in the way I want it to work!