dirrao commented on code in PR #32249:
URL: https://github.com/apache/airflow/pull/32249#discussion_r1266090618
##########
airflow/executors/kubernetes_executor_utils.py:
##########
@@ -129,7 +129,7 @@ def _run(
) -> str | None:
self.log.info("Event: and now my watch begins starting at
resource_version: %s", resource_version)
- kwargs = {"label_selector": f"airflow-worker={scheduler_job_id}"}
+ kwargs = {"label_selector": "airflow-worker"}
Review Comment:
I have verified this fix. This is not adding any additional bugs. However,
there might be slight increase in kube watcher load. I haven't seen any other
options to fix this issue. I have updated the comments in the code.
--
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]
