Logs


Id Dttm Dag Id Task Id Event Execution Date Owner Extra
2241116 07-02T12:09:41.557034+00:00 campaign-delta-job_v002 tries anonymous [('dag_id', 'campaign-delta-job_v002')]
2241115 07-02T12:09:40.657158+00:00 livepop-shuffle-aggregator-modeltransform_v004 check_cluster_status log 06-07T04:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2024-06-07T04:00:00+00:00'), ('task_id', 'check_cluster_status')]
2241114 07-02T12:09:25.436895+00:00 exchange-trade-summary_v002 tree anonymous [('dag_id', 'exchange-trade-summary_v002'), ('num_runs', '25')]
2241113 07-02T12:09:20.886160+00:00 livepop-shuffle-aggregator-modeltransform_v004 graph 06-29T21:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2024-06-29 21:00:00+00:00')]
2241112 07-02T12:09:20.562141+00:00 livepop-shuffle-aggregator-modeltransform_v004 create_emr_steps task 05-02T13:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2024-05-02T13:00:00+00:00'), ('task_id', 'create_emr_steps')]
2241111 07-02T12:09:19.599368+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps log 06-06T13:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-06T13:00:00+00:00'), ('task_id', 'create_cluster_and_add_emr_steps')]
2241110 07-02T12:09:16.642986+00:00 livepop-shuffle-aggregator-modeltransform_v004 graph 06-29T23:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2024-06-29 23:00:00+00:00'), ('run_id', 'scheduled__2024-06-29T23:00:00+00:00')]
2241109 07-02T12:09:15.667364+00:00 vc-asset-import_v002 graph 06-30T02:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('execution_date', '2024-06-30 02:05:00+00:00')]
2241108 07-02T12:09:15.641490+00:00 vc-asset-import_v002 graph 06-30T09:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('execution_date', '2024-06-30 09:05:00+00:00'), ('run_id', 'scheduled__2024-06-30T09:05:00+00:00')]
2241107 07-02T12:09:15.335163+00:00 livepop-shuffle-aggregator-modeltransform_v004 check_cluster_status task 06-07T08:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2024-06-07T08:00:00+00:00'), ('task_id', 'check_cluster_status')]
2241106 07-02T12:09:14.559422+00:00 livepop-shuffle-aggregator-modeltransform_v004 tries anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004')]
2241105 07-02T12:09:14.177016+00:00 livepop-shuffle-aggregator-modeltransform_v004 graph 06-07T00:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2024-06-07T00:00:00+00:00'), ('root', 'check_cluster_status')]
2241104 07-02T12:09:13.657750+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps task 06-06T01:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-06T01:00:00+00:00'), ('task_id', 'create_cluster_and_add_emr_steps')]
2241103 07-02T12:08:58.617168+00:00 vc-asset-import_v002 graph 06-29T22:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('execution_date', '2024-06-29 22:05:00+00:00')]
2241102 07-02T12:08:45.700056+00:00 exchange-trade-summary_v1_v002 graph 06-06T12:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-06T12:00:00+00:00'), ('root', 'check_cluster_status')]
2241101 07-02T12:08:39.379057+00:00 livepop-shuffle-aggregator-modeltransform_v004 create_emr_steps log 06-06T17:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2024-06-06T17:00:00+00:00'), ('task_id', 'create_emr_steps')]
2241100 07-02T12:08:38.346876+00:00 exchange-trade-summary_v1_v002 check_cluster_status log 06-06T09:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-06T09:00:00+00:00'), ('task_id', 'check_cluster_status')]
2241099 07-02T12:08:37.789664+00:00 exchange-trade-summary_v1_v002 graph 06-06T02:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-06T02:00:00+00:00'), ('root', 'check_cluster_status')]
2241098 07-02T12:08:37.329064+00:00 exchange-trade-summary-backfill_all_v002 duration anonymous [('dag_id', 'exchange-trade-summary-backfill_all_v002')]
2241097 07-02T12:08:36.596734+00:00 exchange-trade-summary_v1_v002 create_emr_steps log 06-06T09:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-06T09:00:00+00:00'), ('task_id', 'create_emr_steps')]
2241096 07-02T12:08:35.890865+00:00 cli_scheduler airflow {"host_name": "airflow-scheduler-676bff66f6-25vgd", "full_command": "['/home/airflow/.local/bin/airflow', 'scheduler', '-n', '-1']"}
2241095 07-02T12:08:34.634211+00:00 cli_pool airflow {"host_name": "airflow-scheduler-676bff66f6-25vgd", "full_command": "['/home/airflow/.local/bin/airflow', 'pool', '-i', '/home/airflow/variables-pools/pools.json']"}
2241094 07-02T12:08:33.430437+00:00 publisher-s3-sync graph 06-29T17:00:00+00:00 anonymous [('dag_id', 'publisher-s3-sync'), ('execution_date', '2024-06-29 17:00:00+00:00'), ('run_id', 'scheduled__2024-06-29T17:00:00+00:00')]
2241093 07-02T12:08:33.249314+00:00 cli_variables airflow {"host_name": "airflow-scheduler-676bff66f6-25vgd", "full_command": "['/home/airflow/.local/bin/airflow', 'variables', '-i', '/home/airflow/variables-pools/variables.json']"}
2241092 07-02T12:08:31.749168+00:00 cli_upgradedb airflow {"host_name": "airflow-scheduler-676bff66f6-25vgd", "full_command": "['/home/airflow/.local/bin/airflow', 'upgradedb']"}
2241091 07-02T12:08:30.015981+00:00 campaign-versioning-job_v002 tries anonymous [('dag_id', 'campaign-versioning-job_v002')]
2241090 07-02T12:08:29.391029+00:00 primary-audience-global-cassandra_v003 gantt anonymous [('dag_id', 'primary-audience-global-cassandra_v003')]
2241089 07-02T12:08:28.463661+00:00 publisher-s3-sync duration anonymous [('dag_id', 'publisher-s3-sync')]
2241088 07-02T12:08:28.281951+00:00 vc-asset-import_v002 graph 06-30T03:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('execution_date', '2024-06-30 03:05:00+00:00')]
2241087 07-02T12:08:26.958865+00:00 publisher-s3-sync graph 06-30T05:00:00+00:00 anonymous [('dag_id', 'publisher-s3-sync'), ('execution_date', '2024-06-30 05:00:00+00:00')]
2241086 07-02T12:08:23.575810+00:00 campaign-delta-past-delete-job_v002 duration anonymous [('dag_id', 'campaign-delta-past-delete-job_v002')]
2241085 07-02T12:08:22.407926+00:00 livepop-shuffle-aggregator-modeltransform_v004 graph anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004')]
2241084 07-02T12:08:21.050722+00:00 livepop-shuffle-aggregator-modeltransform_v004 graph 06-30T06:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2024-06-30 06:00:00+00:00'), ('run_id', 'scheduled__2024-06-30T06:00:00+00:00')]
2241083 07-02T12:08:20.876519+00:00 livepop-shuffle-aggregator-modeltransform_v004 check_cluster_status task 05-02T12:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2024-05-02T12:00:00+00:00'), ('task_id', 'check_cluster_status')]
2241082 07-02T12:08:19.349210+00:00 exchange-trade-summary_v1_v002 create_emr_steps log 06-06T05:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-06T05:00:00+00:00'), ('task_id', 'create_emr_steps')]
2241081 07-02T12:08:18.660462+00:00 exchange-trade-summary_v1_v002 graph 06-06T01:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-06 01:00:00+00:00')]
2241080 07-02T12:08:18.659336+00:00 livepop-shuffle-aggregator-modeltransform_v004 graph 06-30T05:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2024-06-30 05:00:00+00:00')]
2241079 07-02T12:08:17.812725+00:00 vc-asset-import_v002 graph 06-30T12:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('execution_date', '2024-06-30 12:05:00+00:00'), ('run_id', 'scheduled__2024-06-30T12:05:00+00:00')]
2241078 07-02T12:08:16.811107+00:00 primary-audience-global-cassandra_v003 trigger anonymous [('dag_id', 'primary-audience-global-cassandra_v003'), ('origin', 'https://airflow.devel.viooh.net.cn/admin/')]
2241077 07-02T12:08:14.806994+00:00 exchange-trade-summary-backfill_all_v002 graph 06-06T15:15:06.651834+00:00 anonymous [('dag_id', 'exchange-trade-summary-backfill_all_v002'), ('execution_date', '2024-06-06 15:15:06.651834+00:00')]
2241076 07-02T12:08:14.365534+00:00 vc-asset-import_v002 graph 06-29T23:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('execution_date', '2024-06-29 23:05:00+00:00'), ('run_id', 'scheduled__2024-06-29T23:05:00+00:00')]
2241075 07-02T12:08:02.585914+00:00 exchange-dsp-reporting_v002 graph 04-10T04:00:00+00:00 anonymous [('dag_id', 'exchange-dsp-reporting_v002'), ('execution_date', '2024-04-10 04:00:00+00:00')]
2241074 07-02T12:07:50.333660+00:00 publisher-s3-sync graph 06-29T13:00:00+00:00 anonymous [('dag_id', 'publisher-s3-sync'), ('execution_date', '2024-06-29 13:00:00+00:00')]
2241073 07-02T12:07:49.299172+00:00 primary-audience-global-masterdb_v003 graph anonymous [('dag_id', 'primary-audience-global-masterdb_v003')]
2241072 07-02T12:07:47.631368+00:00 livepop-shuffle-aggregator-modeltransform_v004 create_cluster_and_add_emr_steps log 05-02T14:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2024-05-02T14:00:00+00:00'), ('task_id', 'create_cluster_and_add_emr_steps')]
2241071 07-02T12:07:46.805681+00:00 exchange-trade-summary_v1_v002 graph 06-06T03:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-06T03:00:00+00:00'), ('root', 'create_cluster_and_add_emr_steps')]
2241070 07-02T12:07:43.636775+00:00 livepop-shuffle-aggregator-modeltransform_v004 graph 06-07T05:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2024-06-07 05:00:00+00:00')]
2241069 07-02T12:07:42.562171+00:00 livepop-shuffle-aggregator-modeltransform_v004 check_cluster_status log 05-01T21:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2024-05-01T21:00:00+00:00'), ('task_id', 'check_cluster_status')]
2241068 07-02T12:07:32.096553+00:00 publisher-s3-sync graph 06-29T16:00:00+00:00 anonymous [('dag_id', 'publisher-s3-sync'), ('execution_date', '2024-06-29 16:00:00+00:00'), ('run_id', 'scheduled__2024-06-29T16:00:00+00:00')]
2241067 07-02T12:07:18.335767+00:00 publisher-s3-sync graph 06-29T19:00:00+00:00 anonymous [('dag_id', 'publisher-s3-sync'), ('execution_date', '2024-06-29 19:00:00+00:00')]
2241066 07-02T12:07:17.110506+00:00 exchange-trade-summary_v1_v002 graph 06-30T07:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-30 07:00:00+00:00')]
2241065 07-02T12:07:10.553676+00:00 livepop-shuffle-aggregator-modeltransform_v004 graph 06-06T22:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2024-06-06 22:00:00+00:00')]
2241064 07-02T12:07:09.818442+00:00 livepop-shuffle-aggregator-modeltransform_v004 check_cluster_status task 06-06T17:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2024-06-06T17:00:00+00:00'), ('task_id', 'check_cluster_status')]
2241063 07-02T12:07:08.913896+00:00 livepop-shuffle-aggregator-modeltransform_v004 create_cluster_and_add_emr_steps log 06-07T05:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2024-06-07T05:00:00+00:00'), ('task_id', 'create_cluster_and_add_emr_steps')]
2241062 07-02T12:06:58.827013+00:00 vc-asset-import_v002 graph 06-29T23:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('execution_date', '2024-06-29 23:05:00+00:00')]
2241061 07-02T12:06:58.190162+00:00 livepop-shuffle-aggregator-modeltransform_v004 create_cluster_and_add_emr_steps task 05-02T14:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2024-05-02T14:00:00+00:00'), ('task_id', 'create_cluster_and_add_emr_steps')]
2241060 07-02T12:06:58.048922+00:00 publisher-s3-sync graph 06-29T20:00:00+00:00 anonymous [('dag_id', 'publisher-s3-sync'), ('execution_date', '2024-06-29 20:00:00+00:00'), ('run_id', 'scheduled__2024-06-29T20:00:00+00:00')]
2241059 07-02T12:06:57.516463+00:00 exchange-trade-summary_v1_v002 graph 06-06T08:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-06T08:00:00+00:00'), ('root', 'create_emr_steps')]
2241058 07-02T12:06:49.691891+00:00 livepop-shuffle-aggregator-modeltransform_v004 check_cluster_status task 06-06T21:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2024-06-06T21:00:00+00:00'), ('task_id', 'check_cluster_status')]
2241057 07-02T12:06:47.655553+00:00 booking-processing-job_v002 duration anonymous [('dag_id', 'booking-processing-job_v002')]
2241056 07-02T12:06:42.876635+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps log 06-06T10:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-06T10:00:00+00:00'), ('task_id', 'create_cluster_and_add_emr_steps')]
2241055 07-02T12:06:42.243160+00:00 livepop-shuffle-aggregator-modeltransform_v004 graph 05-02T12:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2024-05-02 12:00:00+00:00')]
2241054 07-02T12:06:41.465167+00:00 livepop-shuffle-aggregator-modeltransform_v004 check_cluster_status log 06-06T21:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2024-06-06T21:00:00+00:00'), ('task_id', 'check_cluster_status')]
2241053 07-02T12:06:36.308015+00:00 publisher-s3-sync landing_times anonymous [('dag_id', 'publisher-s3-sync')]
2241052 07-02T12:06:36.048466+00:00 pop-quality-check_v002 create_cluster_and_add_emr_steps log 2022-08-25T01:30:00+00:00 anonymous [('dag_id', 'pop-quality-check_v002'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2022-08-25T01:30:00+00:00')]
2241051 07-02T12:06:35.512520+00:00 primary-audience-global-masterdb_v003 trigger anonymous [('dag_id', 'primary-audience-global-masterdb_v003'), ('origin', 'https://airflow.devel.viooh.net.cn/admin/')]
2241050 07-02T12:06:34.598957+00:00 livepop-aggregator-modeltransform_v002 tries anonymous [('dag_id', 'livepop-aggregator-modeltransform_v002')]
2241049 07-02T12:06:33.721135+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps log 06-06T12:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-06T12:00:00+00:00'), ('task_id', 'create_cluster_and_add_emr_steps')]
2241048 07-02T12:06:32.531222+00:00 campaign-delta-past-delete-job_v002 tries anonymous [('dag_id', 'campaign-delta-past-delete-job_v002')]
2241047 07-02T12:06:31.987198+00:00 livepop-aggregator-modeltransform_v002 trigger anonymous [('dag_id', 'livepop-aggregator-modeltransform_v002'), ('origin', 'https://airflow.devel.viooh.net.cn/admin/')]
2241046 07-02T12:06:28.123400+00:00 livepop-shuffle-aggregator-modeltransform_v004 create_cluster_and_add_emr_steps log 06-07T00:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2024-06-07T00:00:00+00:00'), ('task_id', 'create_cluster_and_add_emr_steps')]
2241045 07-02T12:06:15.821144+00:00 exchange-trade-summary_v1_v002 graph 06-29T18:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-29 18:00:00+00:00'), ('run_id', 'scheduled__2024-06-29T18:00:00+00:00')]
2241044 07-02T12:06:15.131709+00:00 exchange-trade-summary_v1_v002 graph 06-29T14:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-29 14:00:00+00:00')]
2241043 07-02T12:06:09.755446+00:00 vc-asset-import_v002 check_cluster_status cli_run 07-02T11:05:00+00:00 airflow {"host_name": "airflow-worker-2", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'vc-asset-import_v002', 'check_cluster_status', '2024-07-02T11:05:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/campaign-compliance/vc-asset-import_v002.py']"}
2241042 07-02T12:06:09.729773+00:00 vc-asset-import_v002 check_cluster_status running 07-02T11:05:00+00:00 data.engineers@viooh.com
2241041 07-02T12:06:09.420598+00:00 exchange-trade-summary_v1_v002 graph 06-30T09:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-30 09:00:00+00:00')]
2241040 07-02T12:06:09.108546+00:00 vc-asset-import_v002 check_cluster_status cli_run 07-02T11:05:00+00:00 airflow {"host_name": "airflow-worker-2", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'vc-asset-import_v002', 'check_cluster_status', '2024-07-02T11:05:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/campaign-compliance/vc-asset-import_v002.py']"}
2241039 07-02T12:06:06.501191+00:00 compliance-daily-export_v002 gantt anonymous [('dag_id', 'compliance-daily-export_v002')]
2241038 07-02T12:05:59.488758+00:00 exchange-trade-summary_v1_v002 graph 06-06T10:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-06 10:00:00+00:00')]
2241037 07-02T12:05:58.918827+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps log 06-06T04:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-06T04:00:00+00:00'), ('task_id', 'create_cluster_and_add_emr_steps')]
2241036 07-02T12:05:58.089682+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps log 06-06T02:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-06T02:00:00+00:00'), ('task_id', 'create_cluster_and_add_emr_steps')]
2241035 07-02T12:05:55.556130+00:00 exchange-trade-summary_v1_v002 create_emr_steps task 06-06T01:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-06T01:00:00+00:00'), ('task_id', 'create_emr_steps')]
2241034 07-02T12:05:53.891660+00:00 livepop-shuffle-aggregator-modeltransform_v004 graph 06-30T09:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2024-06-30 09:00:00+00:00'), ('run_id', 'scheduled__2024-06-30T09:00:00+00:00')]
2241033 07-02T12:05:52.161097+00:00 livepop-shuffle-job_v002 tries anonymous [('dag_id', 'livepop-shuffle-job_v002')]
2241032 07-02T12:05:51.707932+00:00 exchange-trade-summary_v1_v002 check_cluster_status log 06-06T08:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-06T08:00:00+00:00'), ('task_id', 'check_cluster_status')]
2241031 07-02T12:05:51.674265+00:00 promote_lab_audience_to_prd_v01 tries anonymous [('dag_id', 'promote_lab_audience_to_prd_v01')]
2241030 07-02T12:05:51.037337+00:00 primary-audience-global-ind_v003 graph anonymous [('dag_id', 'primary-audience-global-ind_v003')]
2241029 07-02T12:05:51.004488+00:00 vc-asset-import_v002 create_cluster_and_add_emr_steps success 07-02T11:05:00+00:00 data.engineers@viooh.com
2241028 07-02T12:05:50.261870+00:00 livepop-shuffle-aggregator-modeltransform_v004 graph 05-01T21:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2024-05-01 21:00:00+00:00')]
2241027 07-02T12:05:50.181570+00:00 vc-asset-import_v002 create_cluster_and_add_emr_steps cli_run 07-02T11:05:00+00:00 airflow {"host_name": "airflow-worker-0", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'vc-asset-import_v002', 'create_cluster_and_add_emr_steps', '2024-07-02T11:05:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/campaign-compliance/vc-asset-import_v002.py']"}
2241026 07-02T12:05:50.131057+00:00 vc-asset-import_v002 create_cluster_and_add_emr_steps running 07-02T11:05:00+00:00 data.engineers@viooh.com
2241024 07-02T12:05:49.521114+00:00 livepop-shuffle-aggregator-modeltransform_v004 check_cluster_status task 06-06T18:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2024-06-06T18:00:00+00:00'), ('task_id', 'check_cluster_status')]
2241025 07-02T12:05:49.503191+00:00 vc-asset-import_v002 create_cluster_and_add_emr_steps cli_run 07-02T11:05:00+00:00 airflow {"host_name": "airflow-worker-0", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'vc-asset-import_v002', 'create_cluster_and_add_emr_steps', '2024-07-02T11:05:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/campaign-compliance/vc-asset-import_v002.py']"}
2241023 07-02T12:05:48.601160+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps task 06-06T02:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-06T02:00:00+00:00'), ('task_id', 'create_cluster_and_add_emr_steps')]
2241022 07-02T12:05:48.130060+00:00 exchange-trade-summary_v1_v002 graph 06-06T13:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-06T13:00:00+00:00'), ('root', 'create_cluster_and_add_emr_steps')]
2241021 07-02T12:05:47.896551+00:00 vc-asset-import_v002 graph 06-29T15:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('execution_date', '2024-06-29 15:05:00+00:00'), ('run_id', 'scheduled__2024-06-29T15:05:00+00:00')]
2241020 07-02T12:05:47.237945+00:00 exchange-trade-summary_v1_v002 graph 06-29T19:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-29 19:00:00+00:00'), ('run_id', 'scheduled__2024-06-29T19:00:00+00:00')]
2241019 07-02T12:05:46.633481+00:00 vc-asset-import_v002 graph 06-30T04:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('execution_date', '2024-06-30 04:05:00+00:00')]
2241018 07-02T12:05:46.071981+00:00 exchange-trade-summary-backfill_all_v002 tree anonymous [('dag_id', 'exchange-trade-summary-backfill_all_v002')]
2241017 07-02T12:05:42.557302+00:00 campaign-flow-job_v002 landing_times anonymous [('dag_id', 'campaign-flow-job_v002')]