diff --git a/src/api/src/backend/services/PipelineDispatcher.py b/src/api/src/backend/services/PipelineDispatcher.py index 7292693..3e87934 100644 --- a/src/api/src/backend/services/PipelineDispatcher.py +++ b/src/api/src/backend/services/PipelineDispatcher.py @@ -8,6 +8,7 @@ from backend.services.MessageBroker import service as broker from backend.models import Pipeline, PipelineRun, RUN_STATUS_SUBMITTED from backend.errors.api import ServerError +from pprint import pprint class PipelineDispatcher: @@ -50,6 +51,8 @@ def dispatch(self, service_request: dict, pipeline, pipeline_run=None): logger.exception(e.__cause__) raise ServerError(message=str(e)) + + pprint(service_request) try: broker.publish( "workflows",