HsiuChuanHsu commented on issue #55192: URL: https://github.com/apache/airflow/issues/55192#issuecomment-3248498787
I think the key problem is that -- `KubernetesJobOperator` ignores `on_finish_action` parameter. **The Core Issue** - `KubernetesJobOperator` inherits the `on_finish_action` parameter from `KubernetesPodOperator`. - However, during actual execution, the parameter setting is **completely ignored**. - Regardless of the value set, the Kubernetes Job and its associated Pod are not cleaned up upon successful completion. The actual behavior is that the Job and the Pod are both retained, and the `on_finish_action` setting is ignored. I would like to implement the cleanup logic for `on_finish_action` within the `KubernetesJobOperator.execute()`. https://github.com/apache/airflow/blob/0351fbf2c4ebe7c9081e86c6c0007efdaf549abb/providers/cncf/kubernetes/src/airflow/providers/cncf/kubernetes/operators/job.py#L182-L246 May I be assigned to this issue? I'd like to work on this. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
