Talha
05/04/2021, 10:59 AMStéphan Taljaard
05/04/2021, 12:44 PMKevin Kho
Talha
05/04/2021, 1:18 PMKevin Kho
import prefect
from prefect import Task
from prefect import task, Flow, Parameter
from prefect.tasks.shell import ShellTask
shell_task = ShellTask(
helper_script="",
shell="bash",
log_stderr=True,
return_all=True,
stream_output=True,
)
@task
def get_command(param):
return f"echo '{param}'"
with Flow(name="Test") as flow:
param = Parameter('param')
cmd = get_command(param)
test = shell_task(command=cmd)
flow.run(parameters=dict(param='a'))
Talha
05/04/2021, 1:19 PMKevin Kho
Rscript file.R
to run the R file.Talha
05/04/2021, 1:21 PMKevin Kho
Talha
05/06/2021, 3:43 PMTalha
05/06/2021, 4:17 PMKevin Kho
shell_task = ShellTask(
helper_script="",
shell="bash",
log_stderr=True,
return_all=True,
stream_output=True,
)
with Flow(name="Test") as flow:
test = shell_task(command="echo 'test'")
Talha
05/06/2021, 4:24 PMKevin Kho
Talha
05/07/2021, 3:26 PMKevin Kho
Talha
05/10/2021, 11:54 AMKevin Kho
Talha
05/10/2021, 2:28 PMKevin Kho
Talha
05/10/2021, 2:31 PMKevin Kho
Talha
05/10/2021, 2:42 PMKevin Kho
Talha
05/11/2021, 10:55 AMKevin Kho
Talha
05/11/2021, 2:54 PMKevin Kho
Luciano Fernando Palmeira de Almeida
06/04/2021, 8:59 PM