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 | ||
---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|
None | multi_interest_2024_dag | generate_diffurec_recall_result_i2i |
|
BashOperator |
|
|
|
dev | 2 | default |
|
1 | default_pool | |||||
success | 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 | 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 | |||||
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 | |||||
upstream_failed | multi_modal_movie | generate_diffurec_recall_result_movie |
|
BashOperator |
|
|
|
dev | 3 | default |
|
1 | default_pool | |||||
upstream_failed | multi_modal_movie | generate_diffurec_recall_result_movie |
|
BashOperator |
|
|
|
dev | 3 | default |
|
1 | default_pool | |||||
upstream_failed | multi_modal_movie | generate_diffurec_recall_result_movie |
|
BashOperator |
|
|
|
dev | 3 | default |
|
1 | default_pool | |||||
upstream_failed | 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 | airflow_tv_ls_recall | update_media_mv |
|
SparkSubmitOperator |
|
|
|
dev | 7 | 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_xxl_ls_recall | update_media_xxl |
|
BashOperator |
|
|
|
dev | 4 | default |
|
1 | default_pool | |||||
success | airflow_xxl_ls_recall | update_media_xxl_all |
|
BashOperator |
|
|
|
dev | 4 | default |
|
1 | default_pool | |||||
success | multi_interest_ldd | train_diffurec_ldd |
|
BashOperator |
|
|
|
dev | 6 | default |
|
1 | default_pool | |||||
upstream_failed | multi_interest_ldd | train_diffurec_ldd |
|
BashOperator |
|
|
|
dev | 6 | default |
|
1 | default_pool | |||||
success | multi_modal_movie | train_diffurec_movie |
|
BashOperator |
|
|
|
dev | 5 | default |
|
1 | default_pool | |||||
upstream_failed | multi_modal_movie | train_diffurec_movie |
|
BashOperator |
|
|
|
dev | 5 | 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 | 4 | default |
|
1 | default_pool | |||||
success | multi_interest_tv | train_diffurec_tv |
|
BashOperator |
|
|
|
dev | 5 | default |
|
1 | default_pool | |||||
upstream_failed | multi_interest_tv | train_diffurec_tv |
|
BashOperator |
|
|
|
dev | 5 | default |
|
1 | default_pool | |||||
success | multi_interest_youku_jx_lst | save_youku_jx_lst_recall_to_hive |
|
SparkSubmitOperator |
|
|
|
dev | 2 | default |
|
1 | default_pool | |||||
upstream_failed | multi_interest_youku_jx_lst | save_youku_jx_lst_recall_to_hive |
|
SparkSubmitOperator |
|
|
|
dev | 2 | default |
|
1 | default_pool | |||||
upstream_failed | multi_interest_youku_jx_lst | save_youku_jx_lst_recall_to_hive |
|
SparkSubmitOperator |
|
|
|
dev | 2 | default |
|
1 | default_pool | |||||
upstream_failed | multi_interest_youku_jx_lst | save_youku_jx_lst_recall_to_hive |
|
SparkSubmitOperator |
|
|
|
dev | 2 | default |
|
1 | default_pool | |||||
upstream_failed | multi_interest_youku_jx_lst | save_youku_jx_lst_recall_to_hive |
|
SparkSubmitOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
removed | airflow_tv_ls_recall | sim_paid_mv |
|
BashOperator |
|
|
|
dev | 4 | default |
|
1 | default_pool | |||||
upstream_failed | multi_interest_2024_dag | train_diffurec |
|
BashOperator |
|
|
|
dev | 6 | default |
|
1 | default_pool | |||||
success | multi_interest_jx_feed | train_diffurec_jx_feed |
|
BashOperator |
|
|
|
dev | 4 | default |
|
1 | default_pool | |||||
upstream_failed | multi_interest_jx_feed | train_diffurec_jx_feed |
|
BashOperator |
|
|
|
dev | 4 | default |
|
1 | default_pool | |||||
upstream_failed | multi_interest_jx_feed | train_diffurec_jx_feed_novip |
|
BashOperator |
|
|
|
dev | 4 | default |
|
1 | default_pool | |||||
success | multi_interest_tv | train_diffurec_tv_vip |
|
BashOperator |
|
|
|
dev | 4 | default |
|
1 | default_pool | |||||
upstream_failed | multi_interest_tv | train_diffurec_tv_vip |
|
BashOperator |
|
|
|
dev | 4 | default |
|
1 | default_pool | |||||
success | multi_interest_2024_dag | train_diffurec_vip |
|
BashOperator |
|
|
|
dev | 7 | default |
|
1 | default_pool | |||||
upstream_failed | multi_interest_2024_dag | train_diffurec_vip |
|
BashOperator |
|
|
|
dev | 7 | default |
|
1 | default_pool | |||||
upstream_failed | multi_interest_2024_dag | train_diffurec_vip |
|
BashOperator |
|
|
|
dev | 7 | default |
|
1 | default_pool | |||||
upstream_failed | multi_interest_2024_dag | train_diffurec_vip |
|
BashOperator |
|
|
|
dev | 7 | default |
|
1 | default_pool | |||||
upstream_failed | multi_interest_2024_dag | train_diffurec_vip |
|
BashOperator |
|
|
|
dev | 6 | default |
|
1 | default_pool | |||||
success | multi_interest_youku_jx_lst | train_diffurec_youku_jx_lst |
|
BashOperator |
|
|
|
dev | 4 | default |
|
1 | default_pool | |||||
success | multi_interest_youku_jx_lst | train_diffurec_youku_jx_lst |
|
BashOperator |
|
|
|
dev | 4 | default |
|
1 | default_pool | |||||
upstream_failed | multi_interest_youku_jx_lst | train_diffurec_youku_jx_lst_novip |
|
BashOperator |
|
|
|
dev | 4 | default |
|
1 | default_pool | |||||
upstream_failed | multi_interest_youku_jx_lst | train_diffurec_youku_jx_lst_vip |
|
BashOperator |
|
|
|
dev | 4 | default |
|
1 | default_pool | |||||
upstream_failed | multi_interest_2024_dag | train_llm_diffurec_v2 |
|
BashOperator |
|
|
|
dev | 13 | default |
|
1 | default_pool | |||||
removed | multi_interest_2024_dag | save_recall_to_hive_v2 |
|
SparkSubmitOperator |
|
|
|
dev | 3 | default |
|
1 | default_pool | |||||
success | multi_interest_tv | save_tv_recall_to_hive |
|
SparkSubmitOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
success | multi_interest_tv | save_tv_recall_to_hive |
|
SparkSubmitOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
success | 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_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 | |||||
success | multi_interest_youku_jx_lst | save_youku_jx_lst_recall_to_hive |
|
SparkSubmitOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
success | multi_interest_youku_jx_lst | save_youku_jx_lst_recall_to_hive |
|
SparkSubmitOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
upstream_failed | multi_interest_2024_dag | update_jx_feed_media_v2 |
|
BashOperator |
|
|
|
dev | 2 | default |
|
1 | default_pool | |||||
upstream_failed | multi_interest_2024_dag | update_jx_lst_media_v2 |
|
BashOperator |
|
|
|
dev | 4 | 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 | |||||
upstream_failed | multi_interest_2024_dag | update_content_embedding |
|
BashOperator |
|
|
|
dev | 3 | default |
|
1 | default_pool | |||||
upstream_failed | multi_interest_2024_dag | update_content_embedding_jx_feed |
|
BashOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
removed | compute_media_feature_score | update_feature_encoder_child |
|
BashOperator |
|
|
|
dev | 1 | default |
|
1 | default_pool | |||||
success | compute_media_feature_score | update_feature_encoder_comic |
|
BashOperator |
|
|
|
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 | |||||
upstream_failed | multi_interest_jx_feed | get_pretrained_image_embedding_minicpm_jx_feed_sep |
|
BashOperator |
|
|
|
dev | 6 | default |
|
1 | default_pool | |||||
success | multi_interest_ldd | get_pretrained_image_embedding_minicpm_ldd |
|
BashOperator |
|
|
|
dev | 8 | default |
|
1 | default_pool | |||||
upstream_failed | multi_interest_ldd | get_pretrained_image_embedding_minicpm_ldd |
|
BashOperator |
|
|
|
dev | 8 | default |
|
1 | default_pool | |||||
upstream_failed | multi_interest_2024_dag | get_pretrained_image_embedding_minicpm_sep |
|
BashOperator |
|
|
|
dev | 15 | default |
|
1 | default_pool | |||||
success | multi_interest_2024_dag | get_pretrained_image_embedding_minicpm_vip |
|
BashOperator |
|
|
|
dev | 2 | default |
|
1 | default_pool | |||||
upstream_failed | multi_interest_2024_dag | get_pretrained_image_embedding_minicpm_vip |
|
BashOperator |
|
|
|
dev | 2 | default |
|
1 | default_pool | |||||
upstream_failed | multi_interest_2024_dag | get_pretrained_image_embedding_minicpm_vip |
|
BashOperator |
|
|
|
dev | 2 | default |
|
1 | default_pool | |||||
upstream_failed | multi_interest_2024_dag | get_pretrained_image_embedding_minicpm_vip |
|
BashOperator |
|
|
|
dev | 2 | default |
|
1 | default_pool | |||||
upstream_failed | multi_interest_2024_dag | get_pretrained_image_embedding_minicpm_vip |
|
BashOperator |
|
|
|
dev | 2 | default |
|
1 | default_pool | |||||
upstream_failed | multi_interest_youku_jx_lst | get_pretrained_image_embedding_minicpm_youku_vip |
|
BashOperator |
|
|
|
dev | 6 | default |
|
1 | default_pool | |||||
success | multi_interest_tv | get_pretrained_text_embedding |
|
BashOperator |
|
|
|
dev | 7 | default |
|
1 | default_pool | |||||
upstream_failed | 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 | |||||
upstream_failed | multi_modal_movie | get_pretrained_text_embedding |
|
BashOperator |
|
|
|
dev | 7 | 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 |