airflow-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Maria (JIRA)" <j...@apache.org>
Subject [jira] [Updated] (AIRFLOW-3296) Taks Failed with empty Log and doesn't send email
Date Mon, 05 Nov 2018 13:30:00 GMT

     [ https://issues.apache.org/jira/browse/AIRFLOW-3296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]

Maria updated AIRFLOW-3296:
---------------------------
    Summary: Taks Failed with empty Log and doesn't send email  (was: Taks Failed without
empty Log and doesn't send email)

> Taks Failed with empty Log and doesn't send email
> -------------------------------------------------
>
>                 Key: AIRFLOW-3296
>                 URL: https://issues.apache.org/jira/browse/AIRFLOW-3296
>             Project: Apache Airflow
>          Issue Type: Bug
>            Reporter: Maria
>            Priority: Critical
>
> I have a DAG with 60 tasks (PythonsOperators) and in some executions different tasks
are marked as failed, but I don’t know the reason, when I go to "View Log" the log is empty
and when i pass over the red square it says Operator:null what does that mean?
>  
> It seems like it hasn't executed the task, but I don't understand why.
>  
> The questions are:
>  * Why Airflow mark it as failed but there is no execution showed on log?
>  * Why hasn't it send email of error if the tasks it's marked as failed?
>  
> Here is the python code associated to the dag:
> {code:java}
> DEFAULT_ARGS = {
> 'owner': 'blablabla',
> 'depends_on_past': False,
> 'start_date': datetime(2018, 5, 8),
> 'catchup': False,
> 'email': ['mail@mail.com'],
> 'email_on_failure': True,
> 'email_on_retry': False,
> 'retries': 3,
> 'max_active_runs': 1,
> 'retry_delay': timedelta(minutes=5)
> }
> dag = DAG('dag_name',
> default_args=DEFAULT_ARGS,
> schedule_interval='20 0 * * *')
> mylist = get_codes_list()
> for item in mylist:
> healthcheckerName = 'healthchecker_' + item
> healthchecker = PythonOperator(
> dag=dag,
> task_id=healthcheckerName,
> python_callable=prime_ops.check_last_budget_calculation(item),
> queue=SPECIFIC_QUEUE,
> pool=DEFAULT_PPC_POOL
> ){code}



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

Mime
View raw message