Deletes job_pipeline_specs related to jobs when deleting a job

smartcontractkit · Mar 17, 2024 · bf712a2 · bf712a2
1 parent d9e7eb1
commit bf712a2
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/core/services/job/orm.go b/core/services/job/orm.go
@@ -631,6 +631,9 @@ func (o *orm) DeleteJob(id int32, qopts ...pg.QOpt) error {
 		deleted_gateway_specs AS (
 			DELETE FROM gateway_specs WHERE id IN (SELECT gateway_spec_id FROM deleted_jobs)
 		)
+		deleted_job_pipeline_specs AS (
+			DELETE FROM job_pipeline_specs WHERE job_id IN (SELECT pipeline_spec_id FROM deleted_jobs)
+		)
 		DELETE FROM pipeline_specs WHERE id IN (SELECT pipeline_spec_id FROM deleted_jobs)`
 	res, cancel, err := q.ExecQIter(query, id)
 	defer cancel()