Skip to content

Commit

Permalink
debug task creation
Browse files Browse the repository at this point in the history
  • Loading branch information
nathandf committed Oct 11, 2023
1 parent f8116e9 commit 9bd1e95
Showing 1 changed file with 7 additions and 0 deletions.
7 changes: 7 additions & 0 deletions src/api/src/backend/views/ETLPipelines.py
Original file line number Diff line number Diff line change
@@ -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
Expand Down Expand Up @@ -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(
Expand All @@ -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])

Expand Down

0 comments on commit 9bd1e95

Please sign in to comment.