tanvn commented on issue #39088:
URL: https://github.com/apache/airflow/issues/39088#issuecomment-2063329564

   **Just tested with Airflow 2.8.4 and confirmed that the issue still 
happens.**
   
   
   ```
   [2024-04-18T08:29:32.060+0000] {kubernetes_executor.py:661} INFO - 
attempting to adopt pod orphaned-test-select-table-67-1ljpj4u3
   
   [2024-04-18T08:29:32.259+0000] {kubernetes_executor_utils.py:304} INFO - 
Event: orphaned-test-select-table-67-1ljpj4u3 is Running, annotations: <omitted>
   ...
   [2024-04-18T08:29:36.977+0000] {scheduler_job_runner.py:1671} INFO - Reset 
the following 32 orphaned TaskInstances:
   ...
   ```
   
   log on the task instance:
   ```
   [2024-04-18, 17:25:53 JST] {task_command.py:423} INFO - Running 
<TaskInstance: orphaned_test.select_table_67 
scheduled__2024-04-18T06:30:00+00:00 [running]> on host 
orphaned-test-select-table-67-1ljpj4u3
   ...
   [2024-04-18, 17:30:23 JST] {local_task_job_runner.py:302} WARNING - State of 
this instance has been externally set to scheduled. Terminating instance.
   [2024-04-18, 17:30:23 JST] {process_utils.py:131} INFO - Sending 15 to group 
12. PIDs of all processes in the group: [12]
   [2024-04-18, 17:30:23 JST] {process_utils.py:86} INFO - Sending the signal 
15 to group 12
   [2024-04-18, 17:30:23 JST] {taskinstance.py:2483} ERROR - Received SIGTERM. 
Terminating subprocesses.
   [2024-04-18, 17:30:23 JST] {taskinstance.py:2731} ERROR - Task failed with 
exception
   Traceback (most recent call last):
     File 
"/usr/local/lib/python3.10/site-packages/airflow/models/taskinstance.py", line 
444, in _execute_task
       result = _execute_callable(context=context, **execute_callable_kwargs)
     File 
"/usr/local/lib/python3.10/site-packages/airflow/models/taskinstance.py", line 
414, in _execute_callable
       return execute_callable(context=context, **execute_callable_kwargs)
     File "/opt/airflow/plugins/operators/my_dummy_operator.py", line 95, in 
execute
       time.sleep(300)
     File 
"/usr/local/lib/python3.10/site-packages/airflow/models/taskinstance.py", line 
2485, in signal_handler
       raise AirflowException("Task received SIGTERM signal")
   airflow.exceptions.AirflowException: Task received SIGTERM signal
   
   ```


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