sushi30 opened a new issue #22485:
URL: https://github.com/apache/airflow/issues/22485


   ### Apache Airflow Provider(s)
   
   cncf-kubernetes
   
   ### Versions of Apache Airflow Providers
   
   apache-airflow-providers-cncf-kubernetes==3.1.1
   
   ### Apache Airflow version
   
   2.2.2
   
   ### Operating System
   
   Centos 7
   
   ### Deployment
   
   Official Apache Airflow Helm Chart
   
   ### Deployment details
   
   Airflow deployed on kubernetes
   
   ### What happened
   
   These tasks have been running for several months. When trying to upgrade to 
the latest Kubernetes provider, the KubernetesPodOperator the worker pod so it 
does not start a new pod. This just hangs until the task times out.
   
   ```python
   [2022-03-23 09:49:49,950] {kubernetes_pod.py:525} INFO - Creating pod 
engines-distant-sharer.5bfdc82ad54d4dc1b58367f3d6d6a94f with labels: {'dag_id': 
'tag_engine_user', 'task_id': 'engines_distant_sharer', 'run_id': 
'manual__2022-03-23T094931.4187280000-fe99c2456', 'try_number': '1'}
   [2022-03-23 09:49:49,972] {kubernetes_pod.py:336} INFO - Found matching pod 
tagengineuserenginesdistantsharer.1e4548b0558448f9a7aaa69da5f1e69d with labels 
{'airflow-worker': '2258913', 'airflow_version': '2.2.2', 'component': 
'worker', 'dag_id': 'tag_engine_user', 'kubernetes_executor': 'True', 
'release': 'airflow', 'run_id': 
'manual__2022-03-23T094931.4187280000-fe99c2456', 'task_id': 
'engines_distant_sharer', 'tier': 'airflow', 'try_number': '1'}
   ```
   
   ### What you think should happen instead
   
   The task should run succesfully
   
   ### How to reproduce
   
   Run a kubernetes operator with the pod namespace the same as the airfloe 
deployment namespace.
   
   ### Anything else
   
   I see that the label "execution_date" has been changed to "run_id". This is 
most likely the cause.
   
   ```python
   {'dag_id': 'tag_engine', 'task_id': 'engines_stationary_sharer', 
'execution_date': '2022-03-23T0730000000-b016b00b9', 'try_number': '1'}
   ```
   
   ```python
   {'dag_id': 'tag_engine', 'task_id': 'engines_stationary_sharer', 'run_id': 
'scheduled__2022-03-23T0930000000-fdfd231b4', 'try_number': '1'}
   ```
   
   
   ### Are you willing to submit PR?
   
   - [ ] Yes I am willing to submit a PR!
   
   ### Code of Conduct
   
   - [X] I agree to follow this project's [Code of 
Conduct](https://github.com/apache/airflow/blob/main/CODE_OF_CONDUCT.md)
   


-- 
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]


Reply via email to