use user-defined execution profile but use duplicate_submission_polic…

…y defined in the pipeline template
tapis-project · Oct 10, 2023 · 8808840 · 8808840
1 parent fa4b05a
commit 8808840
Showing 1 changed file with 7 additions and 4 deletions.
diff --git a/src/api/src/backend/views/ETLPipelines.py b/src/api/src/backend/views/ETLPipelines.py
@@ -114,12 +114,15 @@ def post(self, request, group_id, *_, **__):
                     description=getattr(body, "description", None) or pipeline_template.get("description"),
                     group=group,
                     owner=request.username,
-                    **body.execution_profile.dict(),
-                    duplicate_submission_policy=(
-                        pipeline_template
+                    # Here we are using the execution profile provided in the request, but
+                    # overwritting the 'duplicate_submission_policy' defined in the
+                    # the pipeline template.
+                    **{
+                        **body.execution_profile.dict(),
+                        "duplicate_submission_policy": pipeline_template
                             .get("execution_profile")
                             .get("duplicate_submission_policy")
-                    ),
+                    },
                     env={
                         **pipeline_template.get("env"),
                         "LOCAL_INBOX_SYSTEM_ID": {