You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by "Chandu Kavar (JIRA)" <ji...@apache.org> on 2018/09/19 03:19:00 UTC

[jira] [Created] (AIRFLOW-3087) Task stuck in UP_FOR_RETRY and continuously showing Not In Retry Period

Chandu Kavar created AIRFLOW-3087:
-------------------------------------

             Summary: Task stuck in UP_FOR_RETRY and continuously showing Not In Retry Period
                 Key: AIRFLOW-3087
                 URL: https://issues.apache.org/jira/browse/AIRFLOW-3087
             Project: Apache Airflow
          Issue Type: Bug
          Components: scheduler
    Affects Versions: 1.9.0
            Reporter: Chandu Kavar
         Attachments: Screen Shot 2018-09-19 at 10.27.25 AM.png

Hi,

We are facing issues with "up_for_retry" of the task in few DAGs. When the task failed and scheduler picks up for "up_for_retry", it got stuck. In task instance details we see this log when the retry time appears:

{{All dependencies are met but the task instance is not running. In most cases this just means that the task will probably be scheduled soon unless: - The scheduler is down or under heavy load If this task instance does not start soon please contact your Airflow administrator for assistance.}}

after retry delay again it shows (and it keep showing this log):

{{Not In Retry Period Task is not ready for retry yet but will be retried automatically. Current date is 2018-08-29T15:xx:xxxx and task will be retrieve. }}

After an hour task is able to retry. 

Code:

 
{code:java}
from datetime import *
from airflow import DAG
from airflow.operators.python_operator import PythonOperator
from airflow.operators.bash_operator import BashOperator

default_args = {
'owner': 'Chandu',
'depends_on_past': False,
'retries': 3,
'retry_delay': timedelta(minutes=1),
'queue': 'worker_test'
}

dag = DAG('airflow-examples.test_failed_dag_v3', description='Failed DAG',
schedule_interval='*/10 * * * *',
start_date=datetime(2018, 9, 7), default_args=default_args)

b = BashOperator(
task_id="ls_command",
bash_command="mdr",
dag=dag
)
{code}
 


Tree view of the DAG:

 

!Screen Shot 2018-09-19 at 10.27.25 AM.png!



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)