raphaelauv commented on issue #22480:
URL: https://github.com/apache/airflow/issues/22480#issuecomment-1076174437


   https://github.com/apache/airflow/pull/22385: @potiuk -> WORK
   
   airlfow `2.1.4` with `apache-airflow-providers-cncf-kubernetes==3.1.1`
   
   give 
   
   ```log
   [2022-03-23 09:56:34,086] {taskinstance.py:1252} INFO - Exporting the 
following env vars:
   AIRFLOW_CTX_DAG_OWNER=airflow
   AIRFLOW_CTX_DAG_ID=kubernetes_dag
   AIRFLOW_CTX_TASK_ID=task-one
   AIRFLOW_CTX_EXECUTION_DATE=2022-03-14T00:00:00+00:00
   AIRFLOW_CTX_DAG_RUN_ID=scheduled__2022-03-14T00:00:00+00:00
   [2022-03-23 09:56:34,096] {kubernetes_pod.py:571} ERROR - 'NoneType' object 
has no attribute 'metadata'
   Traceback (most recent call last):
     File 
"/usr/local/lib/python3.9/site-packages/airflow/providers/cncf/kubernetes/operators/kubernetes_pod.py",
 line 368, in execute
       self.pod_request_obj = self.build_pod_request_obj(context)
     File 
"/usr/local/lib/python3.9/site-packages/airflow/providers/cncf/kubernetes/operators/kubernetes_pod.py",
 line 524, in build_pod_request_obj
       labels = self._get_ti_pod_labels(context)
     File 
"/usr/local/lib/python3.9/site-packages/airflow/providers/cncf/kubernetes/operators/kubernetes_pod.py",
 line 286, in _get_ti_pod_labels
       run_id = getattr(ti, 'run_id') or context['run_id']
   AttributeError: 'TaskInstance' object has no attribute 'run_id'
   
   ```
   
   airflow `2.1.4` with `apache-airflow-providers-cncf-kubernetes==3.1.2rc1`
   
   give 
   ```log
   [2022-03-23 09:58:46,424] {taskinstance.py:1252} INFO - Exporting the 
following env vars:
   AIRFLOW_CTX_DAG_OWNER=airflow
   AIRFLOW_CTX_DAG_ID=kubernetes_dag
   AIRFLOW_CTX_TASK_ID=task-one
   AIRFLOW_CTX_EXECUTION_DATE=2022-03-13T00:00:00+00:00
   AIRFLOW_CTX_DAG_RUN_ID=scheduled__2022-03-13T00:00:00+00:00
   [2022-03-23 09:58:46,428] {kubernetes_pod.py:525} INFO - Creating pod 
airflow-test-pod.186f4469675a401aa74c57c002ee8be4 with labels: {'dag_id': 
'kubernetes_dag', 'task_id': 'task-one', 'run_id': 
'scheduled__2022-03-13T0000000000-eef165281', 'try_number': '2'}
   [2022-03-23 09:58:46,485] {pod_manager.py:159} WARNING - Pod not yet 
started: airflow-test-pod.186f4469675a401aa74c57c002ee8be4
   [2022-03-23 09:58:47,496] {pod_manager.py:159} WARNING - Pod not yet 
started: airflow-test-pod.186f4469675a401aa74c57c002ee8be4
   [2022-03-23 09:58:48,517] {pod_manager.py:199} INFO - toto
   ```


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