State | Dag Id | Task Id | Execution Date | Operator | Start Date | End Date | Duration | Job Id | Hostname | Unixname | Priority Weight | Queue | Queued Dttm | Try Number | Pool | Log Url | ||
---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|
success | multi_interest_tv | pca_text |
|
BashOperator |
|
|
|
dev | 6 | default |
|
1 | default_pool | |||||
success | multi_modal_movie | pca_text |
|
BashOperator |
|
|
|
dev | 6 | default |
|
1 | default_pool | |||||
success | multi_interest_ldd | train_diffurec_ldd |
|
BashOperator |
|
|
|
dev | 6 | default |
|
1 | default_pool | |||||
success | multi_interest_youku_jx_lst | update_user_click_youku_jx_lst_60days |
|
BashOperator |
|
|
|
dev | 6 | default |
|
1 | default_pool | |||||
success | multi_interest_youku_jx_lst | update_user_click_youku_jx_lst_60days |
|
BashOperator |
|
|
|
dev | 6 | default |
|
1 | default_pool | |||||
success | multi_interest_youku_jx_lst | generate_user_click_data_youku |
|
BashOperator |
|
|
|
dev | 7 | default |
|
1 | default_pool | |||||
success | multi_interest_youku_jx_lst | generate_user_click_data_youku |
|
BashOperator |
|
|
|
dev | 7 | default |
|
1 | default_pool | |||||
success | multi_interest_2024_dag | generate_diffurec_recall_result_3579 |
|
BashOperator |
|
|
|
dev | 8 | default |
|
1 | default_pool | |||||
success | multi_modal_movie | train_diffurec_movie_text |
|
BashOperator |
|
|
|
dev | 5 | default |
|
1 | default_pool | |||||
success | multi_interest_tv | train_diffurec_tv |
|
BashOperator |
|
|
|
dev | 5 | default |
|
1 | default_pool | |||||
success | airflow_tv_ls_recall | upload_recall_to_hive |
|
SparkSubmitOperator |
|
|
|
dev | 5 | default |
|
1 | default_pool | |||||
success | calculcate_ecpm_filter | vod_movie_high_ecpm_items |
|
SparkSubmitOperator |
|
|
|
dev | 5 | default |
|
1 | default_pool | |||||
success | multi_interest_2024_dag | generate_inference_dataset_012468 |
|
BashOperator |
|
|
|
dev | 6 | default |
|
1 | default_pool | |||||
success | multi_interest_2024_dag | generate_inference_dataset_vip |
|
BashOperator |
|
|
|
dev | 6 | default |
|
1 | default_pool | |||||
success | xsimgcl_recall_dag | generate_xsimgcl_recall |
|
BashOperator |
|
|
|
root | 6 | default |
|
1 | default_pool | |||||
success | xsimgcl_recall_dag | generate_xsimgcl_recall |
|
BashOperator |
|
|
|
root | 6 | default |
|
1 | default_pool | |||||
success | xsimgcl_recall_dag | generate_xsimgcl_recall |
|
BashOperator |
|
|
|
root | 6 | default |
|
1 | default_pool | |||||
success | xsimgcl_recall_dag | generate_xsimgcl_recall |
|
BashOperator |
|
|
|
root | 6 | default |
|
1 | default_pool | |||||
success | xsimgcl_recall_dag | generate_xsimgcl_recall |
|
BashOperator |
|
|
|
root | 6 | default |
|
1 | default_pool | |||||
success | xsimgcl_recall_dag | generate_xsimgcl_recall |
|
BashOperator |
|
|
|
dev | 6 | default |
|
1 | default_pool | |||||
success | airflow_tv_ls_recall | get_mv_training_data_to_local |
|
SparkSubmitOperator |
|
|
|
dev | 6 | default |
|
1 | default_pool | |||||
success | multi_modal_movie | get_pretrained_image_embedding |
|
BashOperator |
|
|
|
dev | 6 | default |
|
1 | default_pool | |||||
success | multi_interest_tv | get_pretrained_text_embedding |
|
BashOperator |
|
|
|
dev | 7 | default |
|
1 | default_pool | |||||
success | multi_modal_movie | get_pretrained_text_embedding |
|
BashOperator |
|
|
|
dev | 7 | default |
|
1 | default_pool | |||||
success | multi_modal_movie | get_pretrained_text_embedding |
|
BashOperator |
|
|
|
dev | 7 | default |
|
1 | default_pool | |||||
success | multi_interest_ldd | pca_text_image |
|
BashOperator |
|
|
|
dev | 7 | default |
|
1 | default_pool | |||||
success | airflow_tv_ls_recall | run_sdm |
|
BashOperator |
|
|
|
dev | 7 | default |
|
1 | default_pool | |||||
success | multi_interest_2024_dag | train_diffurec_vip |
|
BashOperator |
|
|
|
dev | 7 | default |
|
1 | default_pool | |||||
success | airflow_tv_ls_recall | update_media_mv |
|
SparkSubmitOperator |
|
|
|
dev | 7 | default |
|
1 | default_pool | |||||
success | xsimgcl_recall_dag | xsimgcl_train |
|
BashOperator |
|
|
|
root | 7 | default |
|
1 | default_pool | |||||
success | xsimgcl_recall_dag | xsimgcl_train |
|
BashOperator |
|
|
|
root | 7 | default |
|
1 | default_pool | |||||
success | xsimgcl_recall_dag | xsimgcl_train |
|
BashOperator |
|
|
|
root | 7 | default |
|
1 | default_pool | |||||
success | xsimgcl_recall_dag | xsimgcl_train |
|
BashOperator |
|
|
|
root | 7 | default |
|
1 | default_pool | |||||
success | xsimgcl_recall_dag | xsimgcl_train |
|
BashOperator |
|
|
|
root | 7 | default |
|
1 | default_pool | |||||
success | xsimgcl_recall_dag | xsimgcl_train |
|
BashOperator |
|
|
|
dev | 7 | default |
|
1 | default_pool | |||||
success | vod_post_processing | check_result |
|
BashOperator |
|
|
|
dev | 8 | default |
|
1 | default_pool | |||||
success | airflow_tv_ls_recall | filter_aid |
|
BashOperator |
|
|
|
dev | 8 | default |
|
1 | default_pool | |||||
upstream_failed | multi_interest_2024_dag | generate_diffurec_recall_result_i2i |
|
BashOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
upstream_failed | multi_interest_2024_dag | generate_diffurec_recall_result_i2i |
|
BashOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
upstream_failed | multi_interest_2024_dag | generate_diffurec_recall_result_i2i |
|
BashOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
upstream_failed | train_causimgcl | generate_recall |
|
BashOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
upstream_failed | train_causimgcl | generate_recall |
|
BashOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
upstream_failed | generate_training_labels | generate_training_label_pos |
|
BashOperator |
|
|
|
root | 1 | default |
|
1 | default_pool | |||||
upstream_failed | generate_training_labels | generate_training_label_pos |
|
BashOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
upstream_failed | eges_model_data_preparation | get_basecid_cidlist_ldd_local |
|
SparkSubmitOperator |
|
|
|
root | 1 | default |
|
1 | default_pool | |||||
upstream_failed | eges_model_data_preparation | get_basecid_cidlist_ldd_local |
|
SparkSubmitOperator |
|
|
|
root | 1 | default |
|
1 | default_pool | |||||
upstream_failed | eges_model_data_preparation | get_basecid_cidlist_ldd_local |
|
SparkSubmitOperator |
|
|
|
root | 1 | default |
|
1 | default_pool | |||||
upstream_failed | eges_model_data_preparation | get_click_30days_ldd_local |
|
SparkSubmitOperator |
|
|
|
root | 1 | default |
|
1 | default_pool | |||||
upstream_failed | eges_model_data_preparation | get_click_30days_ldd_local |
|
SparkSubmitOperator |
|
|
|
root | 1 | default |
|
1 | default_pool | |||||
upstream_failed | eges_model_data_preparation | get_click_30days_ldd_local |
|
SparkSubmitOperator |
|
|
|
root | 1 | default |
|
1 | default_pool | |||||
upstream_failed | eges_model_data_preparation | get_click_seq_60days_local |
|
SparkSubmitOperator |
|
|
|
root | 1 | default |
|
1 | default_pool | |||||
upstream_failed | eges_model_data_preparation | get_click_seq_60days_local |
|
SparkSubmitOperator |
|
|
|
root | 1 | default |
|
1 | default_pool | |||||
upstream_failed | eges_model_data_preparation | get_click_seq_60days_local |
|
SparkSubmitOperator |
|
|
|
root | 1 | default |
|
1 | default_pool | |||||
upstream_failed | eges_model_data_preparation | get_monitor_scene_media_local |
|
SparkSubmitOperator |
|
|
|
root | 1 | default |
|
1 | default_pool | |||||
upstream_failed | eges_model_data_preparation | get_monitor_scene_media_local |
|
SparkSubmitOperator |
|
|
|
root | 1 | default |
|
1 | default_pool | |||||
upstream_failed | eges_model_data_preparation | get_monitor_scene_media_local |
|
SparkSubmitOperator |
|
|
|
root | 1 | default |
|
1 | default_pool | |||||
upstream_failed | update_newly_activated_users | get_newly_activated_users_to_local |
|
SparkSubmitOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
upstream_failed | update_newly_activated_users | get_rec_movie_multi_channel_dnum_with_launcher_to_local |
|
SparkSubmitOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
upstream_failed | update_rec_movie_dnum_rr | get_rec_movie_tv_comic_to_local |
|
SparkSubmitOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
upstream_failed | eges_model_data_preparation | get_replace_ldd_local |
|
SparkSubmitOperator |
|
|
|
root | 1 | default |
|
1 | default_pool | |||||
upstream_failed | eges_model_data_preparation | get_replace_ldd_local |
|
SparkSubmitOperator |
|
|
|
root | 1 | default |
|
1 | default_pool | |||||
upstream_failed | eges_model_data_preparation | get_replace_ldd_local |
|
SparkSubmitOperator |
|
|
|
root | 1 | default |
|
1 | default_pool | |||||
upstream_failed | airflow_xxl_ls_recall | merge_xxl |
|
SparkSubmitOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
upstream_failed | multi_interest_2024_dag | pca_text_image_vip |
|
BashOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
upstream_failed | multi_interest_2024_dag | pca_text_image_vip |
|
BashOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
upstream_failed | multi_interest_2024_dag | pca_text_image_vip |
|
BashOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
upstream_failed | vod_multi_recall_comic.py | run_multirecall_filter_nodrop |
|
BashOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
upstream_failed | multi_interest_jx_feed | save_jx_feed_recall_to_hive |
|
SparkSubmitOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
upstream_failed | multi_interest_jx_feed | save_jx_feed_recall_to_hive_v2 |
|
SparkSubmitOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
upstream_failed | multi_interest_jx_feed | save_jx_feed_recall_to_hive_v2 |
|
SparkSubmitOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
upstream_failed | multi_interest_jx_feed | save_jx_feed_recall_to_hive_v2 |
|
SparkSubmitOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
upstream_failed | multi_interest_ldd | save_ldd_recall_to_hive |
|
SparkSubmitOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
upstream_failed | multi_interest_ldd | save_ldd_recall_to_hive |
|
SparkSubmitOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
upstream_failed | multi_interest_ldd | save_ldd_recall_to_hive |
|
SparkSubmitOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
upstream_failed | xsimgcl_recall_ldd | save_ldd_recall_to_hive |
|
SparkSubmitOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
upstream_failed | xsimgcl_recall_ldd | save_ldd_recall_to_hive |
|
SparkSubmitOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
upstream_failed | xsimgcl_recall_ldd | save_ldd_recall_to_hive |
|
SparkSubmitOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
upstream_failed | multi_interest_ldd | save_ldd_recall_to_hive_jx_lst |
|
SparkSubmitOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
upstream_failed | multi_interest_ldd | save_ldd_recall_to_hive_jx_lst |
|
SparkSubmitOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
upstream_failed | multi_interest_ldd | save_ldd_recall_to_hive_jx_lst |
|
SparkSubmitOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
upstream_failed | eges_model_data_preparation | save_media_status |
|
BashOperator |
|
|
|
root | 1 | default |
|
1 | default_pool | |||||
upstream_failed | eges_model_data_preparation | save_media_status |
|
BashOperator |
|
|
|
root | 1 | default |
|
1 | default_pool | |||||
upstream_failed | eges_model_data_preparation | save_media_status |
|
BashOperator |
|
|
|
root | 1 | default |
|
1 | default_pool | |||||
upstream_failed | multi_modal_movie | save_movie_recall_to_hive |
|
SparkSubmitOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
upstream_failed | multi_modal_movie | save_movie_recall_to_hive |
|
SparkSubmitOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
upstream_failed | multi_modal_movie | save_movie_recall_to_hive |
|
SparkSubmitOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
upstream_failed | user_rationales | save_rationales_vip_to_hive |
|
SparkSubmitOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
upstream_failed | xsimgcl_recall | save_recall_to_hive_rr |
|
SparkSubmitOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
upstream_failed | xsimgcl_recall | save_recall_to_hive_rr |
|
SparkSubmitOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
upstream_failed | xsimgcl_recall | save_recall_to_hive_rr |
|
SparkSubmitOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
upstream_failed | multi_interest_tv | save_tv_recall_to_hive |
|
SparkSubmitOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
upstream_failed | multi_interest_tv | save_tv_recall_to_hive |
|
SparkSubmitOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
upstream_failed | multi_interest_tv | save_tv_recall_to_hive |
|
SparkSubmitOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
upstream_failed | multi_interest_2024_dag | save_user_click_seq_to_hive |
|
SparkSubmitOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
upstream_failed | multi_interest_2024_dag | save_user_click_seq_to_hive |
|
SparkSubmitOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
upstream_failed | multi_interest_2024_dag | save_user_click_seq_to_hive |
|
SparkSubmitOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
upstream_failed | multi_interest_youku_jx_lst | save_user_click_youku_seq_to_hive |
|
SparkSubmitOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
upstream_failed | multi_interest_youku_jx_lst | save_user_click_youku_seq_to_hive |
|
SparkSubmitOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
upstream_failed | multi_interest_youku_jx_lst | save_user_click_youku_seq_to_hive |
|
SparkSubmitOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
upstream_failed | multi_interest_2024_dag | update_content_embedding_jx_feed |
|
BashOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool |