[
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 without sending email (was: Taks
Failed with empty Log and doesn't send email)
> Taks Failed with empty Log and without sending 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': ['[email protected]'],
> '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)
