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 | ||
---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|
removed | eges_model_data_preparation | get_replace_ldd_local |
|
SparkSubmitOperator |
|
|
|
root | 1 | default |
|
1 | default_pool | |||||
removed | vod_post_processing | ldd_blacklists |
|
BashOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
removed | vod_post_processing | ldd_local_recall |
|
BashOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
removed | vod_post_processing | ldd_poster_recall_v2 |
|
BashOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
removed | heat_online_data_preparation | trim_cid_pool_basecid |
|
BashOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
removed | heat_online_data_preparation | trim_cid_pool_replace |
|
BashOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
removed | compute_media_feature_score | update_feature_encoder_child |
|
BashOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
removed | multi_interest_jx_feed | update_youku_jx_lst_media |
|
BashOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
removed | multi_interest_2024_dag | generate_diffurec_test_result |
|
BashOperator |
|
|
|
dev | 2 | default |
|
1 | default_pool | |||||
removed | vod_post_processing | ldd_poster_recall |
|
BashOperator |
|
|
|
dev | 2 | default |
|
1 | default_pool | |||||
removed | vod_inference_dag | ldd_r6_int_daily_title_trex_sim |
|
BashOperator |
|
|
|
dev | 2 | default |
|
1 | default_pool | |||||
removed | vod_inference_dag | ldd_r6_int_daily_title_trex_sim |
|
BashOperator |
|
|
|
dev | 2 | default |
|
1 | default_pool | |||||
removed | vod_post_processing | ldd_recall_attribution |
|
BashOperator |
|
|
|
dev | 2 | default |
|
1 | default_pool | |||||
removed | eges_model_data_preparation | get_click_60days_ldd_local |
|
SparkSubmitOperator |
|
|
|
root | 3 | default |
|
1 | default_pool | |||||
removed | eges_model_data_preparation | get_click_60days_ldd_local |
|
SparkSubmitOperator |
|
|
|
root | 3 | default |
|
1 | default_pool | |||||
removed | vod_inference_dag | ldd_r6_int_daily_title_trex |
|
BashOperator |
|
|
|
dev | 3 | default |
|
1 | default_pool | |||||
removed | vod_inference_dag | ldd_r6_int_daily_title_trex |
|
BashOperator |
|
|
|
dev | 3 | default |
|
1 | default_pool | |||||
removed | multi_interest_2024_dag | save_recall_to_hive_v2 |
|
SparkSubmitOperator |
|
|
|
dev | 3 | default |
|
1 | default_pool | |||||
removed | vod_inference_dag | ldd_r6_int_daily_title |
|
BashOperator |
|
|
|
dev | 4 | default |
|
1 | default_pool | |||||
removed | vod_inference_dag | ldd_r6_int_daily_title |
|
BashOperator |
|
|
|
dev | 4 | default |
|
1 | default_pool | |||||
removed | airflow_tv_ls_recall | sim_paid_mv |
|
BashOperator |
|
|
|
dev | 4 | default |
|
1 | default_pool | |||||
removed | vod_inference_dag | ldd_r6_inttower_daily_cold |
|
BashOperator |
|
|
|
dev | 5 | default |
|
1 | default_pool | |||||
removed | vod_post_processing | generate_ldd_ucb_v2 |
|
BashOperator |
|
|
|
dev | 7 | default |
|
1 | default_pool | |||||
removed | vod_post_processing | ldd_merge_recommendations |
|
BashOperator |
|
|
|
dev | 11 | default |
|
1 | default_pool | |||||
removed | vod_post_processing | ldd_user_bucketing |
|
BashOperator |
|
|
|
dev | 12 | default |
|
1 | default_pool | |||||
removed | vod_post_processing | ldd_pp_stop |
|
DummyOperator |
|
|
|
dev | 13 | default |
|
1 | default_pool | |||||
removed | vod_post_processing | r6_cold_end |
|
DummyOperator |
|
|
|
dev | 14 | default |
|
1 | default_pool | |||||
removed | vod_post_processing | r6_sim_end |
|
DummyOperator |
|
|
|
dev | 14 | default |
|
1 | default_pool | |||||
removed | vod_post_processing | pp_filter6_daily_cold |
|
BashOperator |
|
|
|
dev | 15 | default |
|
1 | default_pool | |||||
removed | vod_post_processing | pp_trex_usim6_daily_sim |
|
BashOperator |
|
|
|
dev | 15 | default |
|
1 | default_pool | |||||
removed | vod_post_processing | ldd_post_processing6_daily_cold |
|
BashOperator |
|
|
|
dev | 16 | default |
|
1 | default_pool | |||||
removed | vod_post_processing | pp_greedy6_daily_sim |
|
BashOperator |
|
|
|
dev | 16 | default |
|
1 | default_pool | |||||
removed | vod_post_processing | pp_replace6_daily_sim |
|
BashOperator |
|
|
|
dev | 17 | default |
|
1 | default_pool | |||||
removed | vod_post_processing | r6_cold_start |
|
DummyOperator |
|
|
|
dev | 17 | default |
|
1 | default_pool | |||||
removed | vod_post_processing | pp_mmr6_daily_sim |
|
BashOperator |
|
|
|
dev | 18 | default |
|
1 | default_pool | |||||
removed | vod_post_processing | pp_filter6_daily_sim |
|
BashOperator |
|
|
|
dev | 19 | default |
|
1 | default_pool | |||||
removed | vod_post_processing | ldd_post_processing6_daily_sim |
|
BashOperator |
|
|
|
dev | 20 | default |
|
1 | default_pool | |||||
removed | vod_post_processing | r6_sim_start |
|
DummyOperator |
|
|
|
dev | 21 | default |
|
1 | default_pool | |||||
removed | vod_post_processing | ldd_pp_start |
|
DummyOperator |
|
|
|
dev | 26 | default |
|
1 | default_pool | |||||
removed | vod_post_processing | restrict_ldd_baseCids |
|
BashOperator |
|
|
|
dev | 27 | 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 | vod_post_processing | demote_cids_generation |
|
BashOperator |
|
|
|
dev | 30 | default |
|
1 | default_pool | |||||
removed | vod_post_processing | adjust_ldd_candidates |
|
BashOperator |
|
|
|
dev | 31 | default |
|
1 | default_pool | |||||
success | ab_testing_experiment | AB_testing_experiment |
|
BashOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
success | calculcate_ecpm_filter | generate_movie_have_income_basecids |
|
BashOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
success | xsimgcl_recall_dag | generate_xsimgcl_recall_03 |
|
BashOperator |
|
|
|
root | 1 | default |
|
1 | default_pool | |||||
success | xsimgcl_recall_dag | generate_xsimgcl_recall_03 |
|
BashOperator |
|
|
|
root | 1 | default |
|
1 | default_pool | |||||
success | xsimgcl_recall_dag | generate_xsimgcl_recall_03 |
|
BashOperator |
|
|
|
root | 1 | default |
|
1 | default_pool | |||||
success | xsimgcl_recall_dag | generate_xsimgcl_recall_03 |
|
BashOperator |
|
|
|
root | 1 | default |
|
1 | default_pool | |||||
success | xsimgcl_recall_dag | generate_xsimgcl_recall_03 |
|
BashOperator |
|
|
|
root | 1 | default |
|
1 | default_pool | |||||
success | xsimgcl_recall_dag | generate_xsimgcl_recall_03 |
|
BashOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
success | ab_testing_evaluation | get_aggregate_results |
|
BashOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
success | basecid_cid_click_expose | get_base_aid_cid_click_expose_count_1_7_days_local |
|
SparkSubmitOperator |
|
|
|
root | 1 | default |
|
1 | default_pool | |||||
success | basecid_cid_click_expose | get_base_aid_cid_click_expose_count_1_7_days_local |
|
SparkSubmitOperator |
|
|
|
root | 1 | default |
|
1 | default_pool | |||||
success | eges_model_data_preparation | get_click_seq_60days_local |
|
SparkSubmitOperator |
|
|
|
root | 1 | default |
|
1 | default_pool | |||||
success | eges_model_data_preparation | get_click_seq_60days_local |
|
SparkSubmitOperator |
|
|
|
root | 1 | default |
|
1 | default_pool | |||||
success | filtered_data_preparation | get_comic_filtered_aids_7days_local |
|
SparkSubmitOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
success | filtered_data_preparation | get_comic_filtered_aids_7days_local |
|
SparkSubmitOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
success | heat_online_data_preparation | get_heat_data_comic |
|
BashOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
success | heat_online_data_preparation | get_heat_data_comic_one_hot |
|
BashOperator |
|
|
|
dev | 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 | update_newly_activated_users | get_rec_movie_multi_channel_dnum_with_launcher_to_local |
|
SparkSubmitOperator |
|
|
|
dev | 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 | movie_preprocess_main_rr | handle_doubaninfo_detail_v2 |
|
SparkSubmitOperator |
|
|
|
root | 1 | default |
|
1 | default_pool | |||||
success | vod_inference_dag | inference_stop |
|
DummyOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
success | vod_inference_dag | inference_stop |
|
DummyOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
success | eges_model_data_preparation | save_media_status |
|
BashOperator |
|
|
|
root | 1 | default |
|
1 | default_pool | |||||
success | eges_model_data_preparation | save_media_status |
|
BashOperator |
|
|
|
root | 1 | default |
|
1 | default_pool | |||||
success | multi_modal_movie | save_movie_recall_to_hive |
|
SparkSubmitOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
success | user_rationales | save_rationales_to_hive |
|
SparkSubmitOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
success | calculcate_ecpm_filter | ldd_cvr_table_to_local |
|
SparkSubmitOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
success | ab_testing_evaluation | releasename_breakdown_v2 |
|
BashOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
success | multi_interest_jx_feed | save_jx_feed_recall_to_hive |
|
SparkSubmitOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
success | multi_interest_jx_feed | save_jx_feed_recall_to_hive |
|
SparkSubmitOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
success | compute_media_feature_score | update_feature_encoder_comic |
|
BashOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
success | matching_model_data_preparation_rr | update_media_text_embedding_v2 |
|
BashOperator |
|
|
|
root | 1 | default |
|
1 | default_pool | |||||
success | matching_model_data_preparation_rr | update_media_text_embedding_v2 |
|
BashOperator |
|
|
|
root | 1 | default |
|
1 | default_pool | |||||
success | matching_model_data_preparation_rr | update_media_text_embedding_v2 |
|
BashOperator |
|
|
|
root | 1 | default |
|
1 | default_pool | |||||
success | matching_model_data_preparation_rr | update_media_text_embedding_v2 |
|
BashOperator |
|
|
|
root | 1 | default |
|
1 | default_pool | |||||
success | 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 | |||||
success | airflow_jx_ls_recall | upload_recall_to_hive |
|
SparkSubmitOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
success | airflow_jx_ls_recall | upload_recall_to_hive |
|
SparkSubmitOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
success | airflow_jx_ls_recall | upload_recall_to_hive |
|
SparkSubmitOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
success | airflow_jx_ls_recall | upload_recall_to_hive |
|
SparkSubmitOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
success | airflow_ldd_ls_recall | upload_recall_to_hive |
|
SparkSubmitOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
success | airflow_ldd_ls_recall | upload_recall_to_hive |
|
SparkSubmitOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
success | airflow_tv_ls_recall | upload_recall_to_hive |
|
SparkSubmitOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
success | airflow_tv_ls_recall | upload_recall_to_hive |
|
SparkSubmitOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
success | airflow_tv_ls_recall | upload_recall_to_hive |
|
SparkSubmitOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
success | airflow_xxl_ls_recall | upload_recall_to_hive |
|
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 | |||||
success | airflow_mv_ls_recall | upload_recall_to_hive_mv |
|
SparkSubmitOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool |