diff --git a/src/api/src/backend/migrations/0025_pipeline_description_task_entrypoint.py b/src/api/src/backend/migrations/0025_pipeline_description_task_entrypoint.py new file mode 100644 index 00000000..45bd2e19 --- /dev/null +++ b/src/api/src/backend/migrations/0025_pipeline_description_task_entrypoint.py @@ -0,0 +1,23 @@ +# Generated by Django 4.1.2 on 2023-10-11 01:01 + +from django.db import migrations, models + + +class Migration(migrations.Migration): + + dependencies = [ + ('backend', '0024_pipeline_uses'), + ] + + operations = [ + migrations.AddField( + model_name='pipeline', + name='description', + field=models.TextField(null=True), + ), + migrations.AddField( + model_name='task', + name='entrypoint', + field=models.TextField(null=True), + ), + ] \ No newline at end of file diff --git a/src/api/src/backend/views/ETLPipelines.py b/src/api/src/backend/views/ETLPipelines.py index e7fc9eef..65dc033d 100644 --- a/src/api/src/backend/views/ETLPipelines.py +++ b/src/api/src/backend/views/ETLPipelines.py @@ -184,7 +184,6 @@ def post(self, request, group_id, *_, **__): return BadRequest(message=e.__cause__) except Exception as e: return ServerErrorResp(f"{e}") - print("AFTER PIPELINE CREATE") # Fetch the archives specified in the request then create relations # between them and the pipline @@ -213,13 +212,13 @@ def post(self, request, group_id, *_, **__): # Delete the pipeline archive relationships that were just created [pipeline_archive.delete() for pipeline_archive in pipeline_archives] return BadRequest(message=e.__cause__) - print("AFTER ARCHIVE CREATE") + # The first tapis job should be dependent on the gen-inbound-manifests task last_task_id = "gen-inbound-manifests" # Create a tapis job task for each job provided in the request. tasks = [] - for i, job in enumerate(request.jobs, start=1): + for i, job in enumerate(body.jobs, start=1): task_id = f"etl-job-{i}" tasks.append( TapisJobTask({