Include pipeline_execution_queue for default example so it will run remotely (#37)

This commit is contained in:
Fred DeSerres-Blanchet
2023-01-23 04:58:31 -05:00
committed by GitHub
parent 2c5901e9d3
commit 49e684cb18

View File

@@ -44,7 +44,8 @@ def step(size: int):
@PipelineDecorator.pipeline(
name='ingest',
project='data processing',
version='0.1'
version='0.1',
pipeline_execution_queue="default"
)
def pipeline_logic(do_stuff: bool):
if do_stuff: