From 1080d2a84051ab224140ac76bf920d089cdf0613 Mon Sep 17 00:00:00 2001 From: Rizwan Hasan Date: Thu, 14 Apr 2022 13:53:53 +0600 Subject: [PATCH] Change pipeline example to run locally (#642) --- examples/pipeline/pipeline_from_decorator.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/examples/pipeline/pipeline_from_decorator.py b/examples/pipeline/pipeline_from_decorator.py index 214988c8..580bedd8 100644 --- a/examples/pipeline/pipeline_from_decorator.py +++ b/examples/pipeline/pipeline_from_decorator.py @@ -90,10 +90,10 @@ def executing_pipeline(pickle_url, mock_parameter='mock'): if __name__ == '__main__': # set the pipeline steps default execution queue (per specific step we can override it with the decorator) - PipelineDecorator.set_default_execution_queue('default') + # PipelineDecorator.set_default_execution_queue('default') # Run the pipeline steps as subprocesses on the current machine, great for local executions # (for easy development / debugging, use `PipelineDecorator.pipeline()` to execute steps as regular functions) - # PipelineDecorator.run_locally() + PipelineDecorator.run_locally() # Start the pipeline execution logic. executing_pipeline(