airflow-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Daniel Imberman <>
Subject Re: Optimize KuberneteExecutor pod labels to task instance key
Date Mon, 24 Aug 2020 16:31:04 GMT
Hi Ping,

I think that’s a great idea! Would be glad to help merge this.

via Newton Mail []
On Sun, Aug 23, 2020 at 11:33 PM, Ping Zhang <> wrote:
Hi everyone,

I was evaluating using *KubernetesExcutor* and found the inefficiency of `
*_labels_to_key*`, see code
which potentially does a very expensive db query for a large airflow
cluster when the dag_id or task_id have different char sets of kubernetes

I am proposing using Pod Annotation to record the task instance key
information given that the value of annotation does not have restriction.
In the event streaming from k8s, the annotation can be retrieved via `
*task.metadata.annotations*` with code example

Please let me know your thoughts before I start to upstream my changes.

Best wishes

Ping Zhang
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message