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 | heat_online_data_preparation | get_heat_data_comic_one_hot |
|
BashOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
removed | filtered_data_preparation | get_ldd_filtered_aids_7days_local |
|
SparkSubmitOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
removed | vod_post_processing | get_ldd_ip_decision_vs_reward |
|
BashOperator |
|
|
|
dev | 28 | default |
|
1 | default_pool | |||||
removed | vod_post_processing | get_ldd_ip_performances |
|
BashOperator |
|
|
|
dev | 29 | default |
|
1 | default_pool | |||||
removed | update_rec_movie_dnum_rr | get_ldd_launcher_playpage_user |
|
BashOperator |
|
|
|
dev | 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 | |||||
success | eges_model_data_preparation | get_monitor_scene_media_local |
|
SparkSubmitOperator |
|
|
|
root | 1 | default |
|
1 | default_pool | |||||
success | eges_model_data_preparation | get_monitor_scene_media_local |
|
SparkSubmitOperator |
|
|
|
root | 1 | default |
|
1 | default_pool | |||||
success | multi_interest_ldd | get_pretrained_content_embedding_ldd |
|
BashOperator |
|
|
|
dev | 9 | default |
|
1 | default_pool | |||||
success | multi_interest_2024_dag | get_pretrained_content_embedding_vip |
|
BashOperator |
|
|
|
dev | 3 | default |
|
1 | default_pool | |||||
upstream_failed | multi_interest_2024_dag | get_pretrained_content_embedding_vip |
|
BashOperator |
|
|
|
dev | 3 | default |
|
1 | default_pool | |||||
upstream_failed | multi_interest_2024_dag | get_pretrained_content_embedding_vip |
|
BashOperator |
|
|
|
dev | 3 | default |
|
1 | default_pool | |||||
upstream_failed | multi_interest_2024_dag | get_pretrained_content_embedding_vip |
|
BashOperator |
|
|
|
dev | 3 | default |
|
1 | default_pool | |||||
success | multi_modal_movie | get_pretrained_image_embedding |
|
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 | |||||
upstream_failed | update_newly_activated_users | get_newly_activated_users_to_local |
|
SparkSubmitOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
None | calculcate_ecpm_filter | get_vod_high_ecpm_items_to_local |
|
SparkSubmitOperator |
|
|
|
dev | 3 | default |
|
1 | default_pool | |||||
success | calculcate_ecpm_filter | get_vod_high_ecpm_items_to_local |
|
SparkSubmitOperator |
|
|
|
dev | 3 | default |
|
1 | default_pool | |||||
success | airflow_xxl_ls_recall | get_xxl_traning_data_180days_to_local_ls |
|
SparkSubmitOperator |
|
|
|
dev | 6 | default |
|
1 | default_pool | |||||
success | movie_preprocess_main_rr | handle_doubaninfo_detail_v2 |
|
SparkSubmitOperator |
|
|
|
root | 1 | default |
|
1 | default_pool | |||||
success | movie_preprocess_main_rr | handle_doubaninfo_detail_v2 |
|
SparkSubmitOperator |
|
|
|
root | 1 | default |
|
1 | default_pool | |||||
success | movie_preprocess_main_rr | handle_doubaninfo_detail_v2 |
|
SparkSubmitOperator |
|
|
|
root | 1 | default |
|
1 | default_pool | |||||
success | movie_preprocess_main_rr | handle_doubaninfo_detail_v2 |
|
SparkSubmitOperator |
|
|
|
root | 1 | default |
|
1 | default_pool | |||||
success | movie_preprocess_main_rr | handle_doubaninfo_detail_v2 |
|
SparkSubmitOperator |
|
|
|
root | 1 | default |
|
1 | default_pool | |||||
success | multi_modal_movie | get_pretrained_text_embedding |
|
BashOperator |
|
|
|
dev | 7 | default |
|
1 | default_pool | |||||
success | multi_interest_tv | get_pretrained_text_embedding_vip |
|
BashOperator |
|
|
|
dev | 6 | default |
|
1 | default_pool | |||||
upstream_failed | update_newly_activated_users | get_rec_movie_multi_channel_dnum_with_launcher |
|
SparkSubmitOperator |
|
|
|
dev | 2 | 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 | |||||
success | 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 | |||||
removed | eges_model_data_preparation | get_replace_ldd_local |
|
SparkSubmitOperator |
|
|
|
root | 1 | default |
|
1 | default_pool | |||||
removed | eges_model_data_preparation | get_replace_ldd_local |
|
SparkSubmitOperator |
|
|
|
root | 1 | default |
|
1 | default_pool | |||||
success | multi_interest_ldd | get_top300_aids |
|
BashOperator |
|
|
|
dev | 2 | default |
|
1 | default_pool | |||||
success | airflow_tv_ls_recall | get_tv_sp_traning_data_to_local |
|
SparkSubmitOperator |
|
|
|
dev | 6 | default |
|
1 | default_pool | |||||
success | airflow_tv_ls_recall | get_tv_sp_traning_data_to_local_ls |
|
SparkSubmitOperator |
|
|
|
dev | 6 | default |
|
1 | default_pool | |||||
success | airflow_mv_ls_recall | upload_recall_to_hive_mv |
|
SparkSubmitOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
success | airflow_mv_ls_recall | upload_recall_to_hive_mv |
|
SparkSubmitOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
success | airflow_mv_ls_recall | upload_recall_to_hive_mv |
|
SparkSubmitOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
success | airflow_mv_ls_recall | upload_recall_to_hive_mv |
|
SparkSubmitOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
upstream_failed | airflow_mv_ls_recall | upload_recall_to_hive_mv |
|
SparkSubmitOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
upstream_failed | airflow_mv_ls_recall | upload_recall_to_hive_mv |
|
SparkSubmitOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
upstream_failed | airflow_mv_ls_recall | upload_recall_to_hive_mv |
|
SparkSubmitOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
success | airflow_tv_ls_recall | upload_recall_to_hive_mv |
|
SparkSubmitOperator |
|
|
|
dev | 2 | default |
|
1 | default_pool | |||||
upstream_failed | airflow_tv_ls_recall | upload_recall_to_hive_mv |
|
SparkSubmitOperator |
|
|
|
dev | 2 | default |
|
1 | default_pool | |||||
upstream_failed | airflow_tv_ls_recall | upload_recall_to_hive_mv |
|
SparkSubmitOperator |
|
|
|
dev | 2 | default |
|
1 | default_pool | |||||
success | airflow_tv_ls_recall | upload_recall_to_hive_mv |
|
SparkSubmitOperator |
|
|
|
dev | 2 | default |
|
1 | default_pool | |||||
upstream_failed | airflow_tv_ls_recall | upload_recall_to_hive_mv |
|
SparkSubmitOperator |
|
|
|
dev | 2 | default |
|
1 | default_pool | |||||
success | vod_post_processing | upload_results |
|
BashOperator |
|
|
|
dev | 10 | default |
|
1 | default_pool | |||||
success | vod_post_processing | upload_sparkjson_results |
|
BashOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
success | movie_preprocess_main_rr | user_click_exposure_video |
|
SparkSubmitOperator |
|
|
|
root | 2 | default |
|
1 | default_pool | |||||
success | movie_preprocess_main_rr | user_click_exposure_video |
|
SparkSubmitOperator |
|
|
|
root | 2 | default |
|
1 | default_pool | |||||
success | movie_preprocess_main_rr | user_click_exposure_video |
|
SparkSubmitOperator |
|
|
|
root | 2 | default |
|
1 | default_pool | |||||
success | movie_preprocess_main_rr | user_click_exposure_video |
|
SparkSubmitOperator |
|
|
|
root | 2 | default |
|
1 | default_pool | |||||
success | movie_preprocess_main_rr | user_click_exposure_video_fill |
|
SparkSubmitOperator |
|
|
|
root | 1 | default |
|
1 | default_pool | |||||
success | movie_preprocess_main_rr | user_click_exposure_video_fill |
|
SparkSubmitOperator |
|
|
|
root | 1 | default |
|
1 | default_pool | |||||
success | movie_preprocess_main_rr | user_click_exposure_video_fill |
|
SparkSubmitOperator |
|
|
|
root | 1 | default |
|
1 | default_pool | |||||
success | movie_preprocess_main_rr | user_click_exposure_video_fill |
|
SparkSubmitOperator |
|
|
|
root | 1 | default |
|
1 | default_pool | |||||
success | movie_preprocess_main_rr | user_click_exposure_video_ldd |
|
SparkSubmitOperator |
|
|
|
root | 2 | default |
|
1 | default_pool | |||||
success | movie_preprocess_main_rr | user_click_exposure_video_ldd |
|
SparkSubmitOperator |
|
|
|
root | 2 | default |
|
1 | default_pool | |||||
success | movie_preprocess_main_rr | user_click_exposure_video_ldd |
|
SparkSubmitOperator |
|
|
|
root | 2 | default |
|
1 | default_pool | |||||
success | movie_preprocess_main_rr | user_click_exposure_video_ldd |
|
SparkSubmitOperator |
|
|
|
root | 2 | default |
|
1 | default_pool | |||||
success | movie_preprocess_main_rr | user_click_exposure_video_ldd_local |
|
SparkSubmitOperator |
|
|
|
root | 1 | default |
|
1 | default_pool | |||||
success | movie_preprocess_main_rr | user_click_exposure_video_ldd_local |
|
SparkSubmitOperator |
|
|
|
root | 1 | default |
|
1 | default_pool | |||||
success | movie_preprocess_main_rr | user_click_exposure_video_ldd_local |
|
SparkSubmitOperator |
|
|
|
root | 1 | default |
|
1 | default_pool | |||||
success | movie_preprocess_main_rr | user_click_exposure_video_ldd_local |
|
SparkSubmitOperator |
|
|
|
root | 1 | default |
|
1 | default_pool | |||||
success | movie_preprocess_main_rr | user_click_exposure_video_ldd_local |
|
SparkSubmitOperator |
|
|
|
root | 1 | default |
|
1 | default_pool | |||||
success | user_rationales | user_clustering_vip |
|
BashOperator |
|
|
|
dev | 3 | default |
|
1 | default_pool | |||||
None | calculcate_ecpm_filter | vip_details_to_local |
|
SparkSubmitOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
success | calculcate_ecpm_filter | vip_details_to_local |
|
SparkSubmitOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
None | calculcate_ecpm_filter | vod_movie_high_ecpm_items |
|
SparkSubmitOperator |
|
|
|
dev | 5 | default |
|
1 | default_pool | |||||
success | calculcate_ecpm_filter | vod_movie_high_ecpm_items |
|
SparkSubmitOperator |
|
|
|
dev | 5 | default |
|
1 | default_pool | |||||
None | calculcate_ecpm_filter | vod_tv_high_ecpm_items |
|
SparkSubmitOperator |
|
|
|
dev | 4 | default |
|
1 | default_pool | |||||
success | calculcate_ecpm_filter | vod_tv_high_ecpm_items |
|
SparkSubmitOperator |
|
|
|
dev | 4 | 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 | xsimgcl_recall_dag | xsimgcl_train_03 |
|
BashOperator |
|
|
|
root | 2 | default |
|
1 | default_pool | |||||
success | xsimgcl_recall_dag | xsimgcl_train_03 |
|
BashOperator |
|
|
|
root | 2 | default |
|
1 | default_pool | |||||
success | xsimgcl_recall_dag | xsimgcl_train_03 |
|
BashOperator |
|
|
|
root | 2 | default |
|
1 | default_pool | |||||
success | xsimgcl_recall_dag | xsimgcl_train_03 |
|
BashOperator |
|
|
|
root | 2 | default |
|
1 | default_pool | |||||
success | xsimgcl_recall_dag | xsimgcl_train_03 |
|
BashOperator |
|
|
|
root | 2 | default |
|
1 | default_pool | |||||
success | xsimgcl_recall_dag | xsimgcl_train_03 |
|
BashOperator |
|
|
|
dev | 2 | default |
|
1 | default_pool | |||||
success | xsimgcl_recall_ldd | xsimgcl_train_ldd |
|
BashOperator |
|
|
|
dev | 1 | 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 | |||||
removed | multi_interest_jx_feed | update_youku_jx_lst_media |
|
BashOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
success | airflow_tv_ls_recall | upload_filter_recall_to_hive_mv |
|
SparkSubmitOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
upstream_failed | airflow_tv_ls_recall | upload_filter_recall_to_hive_mv |
|
SparkSubmitOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
upstream_failed | airflow_tv_ls_recall | upload_filter_recall_to_hive_mv |
|
SparkSubmitOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
success | airflow_tv_ls_recall | upload_filter_recall_to_hive_mv |
|
SparkSubmitOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
upstream_failed | airflow_tv_ls_recall | upload_filter_recall_to_hive_mv |
|
SparkSubmitOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
success | airflow_jx_ls_recall | upload_recall_to_hive |
|
SparkSubmitOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool |