Skip to content

Commit 94269f6

Browse files
committed
minor change
1 parent 9c957ab commit 94269f6

1 file changed

Lines changed: 4 additions & 0 deletions

File tree

ddpui/core/orchestrate/pipeline_service.py

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -446,12 +446,16 @@ def get_pipeline_details(org: Org, deployment_id: str) -> Dict[str, Any]:
446446
.order_by("seq")
447447
]
448448

449+
# Exclude auto-managed tasks (dbt-clean, dbt-deps) from the response
450+
# since they are automatically added during pipeline creation/updation
451+
auto_managed_slugs = {TASK_DBTCLEAN, TASK_DBTDEPS}
449452
transform_tasks = [
450453
{"uuid": dataflow_orgtask.orgtask.uuid, "seq": dataflow_orgtask.seq}
451454
for dataflow_orgtask in DataflowOrgTask.objects.filter(
452455
dataflow=org_data_flow,
453456
orgtask__task__type__in=[TaskType.DBT, TaskType.DBTCLOUD],
454457
)
458+
.exclude(orgtask__task__slug__in=auto_managed_slugs)
455459
.all()
456460
.order_by("seq")
457461
]

0 commit comments

Comments
 (0)