Dependency | Reason |
---|---|
Dagrun Running | Task instance's dagrun was not in the 'running' state but in the state 'success'. |
Task Instance State | Task is in the 'success' state which is not a valid state for execution. The task must be cleared in order to be run. |
1 | cd /data/gangyanyuan/terry/terry-recsys-2024/Reland/script && /data/dev/miniconda/envs/easyrec/bin/python 2_rec_rationales.py
|
Attribute | Value |
---|---|
dag_id | user_rationales |
duration | 7885.42 |
end_date | 2025-04-05 05:11:50.358018+00:00 |
execution_date | 2025-04-04T03:00:00+00:00 |
executor_config | {} |
generate_command | <function TaskInstance.generate_command at 0x7f96ecd6bdd0> |
hostname | 10.14.1.101 |
is_premature | False |
job_id | 43006 |
key | ('user_rationales', 'rec_rationales', <Pendulum [2025-04-04T03:00:00+00:00]>, 2) |
log | <Logger airflow.task (INFO)> |
log_filepath | /data/gangyanyuan/airflow/logs/user_rationales/rec_rationales/2025-04-04T03:00:00+00:00.log |
log_url | http://localhost:9000/admin/airflow/log?execution_date=2025-04-04T03%3A00%3A00%2B00%3A00&task_id=rec_rationales&dag_id=user_rationales |
logger | <Logger airflow.task (INFO)> |
mark_success_url | http://localhost:9000/success?task_id=rec_rationales&dag_id=user_rationales&execution_date=2025-04-04T03%3A00%3A00%2B00%3A00&upstream=false&downstream=false |
max_tries | 2 |
metadata | MetaData(bind=None) |
next_try_number | 2 |
operator | BashOperator |
pid | 17986 |
pool | default_pool |
pool_slots | 1 |
prev_attempted_tries | 1 |
previous_execution_date_success | 2025-04-03 03:00:00+00:00 |
previous_start_date_success | 2025-04-04 03:00:20.056325+00:00 |
previous_ti | <TaskInstance: user_rationales.rec_rationales 2025-04-03 03:00:00+00:00 [success]> |
previous_ti_success | <TaskInstance: user_rationales.rec_rationales 2025-04-03 03:00:00+00:00 [success]> |
priority_weight | 5 |
queue | default |
queued_dttm | 2025-04-05 03:00:23.755653+00:00 |
raw | False |
run_as_user | None |
start_date | 2025-04-05 03:00:24.937982+00:00 |
state | success |
task | <Task(BashOperator): rec_rationales> |
task_id | rec_rationales |
test_mode | False |
try_number | 2 |
unixname | dev |
Attribute | Value |
---|---|
dag | <DAG: user_rationales> |
dag_id | user_rationales |
depends_on_past | False |
deps | {<TIDep(Not In Retry Period)>, <TIDep(Not Previously Skipped)>, <TIDep(Previous Dagrun State)>, <TIDep(Trigger Rule)>} |
do_xcom_push | True |
downstream_list | [<Task(SparkSubmitOperator): save_rationales_to_hive>, <Task(BashOperator): user_clustering_vip>] |
downstream_task_ids | {'save_rationales_to_hive', 'user_clustering_vip'} |
['tian23.li@tcl.com'] | |
email_on_failure | True |
email_on_retry | True |
end_date | None |
env | None |
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 | None |
on_retry_callback | None |
on_success_callback | None |
operator_extra_link_dict | {} |
operator_extra_links | () |
outlets | [] |
output_encoding | utf-8 |
owner | Terry |
params | {} |
pool | default_pool |
pool_slots | 1 |
priority_weight | 1 |
priority_weight_total | 5 |
queue | default |
resources | None |
retries | 2 |
retry_delay | 0:08:00 |
retry_exponential_backoff | False |
run_as_user | None |
schedule_interval | 00 11 * * * |
shallow_copy_attrs | () |
sla | None |
start_date | 2025-02-17T00:00:00+00:00 |
sub_process | None |
subdag | None |
task_concurrency | None |
task_id | rec_rationales |
task_type | BashOperator |
template_ext | ('.sh', '.bash') |
template_fields | ('bash_command', 'env') |
trigger_rule | all_success |
ui_color | #f0ede4 |
ui_fgcolor | #000 |
upstream_list | [<Task(BashOperator): user_clustering>] |
upstream_task_ids | {'user_clustering'} |
wait_for_downstream | False |
weight_rule | downstream |
xcom_push_flag | False |