diff --git a/src/api/src/backend/views/ETLPipelines.py b/src/api/src/backend/views/ETLPipelines.py index 8351cacb..fa5e3f9d 100644 --- a/src/api/src/backend/views/ETLPipelines.py +++ b/src/api/src/backend/views/ETLPipelines.py @@ -114,13 +114,18 @@ def post(self, request, group_id, *_, **__): # Convert the data integrity policies to dicts. Easier # to handle for null values via .get inbox_data_integrity_profile = {} + print("LOCAL_INBOX", body.local_inbox) if getattr(body.local_inbox, "data_integrity_profile", None) != None: inbox_data_integrity_profile = body.local_inbox.data_integrity_profile.dict() + print("INBOX INTEGRITY", inbox_data_integrity_profile) + outbox_data_integrity_profile = {} + print("LOCAL OUTBOX", body.local_outbox) if getattr(body.local_outbox, "data_integrity_profile", None) != None: outbox_data_integrity_profile = body.local_outbox.data_integrity_profile.dict() - + print("OUTBOX INTEGRITY", outbox_data_integrity_profile) + pipeline = PipelineModel.objects.create( id=body.id, description=getattr(body, "description", None) or pipeline_template.get("description"),