Debug

tapis-project · Nov 7, 2024 · dc9a9f7 · dc9a9f7
1 parent 0d1b0a9
commit dc9a9f7
Showing 1 changed file with 3 additions and 0 deletions.
diff --git 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",