diff --git a/src/api/src/backend/views/ETLPipelines.py b/src/api/src/backend/views/ETLPipelines.py index 65dc033d..80f7c9e2 100644 --- a/src/api/src/backend/views/ETLPipelines.py +++ b/src/api/src/backend/views/ETLPipelines.py @@ -1,5 +1,7 @@ import os, json +from pprint import pprint + from typing import List from pydantic import ValidationError from django.db import DatabaseError, IntegrityError, OperationalError @@ -218,6 +220,8 @@ def post(self, request, group_id, *_, **__): # Create a tapis job task for each job provided in the request. tasks = [] + print("BODY") + pprint(body) for i, job in enumerate(body.jobs, start=1): task_id = f"etl-job-{i}" tasks.append( @@ -230,6 +234,9 @@ def post(self, request, group_id, *_, **__): ) last_task_id = task_id + print("TASKS") + pprint(tasks) + # Add the tasks from the template to the tasks list tasks.extend([TemplateTask(**task) for task in pipeline_template.tasks])