Skip to content

Commit

Permalink
debug
Browse files Browse the repository at this point in the history
  • Loading branch information
nathandf committed Feb 9, 2024
1 parent 8f8c33d commit 29b2d9e
Showing 1 changed file with 6 additions and 1 deletion.
7 changes: 6 additions & 1 deletion src/api/src/backend/views/ETLPipelines.py
Original file line number Diff line number Diff line change
Expand Up @@ -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"),
Expand Down

0 comments on commit 29b2d9e

Please sign in to comment.