Id | Dttm | Dag Id | Task Id | Event | Execution Date | Owner | Extra |
---|---|---|---|---|---|---|---|
7327 |
|
airflow_tv_ls_recall | tree |
|
anonymous | [('dag_id', 'airflow_tv_ls_recall')] | |
7326 |
|
airflow_tv_ls_recall | tree |
|
anonymous | [('dag_id', 'airflow_tv_ls_recall')] | |
7325 |
|
airflow_tv_ls_recall | tree |
|
anonymous | [('dag_id', 'airflow_tv_ls_recall')] | |
7324 |
|
airflow_ls_recall | tree |
|
anonymous | [('dag_id', 'airflow_ls_recall')] | |
7323 |
|
eges_model_data_preparation | tree |
|
anonymous | [('dag_id', 'eges_model_data_preparation')] | |
7322 |
|
eges_model_data_preparation | tree |
|
anonymous | [('dag_id', 'eges_model_data_preparation')] | |
7321 |
|
airflow_tv_ls_recall | tree |
|
anonymous | [('dag_id', 'airflow_tv_ls_recall')] | |
7320 |
|
airflow_tv_ls_recall | tree |
|
anonymous | [('dag_id', 'airflow_tv_ls_recall')] | |
7319 |
|
remove_history_files | remove_history_files_2024 | get_logs_with_metadata |
|
anonymous | [('dag_id', 'remove_history_files'), ('task_id', 'remove_history_files_2024'), ('execution_date', '2024-04-23T03:00:00+00:00'), ('try_number', '1'), ('metadata', 'null')] |
7318 |
|
remove_history_files | remove_history_files_2024 | log |
|
anonymous | [('task_id', 'remove_history_files_2024'), ('dag_id', 'remove_history_files'), ('execution_date', '2024-04-23T03:00:00+00:00'), ('format', 'json')] |
7317 |
|
remove_history_files | remove_history_files | get_logs_with_metadata |
|
anonymous | [('dag_id', 'remove_history_files'), ('task_id', 'remove_history_files'), ('execution_date', '2024-04-23T03:00:00+00:00'), ('try_number', '1'), ('metadata', 'null')] |
7316 |
|
remove_history_files | remove_history_files | get_logs_with_metadata |
|
anonymous | [('dag_id', 'remove_history_files'), ('task_id', 'remove_history_files'), ('execution_date', '2024-04-23T03:00:00+00:00'), ('try_number', '2'), ('metadata', 'null')] |
7315 |
|
remove_history_files | remove_history_files | log |
|
anonymous | [('task_id', 'remove_history_files'), ('dag_id', 'remove_history_files'), ('execution_date', '2024-04-23T03:00:00+00:00'), ('format', 'json')] |
7314 |
|
remove_history_files | tree |
|
anonymous | [('dag_id', 'remove_history_files')] | |
7313 |
|
airflow_tv_ls_recall | get_mv_training_data_to_local | get_logs_with_metadata |
|
anonymous | [('dag_id', 'airflow_tv_ls_recall'), ('task_id', 'get_mv_training_data_to_local'), ('execution_date', '2024-04-22T23:00:00+00:00'), ('try_number', '1'), ('metadata', 'null')] |
7312 |
|
airflow_tv_ls_recall | get_mv_training_data_to_local | log |
|
anonymous | [('task_id', 'get_mv_training_data_to_local'), ('dag_id', 'airflow_tv_ls_recall'), ('execution_date', '2024-04-22T23:00:00+00:00'), ('format', 'json')] |
7311 |
|
airflow_tv_ls_recall | get_mv_training_data_to_local | get_logs_with_metadata |
|
anonymous | [('dag_id', 'airflow_tv_ls_recall'), ('task_id', 'get_mv_training_data_to_local'), ('execution_date', '2024-04-22T23:00:00+00:00'), ('try_number', '1'), ('metadata', 'null')] |
7310 |
|
airflow_tv_ls_recall | get_mv_training_data_to_local | log |
|
anonymous | [('task_id', 'get_mv_training_data_to_local'), ('dag_id', 'airflow_tv_ls_recall'), ('execution_date', '2024-04-22T23:00:00+00:00'), ('format', 'json')] |
7309 |
|
airflow_tv_ls_recall | get_mv_training_data_to_local | log |
|
anonymous | [('task_id', 'get_mv_training_data_to_local'), ('dag_id', 'airflow_tv_ls_recall'), ('execution_date', '2024-04-22T23:00:00+00:00'), ('format', 'json')] |
7308 |
|
upload_yesterday_results | paused |
|
anonymous | [('is_paused', 'false'), ('dag_id', 'upload_yesterday_results')] | |
7307 |
|
ab_testing_evaluation | tree |
|
anonymous | [('dag_id', 'ab_testing_evaluation')] | |
7306 |
|
ab_testing_evaluation | dagrun_success |
|
anonymous | [('csrf_token', 'IjBjYWU2Nzk4OGU4MzNhNzgxZmYxMTgyMTlmNjdhMWYyZmEzM2UzZDki.ZiiNnA.Gy-9YXd80HDleCXiPBOJSFvbU0k'), ('confirmed', 'true'), ('dag_id', 'ab_testing_evaluation'), ('execution_date', '2024-04-22T19:20:00+00:00'), ('origin', 'http://212.64.14.72:9000/admin/airflow/tree?dag_id=ab_testing_evaluation')] | |
7305 |
|
ab_testing_evaluation | dagrun_success |
|
anonymous | [('csrf_token', 'IjBjYWU2Nzk4OGU4MzNhNzgxZmYxMTgyMTlmNjdhMWYyZmEzM2UzZDki.ZiiNmA.xoy6_ZAOKMOaw7vcm6vE93GgoHI'), ('dag_id', 'ab_testing_evaluation'), ('execution_date', '2024-04-22T19:20:00+00:00'), ('origin', 'http://212.64.14.72:9000/admin/airflow/tree?dag_id=ab_testing_evaluation')] | |
7304 |
|
ab_testing_evaluation | tree |
|
anonymous | [('dag_id', 'ab_testing_evaluation')] | |
7303 |
|
ab_testing_experiment | tree |
|
anonymous | [('dag_id', 'ab_testing_experiment')] | |
7302 |
|
ab_testing_experiment | dagrun_success |
|
anonymous | [('csrf_token', 'IjBjYWU2Nzk4OGU4MzNhNzgxZmYxMTgyMTlmNjdhMWYyZmEzM2UzZDki.ZiiNlQ.EgnCfHA4teLRGSEFPdz9KcGFZSU'), ('confirmed', 'true'), ('dag_id', 'ab_testing_experiment'), ('execution_date', '2024-04-22T23:10:00+00:00'), ('origin', 'http://212.64.14.72:9000/admin/airflow/tree?dag_id=ab_testing_experiment')] | |
7301 |
|
ab_testing_experiment | dagrun_success |
|
anonymous | [('csrf_token', 'IjBjYWU2Nzk4OGU4MzNhNzgxZmYxMTgyMTlmNjdhMWYyZmEzM2UzZDki.ZiiNkQ.UbEpxOcI3eE90L7JDR1w840Sr1Q'), ('dag_id', 'ab_testing_experiment'), ('execution_date', '2024-04-22T23:10:00+00:00'), ('origin', 'http://212.64.14.72:9000/admin/airflow/tree?dag_id=ab_testing_experiment')] | |
7300 |
|
ab_testing_experiment | tree |
|
anonymous | [('dag_id', 'ab_testing_experiment')] | |
7299 |
|
matching_model_data_preparation_rr | paused |
|
anonymous | [('is_paused', 'false'), ('dag_id', 'matching_model_data_preparation_rr')] | |
7298 |
|
movie_preprocess_main_rr | paused |
|
anonymous | [('is_paused', 'false'), ('dag_id', 'movie_preprocess_main_rr')] | |
7297 |
|
vod_post_processing | tree |
|
anonymous | [('dag_id', 'vod_post_processing')] | |
7296 |
|
vod_post_processing | dagrun_success |
|
anonymous | [('csrf_token', 'IjBjYWU2Nzk4OGU4MzNhNzgxZmYxMTgyMTlmNjdhMWYyZmEzM2UzZDki.ZiiNgQ.rOiYHhDFkIz_2IotMfmZxojvkVU'), ('confirmed', 'true'), ('dag_id', 'vod_post_processing'), ('execution_date', '2024-04-23T02:15:00+00:00'), ('origin', 'http://212.64.14.72:9000/admin/airflow/tree?dag_id=vod_post_processing')] | |
7295 |
|
vod_post_processing | dagrun_success |
|
anonymous | [('csrf_token', 'IjBjYWU2Nzk4OGU4MzNhNzgxZmYxMTgyMTlmNjdhMWYyZmEzM2UzZDki.ZiiNfg.saCsZjyW1_MVz1kEnhpt8ZbSgdw'), ('dag_id', 'vod_post_processing'), ('execution_date', '2024-04-23T02:15:00+00:00'), ('origin', 'http://212.64.14.72:9000/admin/airflow/tree?dag_id=vod_post_processing')] | |
7294 |
|
vod_post_processing | tree |
|
anonymous | [('dag_id', 'vod_post_processing')] | |
7293 |
|
upload_yesterday_results | tree |
|
anonymous | [('dag_id', 'upload_yesterday_results')] | |
7292 |
|
vod_indicator_daily | paused |
|
anonymous | [('is_paused', 'false'), ('dag_id', 'vod_indicator_daily')] | |
7291 |
|
vod_inference_dag | paused |
|
anonymous | [('is_paused', 'false'), ('dag_id', 'vod_inference_dag')] | |
7290 |
|
vod_post_processing | paused |
|
anonymous | [('is_paused', 'false'), ('dag_id', 'vod_post_processing')] | |
7289 |
|
update_newly_activated_users | tree |
|
anonymous | [('dag_id', 'update_newly_activated_users')] | |
7288 |
|
update_newly_activated_users | dagrun_success |
|
anonymous | [('csrf_token', 'IjBjYWU2Nzk4OGU4MzNhNzgxZmYxMTgyMTlmNjdhMWYyZmEzM2UzZDki.ZiiNbA.hwEJcs-U2vudAwLpclbnyhpABpQ'), ('confirmed', 'true'), ('dag_id', 'update_newly_activated_users'), ('execution_date', '2024-04-23T04:25:00+00:00'), ('origin', 'http://212.64.14.72:9000/admin/airflow/tree?dag_id=update_newly_activated_users')] | |
7287 |
|
update_newly_activated_users | dagrun_success |
|
anonymous | [('csrf_token', 'IjBjYWU2Nzk4OGU4MzNhNzgxZmYxMTgyMTlmNjdhMWYyZmEzM2UzZDki.ZiiNZA.VYuYIc92Ib4Unv-Vb85ky-rPh3c'), ('dag_id', 'update_newly_activated_users'), ('execution_date', '2024-04-23T04:25:00+00:00'), ('origin', 'http://212.64.14.72:9000/admin/airflow/tree?dag_id=update_newly_activated_users')] | |
7286 |
|
update_newly_activated_users | dagrun_success |
|
anonymous | [('csrf_token', 'IjBjYWU2Nzk4OGU4MzNhNzgxZmYxMTgyMTlmNjdhMWYyZmEzM2UzZDki.ZiiNZA.VYuYIc92Ib4Unv-Vb85ky-rPh3c'), ('dag_id', 'update_newly_activated_users'), ('execution_date', '2024-04-23T04:25:00+00:00'), ('origin', 'http://212.64.14.72:9000/admin/airflow/tree?dag_id=update_newly_activated_users')] | |
7285 |
|
update_newly_activated_users | dagrun_failed |
|
anonymous | [('csrf_token', 'IjBjYWU2Nzk4OGU4MzNhNzgxZmYxMTgyMTlmNjdhMWYyZmEzM2UzZDki.ZiiNZA.VYuYIc92Ib4Unv-Vb85ky-rPh3c'), ('dag_id', 'update_newly_activated_users'), ('execution_date', '2024-04-23T04:25:00+00:00'), ('origin', 'http://212.64.14.72:9000/admin/airflow/tree?dag_id=update_newly_activated_users')] | |
7284 |
|
update_newly_activated_users | tree |
|
anonymous | [('dag_id', 'update_newly_activated_users')] | |
7283 |
|
update_rec_movie_dnum_rr | paused |
|
anonymous | [('is_paused', 'false'), ('dag_id', 'update_rec_movie_dnum_rr')] | |
7282 |
|
update_newly_activated_users | paused |
|
anonymous | [('is_paused', 'false'), ('dag_id', 'update_newly_activated_users')] | |
7281 |
|
update_launcher_dnum_rr | paused |
|
anonymous | [('is_paused', 'false'), ('dag_id', 'update_launcher_dnum_rr')] | |
7280 |
|
train_causimgcl | paused |
|
anonymous | [('is_paused', 'false'), ('dag_id', 'train_causimgcl')] | |
7279 |
|
generate_training_labels | paused |
|
anonymous | [('is_paused', 'false'), ('dag_id', 'generate_training_labels')] | |
7278 |
|
eges_model_data_preparation | paused |
|
anonymous | [('is_paused', 'false'), ('dag_id', 'eges_model_data_preparation')] | |
7277 |
|
basecid_cid_click_expose | paused |
|
anonymous | [('is_paused', 'false'), ('dag_id', 'basecid_cid_click_expose')] | |
7276 |
|
ab_testing_experiment | paused |
|
anonymous | [('is_paused', 'false'), ('dag_id', 'ab_testing_experiment')] | |
7275 |
|
ab_testing_evaluation | paused |
|
anonymous | [('is_paused', 'false'), ('dag_id', 'ab_testing_evaluation')] | |
7274 |
|
update_launcher_dnum_rr | tree |
|
anonymous | [('dag_id', 'update_launcher_dnum_rr')] | |
7273 |
|
vod_post_processing | upload_sparkjson_results | failed |
|
Gary | |
7272 |
|
vod_post_processing | check_result | failed |
|
Gary | |
7271 |
|
vod_post_processing | check_result | cli_run |
|
dev | {"host_name": "10.14.1.101", "full_command": "['/data/dev/miniconda/bin/airflow', 'run', 'vod_post_processing', 'check_result', '2024-04-23T02:15:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/data/gangyanyuan/airflow/dags/vod_post_processing.py']"} |
7270 |
|
vod_post_processing | check_result | running |
|
Gary | |
7269 |
|
vod_post_processing | upload_sparkjson_results | cli_run |
|
dev | {"host_name": "10.14.1.101", "full_command": "['/data/dev/miniconda/bin/airflow', 'run', 'vod_post_processing', 'upload_sparkjson_results', '2024-04-23T02:15:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/data/gangyanyuan/airflow/dags/vod_post_processing.py']"} |
7268 |
|
vod_post_processing | upload_sparkjson_results | running |
|
Gary | |
7267 |
|
vod_post_processing | check_result | cli_run |
|
dev | {"host_name": "10.14.1.101", "full_command": "['/data/dev/miniconda/bin/airflow', 'run', 'vod_post_processing', 'check_result', '2024-04-23T02:15:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/data/gangyanyuan/airflow/dags/vod_post_processing.py']"} |
7266 |
|
vod_post_processing | upload_sparkjson_results | cli_run |
|
dev | {"host_name": "10.14.1.101", "full_command": "['/data/dev/miniconda/bin/airflow', 'run', 'vod_post_processing', 'upload_sparkjson_results', '2024-04-23T02:15:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/data/gangyanyuan/airflow/dags/vod_post_processing.py']"} |
7265 |
|
update_newly_activated_users | get_rec_movie_multi_channel_dnum_with_launcher | cli_run |
|
dev | {"host_name": "10.14.1.101", "full_command": "['/data/dev/miniconda/bin/airflow', 'run', 'update_newly_activated_users', 'get_rec_movie_multi_channel_dnum_with_launcher', '2024-04-23T04:25:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/data/gangyanyuan/airflow/dags/update_newly_activated_users.py']"} |
7264 |
|
update_newly_activated_users | get_rec_movie_multi_channel_dnum_with_launcher | running |
|
Gary | |
7263 |
|
update_newly_activated_users | get_rec_movie_multi_channel_dnum_with_launcher | cli_run |
|
dev | {"host_name": "10.14.1.101", "full_command": "['/data/dev/miniconda/bin/airflow', 'run', 'update_newly_activated_users', 'get_rec_movie_multi_channel_dnum_with_launcher', '2024-04-23T04:25:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/data/gangyanyuan/airflow/dags/update_newly_activated_users.py']"} |
7262 |
|
update_newly_activated_users | get_newly_activated_users_to_local | success |
|
Gary | |
7261 |
|
update_newly_activated_users | get_newly_activated_users_to_local | cli_run |
|
dev | {"host_name": "10.14.1.101", "full_command": "['/data/dev/miniconda/bin/airflow', 'run', 'update_newly_activated_users', 'get_newly_activated_users_to_local', '2024-04-23T04:25:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/data/gangyanyuan/airflow/dags/update_newly_activated_users.py']"} |
7260 |
|
update_newly_activated_users | get_rec_movie_multi_channel_dnum_with_launcher | cli_run |
|
dev | {"host_name": "10.14.1.101", "full_command": "['/data/dev/miniconda/bin/airflow', 'run', 'update_newly_activated_users', 'get_rec_movie_multi_channel_dnum_with_launcher', '2024-04-23T04:25:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/data/gangyanyuan/airflow/dags/update_newly_activated_users.py']"} |
7259 |
|
update_newly_activated_users | get_newly_activated_users_to_local | running |
|
Gary | |
7258 |
|
update_newly_activated_users | get_rec_movie_multi_channel_dnum_with_launcher | running |
|
Gary | |
7257 |
|
update_newly_activated_users | get_newly_activated_users_to_local | cli_run |
|
dev | {"host_name": "10.14.1.101", "full_command": "['/data/dev/miniconda/bin/airflow', 'run', 'update_newly_activated_users', 'get_newly_activated_users_to_local', '2024-04-23T04:25:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/data/gangyanyuan/airflow/dags/update_newly_activated_users.py']"} |
7256 |
|
update_newly_activated_users | get_rec_movie_multi_channel_dnum_with_launcher | cli_run |
|
dev | {"host_name": "10.14.1.101", "full_command": "['/data/dev/miniconda/bin/airflow', 'run', 'update_newly_activated_users', 'get_rec_movie_multi_channel_dnum_with_launcher', '2024-04-23T04:25:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/data/gangyanyuan/airflow/dags/update_newly_activated_users.py']"} |
7255 |
|
update_newly_activated_users | update_newly_activated_users | success |
|
Gary | |
7254 |
|
update_newly_activated_users | update_newly_activated_users | cli_run |
|
dev | {"host_name": "10.14.1.101", "full_command": "['/data/dev/miniconda/bin/airflow', 'run', 'update_newly_activated_users', 'update_newly_activated_users', '2024-04-23T04:25:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/data/gangyanyuan/airflow/dags/update_newly_activated_users.py']"} |
7253 |
|
update_newly_activated_users | update_newly_activated_users | running |
|
Gary | |
7252 |
|
update_newly_activated_users | update_newly_activated_users | cli_run |
|
dev | {"host_name": "10.14.1.101", "full_command": "['/data/dev/miniconda/bin/airflow', 'run', 'update_newly_activated_users', 'update_newly_activated_users', '2024-04-23T04:25:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/data/gangyanyuan/airflow/dags/update_newly_activated_users.py']"} |
7251 |
|
airflow_tv_ls_recall | upload_filter_recall_to_hive_mv | success |
|
LIUBING | |
7250 |
|
update_launcher_dnum_rr | get_user_with_launcher_rec_hive | success |
|
LIUBING | |
7249 |
|
generate_training_labels | generate_training_label | cli_run |
|
dev | {"host_name": "10.14.1.101", "full_command": "['/data/dev/miniconda/bin/airflow', 'run', 'generate_training_labels', 'generate_training_label', '2024-04-22T18:10:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/data/gangyanyuan/airflow/dags/generate_training_labels.py']"} |
7248 |
|
generate_training_labels | generate_training_label | running |
|
Terry | |
7247 |
|
generate_training_labels | generate_training_label | cli_run |
|
dev | {"host_name": "10.14.1.101", "full_command": "['/data/dev/miniconda/bin/airflow', 'run', 'generate_training_labels', 'generate_training_label', '2024-04-22T18:10:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/data/gangyanyuan/airflow/dags/generate_training_labels.py']"} |
7246 |
|
update_rec_movie_dnum_rr | get_rec_movie_tv_comic_to_local | success |
|
LIUBING | |
7245 |
|
upload_yesterday_results | check_result | cli_run |
|
dev | {"host_name": "10.14.1.101", "full_command": "['/data/dev/miniconda/bin/airflow', 'run', 'upload_yesterday_results', 'check_result', '2024-04-23T03:40:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/data/gangyanyuan/airflow/dags/upload_yesterday_results_to_oss.py']"} |
7244 |
|
upload_yesterday_results | check_result | running |
|
Terry | |
7243 |
|
upload_yesterday_results | check_result | cli_run |
|
dev | {"host_name": "10.14.1.101", "full_command": "['/data/dev/miniconda/bin/airflow', 'run', 'upload_yesterday_results', 'check_result', '2024-04-23T03:40:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/data/gangyanyuan/airflow/dags/upload_yesterday_results_to_oss.py']"} |
7242 |
|
update_rec_movie_dnum_rr | get_rec_movie_tv_comic_to_local | cli_run |
|
dev | {"host_name": "10.14.1.101", "full_command": "['/data/dev/miniconda/bin/airflow', 'run', 'update_rec_movie_dnum_rr', 'get_rec_movie_tv_comic_to_local', '2024-04-23T04:10:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/data/gangyanyuan/airflow/dags/update_rec_movie_dnum_rr.py']"} |
7241 |
|
update_rec_movie_dnum_rr | get_rec_movie_tv_comic_to_local | running |
|
LIUBING | |
7240 |
|
update_rec_movie_dnum_rr | get_rec_movie_tv_comic_to_local | cli_run |
|
dev | {"host_name": "10.14.1.101", "full_command": "['/data/dev/miniconda/bin/airflow', 'run', 'update_rec_movie_dnum_rr', 'get_rec_movie_tv_comic_to_local', '2024-04-23T04:10:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/data/gangyanyuan/airflow/dags/update_rec_movie_dnum_rr.py']"} |
7239 |
|
update_rec_movie_dnum_rr | get_rec_movie_tv_comic_dnum_ndays | success |
|
LIUBING | |
7238 |
|
update_rec_movie_dnum_rr | get_rec_movie_tv_comic_dnum_ndays | cli_run |
|
dev | {"host_name": "10.14.1.101", "full_command": "['/data/dev/miniconda/bin/airflow', 'run', 'update_rec_movie_dnum_rr', 'get_rec_movie_tv_comic_dnum_ndays', '2024-04-23T04:10:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/data/gangyanyuan/airflow/dags/update_rec_movie_dnum_rr.py']"} |
7237 |
|
update_rec_movie_dnum_rr | get_rec_movie_tv_comic_dnum_ndays | running |
|
LIUBING | |
7236 |
|
update_rec_movie_dnum_rr | get_rec_movie_tv_comic_dnum_ndays | cli_run |
|
dev | {"host_name": "10.14.1.101", "full_command": "['/data/dev/miniconda/bin/airflow', 'run', 'update_rec_movie_dnum_rr', 'get_rec_movie_tv_comic_dnum_ndays', '2024-04-23T04:10:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/data/gangyanyuan/airflow/dags/update_rec_movie_dnum_rr.py']"} |
7235 |
|
update_launcher_dnum_rr | tree |
|
anonymous | [('dag_id', 'update_launcher_dnum_rr')] | |
7234 |
|
vod_post_processing | check_result | get_logs_with_metadata |
|
anonymous | [('dag_id', 'vod_post_processing'), ('task_id', 'check_result'), ('execution_date', '2024-04-23T02:15:00+00:00'), ('try_number', '1'), ('metadata', 'null')] |
7233 |
|
vod_post_processing | check_result | log |
|
anonymous | [('task_id', 'check_result'), ('dag_id', 'vod_post_processing'), ('execution_date', '2024-04-23T02:15:00+00:00'), ('format', 'json')] |
7232 |
|
vod_post_processing | tree |
|
anonymous | [('dag_id', 'vod_post_processing')] | |
7231 |
|
generate_training_labels | generate_training_label | cli_run |
|
dev | {"host_name": "10.14.1.101", "full_command": "['/data/dev/miniconda/bin/airflow', 'run', 'generate_training_labels', 'generate_training_label', '2024-04-22T18:10:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/data/gangyanyuan/airflow/dags/generate_training_labels.py']"} |
7230 |
|
generate_training_labels | generate_training_label | running |
|
Terry | |
7229 |
|
generate_training_labels | generate_training_label | cli_run |
|
dev | {"host_name": "10.14.1.101", "full_command": "['/data/dev/miniconda/bin/airflow', 'run', 'generate_training_labels', 'generate_training_label', '2024-04-22T18:10:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/data/gangyanyuan/airflow/dags/generate_training_labels.py']"} |
7228 |
|
vod_post_processing | upload_sparkjson_results | failed |
|
Gary |