Maria created AIRFLOW-3296:
------------------------------
Summary: Taks Failed without 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
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)
