DAG: vod_rr vod_rr

schedule: 30 16 * * *

Task Instance: feature_engineering

Task Instance Details

Dependencies Blocking Task From Getting Scheduled
Dependency Reason
Dag Not Paused Task's DAG 'vod_rr' is paused.
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.
Attribute: bash_command
1
cd /data/gangyanyuan/terry/terry-recsys-rr/script && /data/dev/miniconda/envs/deepmatch/bin/python /data/gangyanyuan/terry/terry-recsys-rr/script_2025/feature_engineering_v2.py
Task Instance Attributes
Attribute Value
dag_id vod_rr
duration 115.891
end_date 2025-05-28 08:37:58.885072+00:00
execution_date 2025-05-27T08:30:00+00:00
executor_config {}
generate_command <function TaskInstance.generate_command at 0x7f96ecd6bdd0>
hostname 10.14.1.101
is_premature False
job_id 52739
key ('vod_rr', 'feature_engineering', <Pendulum [2025-05-27T08:30:00+00:00]>, 2)
log <Logger airflow.task (INFO)>
log_filepath /data/gangyanyuan/airflow/logs/vod_rr/feature_engineering/2025-05-27T08:30:00+00:00.log
log_url http://localhost:9000/admin/airflow/log?execution_date=2025-05-27T08%3A30%3A00%2B00%3A00&task_id=feature_engineering&dag_id=vod_rr
logger <Logger airflow.task (INFO)>
mark_success_url http://localhost:9000/success?task_id=feature_engineering&dag_id=vod_rr&execution_date=2025-05-27T08%3A30%3A00%2B00%3A00&upstream=false&downstream=false
max_tries 2
metadata MetaData(bind=None)
next_try_number 2
operator BashOperator
pid 15510
pool default_pool
pool_slots 1
prev_attempted_tries 1
previous_execution_date_success 2025-05-26 08:30:00+00:00
previous_start_date_success 2025-05-27 08:35:51.846390+00:00
previous_ti <TaskInstance: vod_rr.feature_engineering 2025-05-26 08:30:00+00:00 [success]>
previous_ti_success <TaskInstance: vod_rr.feature_engineering 2025-05-26 08:30:00+00:00 [success]>
priority_weight 2
queue default
queued_dttm 2025-05-28 08:36:01.795061+00:00
raw False
run_as_user None
start_date 2025-05-28 08:36:02.994314+00:00
state success
task <Task(BashOperator): feature_engineering>
task_id feature_engineering
test_mode False
try_number 2
unixname dev
Task Attributes
Attribute Value
dag <DAG: vod_rr>
dag_id vod_rr
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(BashOperator): generate_joint_features>]
downstream_task_ids {'generate_joint_features'}
email ['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 2
queue default
resources None
retries 2
retry_delay 0:08:00
retry_exponential_backoff False
run_as_user None
schedule_interval 30 16 * * *
shallow_copy_attrs ()
sla None
start_date 2025-03-26T00:00:00+00:00
sub_process None
subdag None
task_concurrency None
task_id feature_engineering
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): generate_training_label>]
upstream_task_ids {'generate_training_label'}
wait_for_downstream False
weight_rule downstream
xcom_push_flag False