cancel_pipelines: include downstream pipelines

scripts/cancel_pipelines.py

@@ -8,6 +8,39 @@ from gitlab.v4.objects import Project, ProjectPipeline
 import common
 
 
+def cancel_pipeline_including_children(
+    project: Project,
+    pipeline: ProjectPipeline,
+):
+    """Cancel pipeline including downstream pipelines (parent/child or multi-project).
+
+    Args:
+        project: Project containing the pipeline
+        pipeline: Pipeline to cancel
+
+    Returns:
+        Nothing
+    """
+
+    # Browse through all downstream pipelines
+    for bridge in pipeline.bridges.list():
+
+        if not bridge.downstream_pipeline:
+            continue
+
+        # Check if downstream pipeline is in different project
+        if bridge.downstream_pipeline["project_id"] != pipeline.project_id:
+            project = pipeline.manager.gitlab.projects.get(
+                bridge.downstream_pipeline["project_id"]
+            )
+
+        # Recurse to downstream pipeline
+        downstream_pipeline = project.pipelines.get(bridge.downstream_pipeline["id"])
+        cancel_pipeline_including_children(project, downstream_pipeline)
+
+    pipeline.cancel()
+
+
 def cancel_pipelines(
     project: Project,
     ref: str = "",
@@ -31,7 +64,7 @@ def cancel_pipelines(
     cancelled_pipelines = []
     for pipeline in pipelines:
         if pipeline.id < below_pipeline_id:
-            pipeline.cancel()
+            cancel_pipeline_including_children(project, pipeline)
             cancelled_pipelines.append(pipeline)
 
     return cancelled_pipelines