You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by GitBox <gi...@apache.org> on 2021/07/28 03:37:24 UTC

[GitHub] [airflow] ashaw27 edited a comment on issue #10026: Duplicate tasks invoked for a single task_id when manually invoked task details modal.

ashaw27 edited a comment on issue #10026:
URL: https://github.com/apache/airflow/issues/10026#issuecomment-799613642


   I'm having this issue in 2.0.1.  Is there a workaround?  My timesensor failed at a seemingly random time, twice, resulting in 4 failures.  I only had 3 retries set, so the DAG failed.
   
   ```
   [2021-03-15 02:47:28,089] {time_sensor.py:38} INFO - Checking if the time (03:30:00) has come
   [2021-03-15 02:48:28,149] {time_sensor.py:38} INFO - Checking if the time (03:30:00) has come
   [2021-03-15 02:49:28,209] {time_sensor.py:38} INFO - Checking if the time (03:30:00) has come
   [2021-03-15 02:50:21,225] {local_task_job.py:184} WARNING - Recorded pid 211954 does not match the current pid 189553
   [2021-03-15 02:50:21,229] {process_utils.py:100} INFO - Sending Signals.SIGTERM to GPID 189554
   [2021-03-15 02:50:21,230] {taskinstance.py:1239} ERROR - Received SIGTERM. Terminating subprocesses.
   [2021-03-15 02:50:21,241] {taskinstance.py:1455} ERROR - Task received SIGTERM signal
   Traceback (most recent call last):
     File "/home/airflowuser/miniconda3/lib/python3.8/site-packages/airflow/models/taskinstance.py", line 1112, in _run_raw_task
       self._prepare_and_execute_task_with_callbacks(context, task)
     File "/home/airflowuser/miniconda3/lib/python3.8/site-packages/airflow/models/taskinstance.py", line 1285, in _prepare_and_execute_task_with_callbacks
       result = self._execute_task(context, task_copy)
     File "/home/airflowuser/miniconda3/lib/python3.8/site-packages/airflow/models/taskinstance.py", line 1315, in _execute_task
       result = task_copy.execute(context=context)
     File "/home/airflowuser/miniconda3/lib/python3.8/site-packages/airflow/sensors/base.py", line 243, in execute
       time.sleep(self._get_next_poke_interval(started_at, run_duration, try_number))
     File "/home/airflowuser/miniconda3/lib/python3.8/site-packages/airflow/models/taskinstance.py", line 1241, in signal_handler
       raise AirflowException("Task received SIGTERM signal")
   airflow.exceptions.AirflowException: Task received SIGTERM signal
   [2021-03-15 02:50:21,242] {taskinstance.py:1496} INFO - Marking task as FAILED. dag_id=Daily_Ref_Data, task_id=at_0330_ET, execution_date=20210314T050100, start_date=20210315T065020, end_date=20210315T065021
   ```


-- 
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: commits-unsubscribe@airflow.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org