diff --git a/sentry_streams_k8s/sentry_streams_k8s/pipeline_step.py b/sentry_streams_k8s/sentry_streams_k8s/pipeline_step.py
index 7ff4a88e..3a13b310 100644
--- a/sentry_streams_k8s/sentry_streams_k8s/pipeline_step.py
+++ b/sentry_streams_k8s/sentry_streams_k8s/pipeline_step.py
@@ -401,6 +401,7 @@ def run(self, context: dict[str, Any]) -> dict[str, Any]:
         labels = {
             "pipeline-app": make_k8s_name(pipeline_module),
             "pipeline": make_k8s_name(pipeline_name),
+            "service": make_k8s_name(service_name),
         }
         configmap_name = make_k8s_name(f"{service_name}-pipeline-{pipeline_name}")
 
diff --git a/sentry_streams_k8s/tests/test_pipeline_step.py b/sentry_streams_k8s/tests/test_pipeline_step.py
index ea93224c..ea390aed 100644
--- a/sentry_streams_k8s/tests/test_pipeline_step.py
+++ b/sentry_streams_k8s/tests/test_pipeline_step.py
@@ -435,6 +435,7 @@ def test_run_generates_complete_manifests() -> None:
     # Validate deployment name
     assert deployment["metadata"]["name"] == "my-service-pipeline-profiles-0"
     assert deployment["metadata"]["labels"]["pipeline-app"] == "sbc-profiles"
+    assert deployment["metadata"]["labels"]["service"] == "my-service"
     assert (
         deployment["spec"]["template"]["metadata"]["annotations"]["sidecar.istio.io/inject"]
         == "false"
@@ -443,6 +444,7 @@ def test_run_generates_complete_manifests() -> None:
     selector = deployment["spec"]["selector"]
     assert selector["matchLabels"]["pipeline-app"] == "sbc-profiles"
     assert selector["matchLabels"]["pipeline"] == "profiles"
+    assert selector["matchLabels"]["service"] == "my-service"
 
     # Validate deployment has container
     containers = deployment["spec"]["template"]["spec"]["containers"]
@@ -467,6 +469,7 @@ def test_run_generates_complete_manifests() -> None:
     assert configmap["metadata"]["name"] == "my-service-pipeline-profiles"
     assert configmap["metadata"]["labels"]["pipeline-app"] == "sbc-profiles"
     assert configmap["metadata"]["labels"]["pipeline"] == "profiles"
+    assert configmap["metadata"]["labels"]["service"] == "my-service"
 
     # Validate configmap data
     assert "pipeline_config.yaml" in configmap["data"]
@@ -617,6 +620,7 @@ def test_run_with_base_templates() -> None:
     # Check that pipeline additions are present
     assert deployment["metadata"]["name"] == "my-service-pipeline-profiles-0"
     assert "pipeline" in deployment["metadata"]["labels"]
+    assert "service" in deployment["metadata"]["labels"]
     assert len(deployment["spec"]["template"]["spec"]["containers"]) == 1
     assert (
         len(deployment["spec"]["template"]["spec"]["volumes"]) == 2
@@ -1084,6 +1088,7 @@ def test_emergency_patch_overrides_final_deployment() -> None:
     # Verify pipeline additions are still present (not removed by emergency patch)
     assert deployment["metadata"]["name"] == "my-service-pipeline-profiles-0"
     assert deployment["metadata"]["labels"]["pipeline-app"] == "sbc-profiles"
+    assert deployment["metadata"]["labels"]["service"] == "my-service"
     assert len(deployment["spec"]["template"]["spec"]["containers"]) == 1
     assert deployment["spec"]["template"]["spec"]["containers"][0]["name"] == "pipeline-consumer"