Evan Brown
09/01/2021, 2:23 PMKevin Kho
Evan Brown
09/01/2021, 2:36 PMKevin Kho
log_stdout=True
to ShellTask
? It inherits from Task so it can take all of the kwargs.Evan Brown
09/01/2021, 2:55 PMKevin Kho
stream_output=True
like this:
from os import path
from prefect import Flow
from prefect.tasks.shell import ShellTask
shelltask = ShellTask(
name="shell_task",
log_stderr=True,
return_all=True,
stream_output=True
)
with Flow("shelltest") as flow:
shelltask(command="echo 'test'")
flow.run()
Evan Brown
09/01/2021, 3:15 PMKevin Kho
Evan Brown
09/01/2021, 3:15 PMKevin Kho
Evan Brown
09/01/2021, 3:18 PM