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 | 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 | multi_interest_2024_dag | generate_diffurec_recall_result_i2i |
|
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 | 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 | vod_rr | update_media_text_embedding_v2 |
|
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 | |||||
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 | multi_modal_movie | generate_diffurec_recall_result_movie |
|
BashOperator |
|
|
|
dev | 3 | default |
|
1 | default_pool | |||||
success | multi_modal_movie | generate_diffurec_recall_result_movie |
|
BashOperator |
|
|
|
dev | 3 | default |
|
1 | default_pool | |||||
success | multi_modal_movie | generate_diffurec_recall_result_movie_text |
|
BashOperator |
|
|
|
dev | 3 | default |
|
1 | default_pool | |||||
success | multi_interest_tv | generate_diffurec_recall_result_tv |
|
BashOperator |
|
|
|
dev | 3 | default |
|
1 | default_pool | |||||
success | multi_interest_tv | generate_diffurec_recall_result_tv |
|
BashOperator |
|
|
|
dev | 3 | default |
|
1 | default_pool | |||||
success | multi_interest_youku_jx_lst | generate_diffurec_recall_result_vip |
|
BashOperator |
|
|
|
dev | 3 | default |
|
1 | default_pool | |||||
success | multi_interest_jx_feed | generate_inference_dataset |
|
BashOperator |
|
|
|
dev | 3 | default |
|
1 | default_pool | |||||
success | multi_interest_youku_jx_lst | generate_inference_dataset |
|
BashOperator |
|
|
|
dev | 3 | default |
|
1 | default_pool | |||||
success | multi_interest_youku_jx_lst | generate_inference_dataset |
|
BashOperator |
|
|
|
dev | 3 | default |
|
1 | default_pool | |||||
success | matching_model_data_preparation_rr | get_base_aid_cid_click_expose_count_1_7_days_ldd_trex_local |
|
SparkSubmitOperator |
|
|
|
root | 2 | default |
|
1 | default_pool | |||||
success | matching_model_data_preparation_rr | get_base_aid_cid_click_expose_count_1_7_days_ldd_trex_local |
|
SparkSubmitOperator |
|
|
|
root | 2 | default |
|
1 | default_pool | |||||
success | matching_model_data_preparation_rr | get_base_aid_cid_click_expose_count_1_7_days_ldd_trex_local |
|
SparkSubmitOperator |
|
|
|
root | 2 | default |
|
1 | default_pool | |||||
success | matching_model_data_preparation_rr | get_base_aid_cid_click_expose_count_1_7_days_ldd_trex_local |
|
SparkSubmitOperator |
|
|
|
root | 2 | default |
|
1 | default_pool | |||||
success | basecid_cid_click_expose | get_base_aid_cid_click_expose_count_ndays_v2 |
|
SparkSubmitOperator |
|
|
|
dev | 2 | default |
|
1 | default_pool | |||||
success | eges_model_data_preparation | get_click_30days_ldd_hive |
|
SparkSubmitOperator |
|
|
|
root | 2 | default |
|
1 | default_pool | |||||
success | eges_model_data_preparation | get_click_30days_ldd_hive |
|
SparkSubmitOperator |
|
|
|
root | 2 | default |
|
1 | default_pool | |||||
success | calculcate_ecpm_filter | get_ecpm_filter_to_local |
|
SparkSubmitOperator |
|
|
|
dev | 2 | default |
|
1 | default_pool | |||||
success | ab_testing_evaluation | get_eval_results_to_local |
|
BashOperator |
|
|
|
dev | 2 | default |
|
1 | default_pool | |||||
success | multi_interest_2024_dag | get_pretrained_image_embedding_minicpm_vip |
|
BashOperator |
|
|
|
dev | 2 | default |
|
1 | default_pool | |||||
success | multi_interest_ldd | get_top300_aids |
|
BashOperator |
|
|
|
dev | 2 | default |
|
1 | default_pool | |||||
success | calculcate_ecpm_filter | ldd_cvr_table |
|
SparkSubmitOperator |
|
|
|
dev | 2 | default |
|
1 | default_pool | |||||
success | airflow_jx_ls_recall | merge_recall |
|
BashOperator |
|
|
|
dev | 2 | default |
|
1 | default_pool | |||||
success | airflow_jx_ls_recall | merge_recall |
|
BashOperator |
|
|
|
dev | 2 | default |
|
1 | default_pool | |||||
success | airflow_jx_ls_recall | merge_recall |
|
BashOperator |
|
|
|
dev | 2 | default |
|
1 | default_pool | |||||
success | airflow_ldd_ls_recall | merge_recall |
|
BashOperator |
|
|
|
dev | 2 | default |
|
1 | default_pool | |||||
success | airflow_ldd_ls_recall | merge_recall |
|
BashOperator |
|
|
|
dev | 2 | default |
|
1 | default_pool | |||||
success | airflow_xxl_ls_recall | merge_recall |
|
BashOperator |
|
|
|
dev | 2 | default |
|
1 | default_pool | |||||
success | airflow_tv_ls_recall | merge_recall_1 |
|
BashOperator |
|
|
|
dev | 2 | default |
|
1 | default_pool | |||||
success | airflow_tv_ls_recall | merge_recall_1 |
|
BashOperator |
|
|
|
dev | 2 | default |
|
1 | default_pool | |||||
success | airflow_tv_ls_recall | merge_recall_1 |
|
BashOperator |
|
|
|
dev | 2 | default |
|
1 | default_pool | |||||
success | multi_interest_tv | generate_diffurec_recall_result_tv |
|
BashOperator |
|
|
|
dev | 2 | default |
|
1 | default_pool | |||||
success | multi_interest_tv | generate_diffurec_recall_result_tv_vip |
|
BashOperator |
|
|
|
dev | 2 | default |
|
1 | default_pool | |||||
success | multi_interest_tv | generate_diffurec_recall_result_tv_vip |
|
BashOperator |
|
|
|
dev | 2 | default |
|
1 | default_pool | |||||
success | multi_interest_2024_dag | generate_inference_dataset_i2i |
|
BashOperator |
|
|
|
dev | 2 | default |
|
1 | default_pool | |||||
success | multi_interest_tv | generate_inference_dataset_tv |
|
BashOperator |
|
|
|
dev | 3 | default |
|
1 | default_pool | |||||
success | multi_interest_tv | generate_inference_dataset_tv_vip |
|
BashOperator |
|
|
|
dev | 3 | default |
|
1 | default_pool | |||||
success | multi_interest_tv | generate_inference_dataset_tv_vip |
|
BashOperator |
|
|
|
dev | 3 | default |
|
1 | default_pool | |||||
success | multi_interest_youku_jx_lst | generate_llm_diffurec_recall_result_014578 |
|
BashOperator |
|
|
|
dev | 3 | default |
|
1 | default_pool | |||||
success | xsimgcl_recall_dag | generate_training_data_03 |
|
BashOperator |
|
|
|
root | 3 | default |
|
1 | default_pool | |||||
success | xsimgcl_recall_dag | generate_training_data_03 |
|
BashOperator |
|
|
|
root | 3 | default |
|
1 | default_pool | |||||
success | xsimgcl_recall_dag | generate_training_data_03 |
|
BashOperator |
|
|
|
root | 3 | default |
|
1 | default_pool | |||||
success | xsimgcl_recall_dag | generate_training_data_03 |
|
BashOperator |
|
|
|
root | 3 | default |
|
1 | default_pool | |||||
success | xsimgcl_recall_dag | generate_training_data_03 |
|
BashOperator |
|
|
|
root | 3 | default |
|
1 | default_pool | |||||
success | xsimgcl_recall_dag | generate_training_data_03 |
|
BashOperator |
|
|
|
dev | 3 | default |
|
1 | default_pool | |||||
success | xsimgcl_recall | generate_xsimgcl_recall_novip_rr |
|
BashOperator |
|
|
|
dev | 3 | default |
|
1 | default_pool | |||||
success | 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 | |||||
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 |