DAG: campaign-flow-job_v002

schedule: 0 */1 * * *

Task Instance: trigger_dagrun_campaign-history-job_v002

Task Instance Details

Dependencies Blocking Task From Getting Scheduled
Dependency Reason
Execution Date The execution date is 2023-06-22T12:00:00+00:00 but this is before the task's start date 2024-07-14T19:00:00+00:00.
Execution Date The execution date is 2023-06-22T12:00:00+00:00 but this is before the task's DAG's start date 2024-07-14T19:00:00+00:00.
Task Instance State Task is in the 'None' state which is not a valid state for execution. The task must be cleared in order to be run.
Dag Not Paused Task's DAG 'campaign-flow-job_v002' is paused.
Trigger Rule Task's trigger rule 'all_success' requires all upstream tasks to have succeeded, but found 1 non-success(es). upstream_tasks_state={'total': 1, 'successes': 0, 'skipped': 0, 'failed': 0, 'upstream_failed': 0, 'done': 0}, upstream_task_ids={'check_cluster_status'}
Attribute: python_callable
1
No source code available for <class 'NoneType'>
Task Instance Attributes
Attribute Value
dag_id campaign-flow-job_v002
duration None
end_date None
execution_date 2023-06-22T12:00:00+00:00
executor_config {}
generate_command <function TaskInstance.generate_command at 0x7ffa4fe777b8>
hostname
is_premature False
job_id None
key ('campaign-flow-job_v002', 'trigger_dagrun_campaign-history-job_v002', <Pendulum [2023-06-22T12:00:00+00:00]>, 1)
log <Logger airflow.task (INFO)>
log_filepath /opt/airflow/logs/campaign-flow-job_v002/trigger_dagrun_campaign-history-job_v002/2023-06-22T12:00:00+00:00.log
log_url https://airflow.devel.viooh.net.cn/admin/airflow/log?execution_date=2023-06-22T12%3A00%3A00%2B00%3A00&task_id=trigger_dagrun_campaign-history-job_v002&dag_id=campaign-flow-job_v002
logger <Logger airflow.task (INFO)>
mark_success_url https://airflow.devel.viooh.net.cn/success?task_id=trigger_dagrun_campaign-history-job_v002&dag_id=campaign-flow-job_v002&execution_date=2023-06-22T12%3A00%3A00%2B00%3A00&upstream=false&downstream=false
max_tries 4
metadata MetaData(bind=None)
next_try_number 1
operator TriggerDagRunOperator
pid None
pool default_pool
pool_slots 1
prev_attempted_tries 0
previous_execution_date_success 2023-06-22 04:00:00+00:00
previous_start_date_success 2023-06-22 05:26:32.734539+00:00
previous_ti <TaskInstance: campaign-flow-job_v002.trigger_dagrun_campaign-history-job_v002 2023-06-22 11:00:00+00:00 [None]>
previous_ti_success <TaskInstance: campaign-flow-job_v002.trigger_dagrun_campaign-history-job_v002 2023-06-22 04:00:00+00:00 [success]>
priority_weight 1
queue default
queued_dttm None
raw False
run_as_user None
start_date None
state None
task <Task(TriggerDagRunOperator): trigger_dagrun_campaign-history-job_v002>
task_id trigger_dagrun_campaign-history-job_v002
test_mode False
try_number 1
unixname airflow
Task Attributes
Attribute Value
dag <DAG: campaign-flow-job_v002>
dag_id campaign-flow-job_v002
depends_on_past False
deps {<TIDep(Previous Dagrun State)>, <TIDep(Not Previously Skipped)>, <TIDep(Trigger Rule)>, <TIDep(Not In Retry Period)>}
do_xcom_push True
downstream_list []
downstream_task_ids set()
email None
email_on_failure True
email_on_retry True
end_date None
execution_date {{execution_date}}
execution_timeout None
executor_config {}
extra_links []
global_operator_extra_link_dict {}
inlets []
lineage_data None
log <Logger airflow.task.operators (INFO)>
logger <Logger airflow.task.operators (INFO)>
max_retry_delay None
on_failure_callback <function task_fail_slack_alert at 0x7ffa3fcd4a60>
on_retry_callback None
on_success_callback None
operator_extra_link_dict {}
operator_extra_links ()
outlets []
owner airflow
params {}
pool default_pool
pool_slots 1
priority_weight 1
priority_weight_total 1
queue default
resources None
retries 4
retry_delay 0:01:00
retry_exponential_backoff False
run_as_user None
schedule_interval 0 */1 * * *
shallow_copy_attrs ()
sla None
start_date 2024-07-14 19:00:00+00:00
subdag None
task_concurrency None
task_id trigger_dagrun_campaign-history-job_v002
task_type TriggerDagRunOperator
template_ext []
template_fields ('trigger_dag_id', 'execution_date')
trigger_dag_id campaign-history-job_v002
trigger_rule all_success
ui_color #ffefeb
ui_fgcolor #000
upstream_list [<Task(EmrJobFlowSensor): check_cluster_status>]
upstream_task_ids {'check_cluster_status'}
wait_for_downstream False
weight_rule downstream