diff --git a/providers/src/airflow/providers/cncf/kubernetes/utils/pod_manager.py b/providers/src/airflow/providers/cncf/kubernetes/utils/pod_manager.py index f7a602417b7fc..e65f0a63ae28b 100644 --- a/providers/src/airflow/providers/cncf/kubernetes/utils/pod_manager.py +++ b/providers/src/airflow/providers/cncf/kubernetes/utils/pod_manager.py @@ -855,7 +855,7 @@ def extract_xcom_kill(self, pod: V1Pod): _preload_content=False, ) ) as resp: - self._exec_pod_command(resp, "kill -2 1") + self._exec_pod_command(resp, "kill -2 $(pgrep -u $(whoami) -f trap)") def _exec_pod_command(self, resp, command: str) -> str | None: res = ""