dirrao commented on code in PR #32249:
URL: https://github.com/apache/airflow/pull/32249#discussion_r1266084027
##########
airflow/executors/kubernetes_executor_utils.py:
##########
@@ -143,6 +143,10 @@ def _run(
self.log.debug("Event: %s had an event of type %s",
task.metadata.name, event["type"])
if event["type"] == "ERROR":
return self.process_error(event)
+ labels = task.metadata.labels
+ if labels.get("airflow-worker", None) != scheduler_job_id:
+ last_resource_version = task.metadata.resource_version
Review Comment:
The scheduler don't want to receives the same event again and again. To
avoid this we have to update the last_resource_version. So, it will get the
events from the last_resource_version onwards.
--
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]
