DAG: multi_interest_2024_dag flow for multi-interest modeling

schedule: 10 03 * * *

success Base date: Number of runs: Run: Layout:
BashOperator
SparkSubmitOperator
no_status
queued
running
success
failed
up_for_retry
up_for_reschedule
upstream_failed
skipped
scheduled
kill_iPython_jobupdate_jx_lst_mediagenerate_user_click_dataget_ecpm_aidsupdate_user_click_all_channelname_60days_012468update_user_click_all_channelname_60days_3579generate_diffurec_dataset_all_channelname_012468generate_diffurec_dataset_all_channelname_3579get_pretrained_content_embedding_jx_lstget_pretrained_image_embedding_minicpmpca_text_imagetrain_diffurecget_pretrained_content_embedding_sepget_pretrained_image_embedding_minicpm_seppca_text_image_v2train_llm_diffurec_v2generate_inference_dataset_012468generate_inference_dataset_3579generate_diffurec_recall_result_2468generate_diffurec_recall_result_3579get_pretrained_content_embedding_vipget_pretrained_image_embedding_minicpm_vipgenerate_diffurec_dataset_all_channelname_vippca_text_image_viptrain_diffurec_vipgenerate_inference_dataset_vipgenerate_diffurec_recall_result_vipsave_recall_to_hivesave_user_click_seq_to_hiveupdate_text_embeddingupdate_content_embeddingupdate_jx_feed_mediaupdate_jx_feed_media_v2update_content_embedding_jx_feedgenerate_inference_dataset_i2igenerate_diffurec_recall_result_i2iupdate_jx_lst_media_v2 spinner
SuMoTuWeThFrSa
30123456
78910111213
14151617181920
21222324252627
28293031123
45678910
: