Jake Schmidt
prefect.Parameter
prefect.ShellTask
StringFormatter
Zachary Hughes
ShellTask
@task def print_plus_one(x): print(x + 1) with Flow('Parameterized Flow') as flow: x = Parameter('x', default = 2) print_plus_one(x=x)
tar -zcvf {output_dir}.tar.gz {output_dir}
output_dir
pf.Parameter
Jeremiah
Chris White
run
self.command
super().run(command=command)
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.