question about `shell_run_command` in orion. I’m not able to pass a `retries` parameter to the task....

Bob Colner

05/22/2022, 7:23 PM

question about

shell_run_command

in orion. I’m not able to pass a

retries

parameter to the task.

TypeError: got an unexpected keyword argument 'retries'

any ideas?

Bob Colner

05/22/2022, 7:24 PM

Copy code

config_ssh_rsync_f = shell_run_command(
        retries = 3, 
        retry_delay_seconds = 10, 
        command = "ls", 
        return_all = True, 
        wait_for = [spinup_databox_f], 
    )

Bob Colner

05/22/2022, 7:25 PM

the above is inside my @flow function of course

Anna Geller

05/22/2022, 7:31 PM

try this syntax:

Copy code

from prefect import flow
from prefect_shell import shell_run_command


@flow
def example_shell_run_command_flow():
    return shell_run_command.with_options(retries=5)(command="ls .", return_all=True)


if __name__ == "__main__":
    example_shell_run_command_flow()

Anna Geller

05/22/2022, 7:31 PM

or with more task-args like delay:

Copy code

from prefect import flow
from prefect_shell import shell_run_command


@flow
def example_shell_run_command_flow():
    return shell_run_command.with_options(retries=5, retry_delay_seconds=30)(
        command="ls .", return_all=True
    )


if __name__ == "__main__":
    example_shell_run_command_flow()

Bob Colner

05/22/2022, 7:48 PM

thanks for the magic syntax -that worked

👍 1

12 Views

Open in Slack

Previous Next

Prefect Community

Bring your towel and join one of the fastest growing data communities. Welcome to our second-generation open source orchestration platform, a completely rethought approach to dataflow automation.