Fix PipelineDecorator example

This commit is contained in:
allegroai 2022-03-07 23:45:34 +02:00
parent 3006085fcb
commit cc9ad00eeb

View File

@ -91,8 +91,9 @@ def executing_pipeline(pickle_url, mock_parameter='mock'):
if __name__ == '__main__': if __name__ == '__main__':
# set the pipeline steps default execution queue (per specific step we can override it with the decorator) # 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 subprocess on the current machine, for debugging purposes # Run the pipeline steps as subprocesses on the current machine, great for local executions
# PipelineDecorator.debug_pipeline() # (for easy development / debugging, use `PipelineDecorator.pipeline()` to execute steps as regular functions)
# PipelineDecorator.run_locally()
# Start the pipeline execution logic. # Start the pipeline execution logic.
executing_pipeline( executing_pipeline(