Logs


Id Dttm Dag Id Task Id Event Execution Date Owner Extra
3266264 01-18T02:08:56.213337+00:00 vc-asset-import_v002 check_cluster_status task 2024-11-17T02:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2024-11-17T02:05:00+00:00')]
3266263 01-18T02:08:10.694792+00:00 vc-asset-import_v002 create_emr_steps rendered 2021-03-25T22:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('task_id', 'create_emr_steps'), ('execution_date', '2021-03-25T22:05:00+00:00')]
3266262 01-18T02:07:57.887011+00:00 booking-processing-job_v002 create_emr_steps task 2024-12-22T20:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('task_id', 'create_emr_steps'), ('execution_date', '2024-12-22T20:00:00+00:00')]
3266261 01-18T02:07:16.344552+00:00 livepop-shuffle-aggregator-modeltransform_v004 create_cluster_and_add_emr_steps task 2024-10-03T11:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2024-10-03T11:00:00+00:00')]
3266260 01-18T02:07:08.884233+00:00 vc-asset-import_v002 graph 2024-05-30T03:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('root', 'create_emr_steps'), ('execution_date', '2024-05-30T03:05:00+00:00')]
3266259 01-18T02:06:14.678016+00:00 livepop-shuffle-aggregator-modeltransform_v004 graph 2022-01-02T09:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('root', 'check_input_available'), ('execution_date', '2022-01-02T09:00:00+00:00')]
3266258 01-18T02:06:09.830765+00:00 vc-asset-import_v002 create_cluster_and_add_emr_steps log 2024-08-31T20:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2024-08-31T20:05:00+00:00')]
3266257 01-18T02:06:03.775873+00:00 booking-processing-job_v002 create_emr_steps rendered 2023-01-21T15:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('task_id', 'create_emr_steps'), ('execution_date', '2023-01-21T15:00:00+00:00')]
3266256 01-18T02:05:49.946678+00:00 livepop-shuffle-aggregator-modeltransform_v004 graph 2024-12-03T22:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2024-12-03 22:00:00+00:00')]
3266255 01-18T02:05:25.195161+00:00 livepop-shuffle-aggregator-modeltransform_v004 create_emr_steps log 2023-10-24T22:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('task_id', 'create_emr_steps'), ('execution_date', '2023-10-24T22:00:00+00:00')]
3266254 01-18T02:04:35.174812+00:00 cli_scheduler airflow {"host_name": "airflow-scheduler-676bff66f6-4tgfr", "full_command": "['/home/airflow/.local/bin/airflow', 'scheduler', '-n', '-1']"}
3266253 01-18T02:04:33.577222+00:00 cli_pool airflow {"host_name": "airflow-scheduler-676bff66f6-4tgfr", "full_command": "['/home/airflow/.local/bin/airflow', 'pool', '-i', '/home/airflow/variables-pools/pools.json']"}
3266252 01-18T02:04:31.950049+00:00 cli_variables airflow {"host_name": "airflow-scheduler-676bff66f6-4tgfr", "full_command": "['/home/airflow/.local/bin/airflow', 'variables', '-i', '/home/airflow/variables-pools/variables.json']"}
3266251 01-18T02:04:29.807157+00:00 cli_upgradedb airflow {"host_name": "airflow-scheduler-676bff66f6-4tgfr", "full_command": "['/home/airflow/.local/bin/airflow', 'upgradedb']"}
3266250 01-18T02:04:00.340370+00:00 booking-processing-job_v002 create_cluster_and_add_emr_steps task 2022-08-06T11:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2022-08-06T11:00:00+00:00')]
3266249 01-18T02:02:34.976800+00:00 vc-asset-import_v002 check_cluster_status task 2024-07-30T02:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2024-07-30T02:05:00+00:00')]
3266248 01-18T02:01:16.692297+00:00 livepop-shuffle-aggregator-modeltransform_v004 graph 2024-12-30T11:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2024-12-30 11:00:00+00:00')]
3266247 01-18T02:01:09.254158+00:00 exchange-trade-summary_v1_v002 check_cluster_status cli_run 01-18T01:00:00+00:00 airflow {"host_name": "airflow-worker-0", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'exchange-trade-summary_v1_v002', 'check_cluster_status', '2025-01-18T01:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"}
3266246 01-18T02:01:09.186348+00:00 exchange-trade-summary_v1_v002 check_cluster_status running 01-18T01:00:00+00:00 data.engineers@viooh.com
3266245 01-18T02:01:08.656744+00:00 vc-asset-import_v002 check_cluster_status xcom 2022-12-07T11:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2022-12-07T11:05:00+00:00')]
3266244 01-18T02:01:08.029084+00:00 exchange-trade-summary_v1_v002 check_cluster_status cli_run 01-18T01:00:00+00:00 airflow {"host_name": "airflow-worker-0", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'exchange-trade-summary_v1_v002', 'check_cluster_status', '2025-01-18T01:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"}
3266243 01-18T02:00:47.633638+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps success 01-18T01:00:00+00:00 data.engineers@viooh.com
3266242 01-18T02:00:46.843885+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps cli_run 01-18T01:00:00+00:00 airflow {"host_name": "airflow-worker-1", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'exchange-trade-summary_v1_v002', 'create_cluster_and_add_emr_steps', '2025-01-18T01:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"}
3266241 01-18T02:00:46.809860+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps running 01-18T01:00:00+00:00 data.engineers@viooh.com
3266240 01-18T02:00:46.357153+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps cli_run 01-18T01:00:00+00:00 airflow {"host_name": "airflow-worker-1", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'exchange-trade-summary_v1_v002', 'create_cluster_and_add_emr_steps', '2025-01-18T01:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"}
3266239 01-18T02:00:45.690237+00:00 livepop-shuffle-aggregator-modeltransform_v004 create_emr_steps log 2024-10-09T00:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('task_id', 'create_emr_steps'), ('execution_date', '2024-10-09T00:00:00+00:00')]
3266238 01-18T02:00:40.680173+00:00 publisher-s3-sync graph 01-17T22:00:00+00:00 anonymous [('dag_id', 'publisher-s3-sync'), ('execution_date', '2025-01-17 22:00:00+00:00')]
3266237 01-18T02:00:26.915350+00:00 exchange-trade-summary_v1_v002 create_emr_steps success 01-18T01:00:00+00:00 data.engineers@viooh.com
3266236 01-18T02:00:24.753505+00:00 exchange-trade-summary_v1_v002 create_emr_steps cli_run 01-18T01:00:00+00:00 airflow {"host_name": "airflow-worker-1", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'exchange-trade-summary_v1_v002', 'create_emr_steps', '2025-01-18T01:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"}
3266235 01-18T02:00:24.730941+00:00 exchange-trade-summary_v1_v002 create_emr_steps running 01-18T01:00:00+00:00 data.engineers@viooh.com
3266234 01-18T02:00:24.256464+00:00 exchange-trade-summary_v1_v002 create_emr_steps cli_run 01-18T01:00:00+00:00 airflow {"host_name": "airflow-worker-1", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'exchange-trade-summary_v1_v002', 'create_emr_steps', '2025-01-18T01:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"}
3266233 01-18T02:00:11.544032+00:00 publisher-s3-sync publisher_sync_task success 01-18T01:00:00+00:00 data.engineers@viooh.com
3266232 01-18T02:00:10.908307+00:00 publisher-s3-sync publisher_sync_task cli_run 01-18T01:00:00+00:00 airflow {"host_name": "airflow-worker-1", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'publisher-s3-sync', 'publisher_sync_task', '2025-01-18T01:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/publisher_service/publisher_service_sync.py']"}
3266231 01-18T02:00:10.884031+00:00 publisher-s3-sync publisher_sync_task running 01-18T01:00:00+00:00 data.engineers@viooh.com
3266230 01-18T02:00:10.355324+00:00 publisher-s3-sync publisher_sync_task cli_run 01-18T01:00:00+00:00 airflow {"host_name": "airflow-worker-1", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'publisher-s3-sync', 'publisher_sync_task', '2025-01-18T01:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/publisher_service/publisher_service_sync.py']"}
3266229 01-18T02:00:03.866883+00:00 vc-asset-import_v002 graph 2021-05-26T19:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('execution_date', '2021-05-26 19:05:00+00:00')]
3266228 01-18T01:59:58.822009+00:00 booking-processing-job_v002 create_cluster_and_add_emr_steps task 2022-03-01T23:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2022-03-01T23:00:00+00:00')]
3266227 01-18T01:59:14.304744+00:00 livepop-shuffle-aggregator-modeltransform_v004 graph 2024-08-19T16:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('run_id', 'scheduled__2024-08-19T16:00:00+00:00'), ('execution_date', '2024-08-19 16:00:00+00:00')]
3266226 01-18T01:57:44.886758+00:00 vc-asset-import_v002 graph 2024-05-27T06:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('execution_date', '2024-05-27 06:05:00+00:00')]
3266225 01-18T01:57:07.179718+00:00 booking-processing-job_v002 graph 2023-05-08T01:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('execution_date', '2023-05-08T01:00:00+00:00')]
3266224 01-18T01:57:04.884240+00:00 cli_scheduler airflow {"host_name": "airflow-scheduler-676bff66f6-4tgfr", "full_command": "['/home/airflow/.local/bin/airflow', 'scheduler', '-n', '-1']"}
3266223 01-18T01:57:03.231988+00:00 cli_pool airflow {"host_name": "airflow-scheduler-676bff66f6-4tgfr", "full_command": "['/home/airflow/.local/bin/airflow', 'pool', '-i', '/home/airflow/variables-pools/pools.json']"}
3266222 01-18T01:57:01.581703+00:00 cli_variables airflow {"host_name": "airflow-scheduler-676bff66f6-4tgfr", "full_command": "['/home/airflow/.local/bin/airflow', 'variables', '-i', '/home/airflow/variables-pools/variables.json']"}
3266221 01-18T01:56:59.661477+00:00 cli_upgradedb airflow {"host_name": "airflow-scheduler-676bff66f6-4tgfr", "full_command": "['/home/airflow/.local/bin/airflow', 'upgradedb']"}
3266220 01-18T01:56:34.216111+00:00 exchange-trade-summary_v1_v002 create_emr_steps log 2023-11-02T05:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('task_id', 'create_emr_steps'), ('execution_date', '2023-11-02T05:00:00+00:00')]
3266219 01-18T01:55:54.761837+00:00 booking-processing-job_v002 create_emr_steps log 2022-12-20T01:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('task_id', 'create_emr_steps'), ('execution_date', '2022-12-20T01:00:00+00:00')]
3266218 01-18T01:54:32.521980+00:00 campaign-history-job_v002 create_emr_steps rendered 2020-10-26T22:10:00+00:00 anonymous [('dag_id', 'campaign-history-job_v002'), ('task_id', 'create_emr_steps'), ('execution_date', '2020-10-26T22:10:00+00:00')]
3266217 01-18T01:53:53.758789+00:00 livepop-shuffle-aggregator-modeltransform_v004 create_emr_steps xcom 2023-07-24T10:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('task_id', 'create_emr_steps'), ('execution_date', '2023-07-24T10:00:00+00:00')]
3266216 01-18T01:53:28.327370+00:00 primary-audience-global-ind_v003 graph 01-10T12:23:43.921526+00:00 anonymous [('dag_id', 'primary-audience-global-ind_v003'), ('execution_date', '2025-01-10 12:23:43.921526+00:00')]
3266215 01-18T01:52:36.020732+00:00 campaign-flow-job_v002 create_emr_steps task 2021-06-03T09:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('task_id', 'create_emr_steps'), ('execution_date', '2021-06-03T09:00:00+00:00')]
3266214 01-18T01:52:24.548019+00:00 vc-asset-import_v002 graph 2021-04-04T16:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('execution_date', '2021-04-04 16:05:00+00:00')]
3266213 01-18T01:51:25.704336+00:00 vc-asset-import_v002 create_emr_steps task 2024-05-20T23:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('task_id', 'create_emr_steps'), ('execution_date', '2024-05-20T23:05:00+00:00')]
3266212 01-18T01:51:23.589048+00:00 booking-processing-job_v002 check_cluster_status task 2022-12-05T07:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2022-12-05T07:00:00+00:00')]
3266211 01-18T01:50:51.115822+00:00 Terminate_Custom_EMR_Clusters graph 01-16T18:30:00+00:00 anonymous [('dag_id', 'Terminate_Custom_EMR_Clusters'), ('execution_date', '2025-01-16 18:30:00+00:00')]
3266210 01-18T01:50:14.273076+00:00 vc-asset-import_v002 graph 2021-04-09T15:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('root', 'check_cluster_status'), ('execution_date', '2021-04-09T15:05:00+00:00')]
3266209 01-18T01:49:35.073980+00:00 cli_scheduler airflow {"host_name": "airflow-scheduler-676bff66f6-4tgfr", "full_command": "['/home/airflow/.local/bin/airflow', 'scheduler', '-n', '-1']"}
3266208 01-18T01:49:33.448372+00:00 cli_pool airflow {"host_name": "airflow-scheduler-676bff66f6-4tgfr", "full_command": "['/home/airflow/.local/bin/airflow', 'pool', '-i', '/home/airflow/variables-pools/pools.json']"}
3266207 01-18T01:49:32.134989+00:00 livepop-shuffle-aggregator-modeltransform_v004 check_input_available task 2021-12-30T05:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('task_id', 'check_input_available'), ('execution_date', '2021-12-30T05:00:00+00:00')]
3266206 01-18T01:49:31.683308+00:00 cli_variables airflow {"host_name": "airflow-scheduler-676bff66f6-4tgfr", "full_command": "['/home/airflow/.local/bin/airflow', 'variables', '-i', '/home/airflow/variables-pools/variables.json']"}
3266205 01-18T01:49:29.708198+00:00 cli_upgradedb airflow {"host_name": "airflow-scheduler-676bff66f6-4tgfr", "full_command": "['/home/airflow/.local/bin/airflow', 'upgradedb']"}
3266204 01-18T01:49:22.451657+00:00 livepop-shuffle-aggregator-modeltransform_v004 create_cluster_and_add_emr_steps log 2024-08-27T09:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2024-08-27T09:00:00+00:00')]
3266203 01-18T01:48:00.623874+00:00 livepop-shuffle-aggregator-modeltransform_v004 create_emr_steps rendered 2022-08-31T18:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('task_id', 'create_emr_steps'), ('execution_date', '2022-08-31T18:00:00+00:00')]
3266202 01-18T01:47:35.467523+00:00 exchange-dsp-reporting_v002 create_emr_steps task 2024-05-08T04:00:00+00:00 anonymous [('dag_id', 'exchange-dsp-reporting_v002'), ('task_id', 'create_emr_steps'), ('execution_date', '2024-05-08T04:00:00+00:00')]
3266201 01-18T01:47:33.490484+00:00 livepop-shuffle-aggregator-modeltransform_v004 graph 2022-03-18T02:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('run_id', 'scheduled__2022-03-18T02:00:00+00:00'), ('execution_date', '2022-03-18 02:00:00+00:00')]
3266200 01-18T01:47:09.439708+00:00 pop-quality-check_v002 create_cluster_and_add_emr_steps log 2023-10-01T01:30:00+00:00 anonymous [('dag_id', 'pop-quality-check_v002'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2023-10-01T01:30:00+00:00')]
3266199 01-18T01:46:48.883827+00:00 booking-processing-job_v002 create_cluster_and_add_emr_steps rendered 2022-05-29T04:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2022-05-29T04:00:00+00:00')]
3266198 01-18T01:46:23.481458+00:00 vc-asset-import_v002 graph 2024-12-20T15:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('run_id', 'scheduled__2024-12-20T15:05:00+00:00'), ('execution_date', '2024-12-20 15:05:00+00:00')]
3266197 01-18T01:45:55.611444+00:00 exchange-dsp-reporting_v002 graph 01-16T04:00:00+00:00 anonymous [('dag_id', 'exchange-dsp-reporting_v002'), ('execution_date', '2025-01-16 04:00:00+00:00')]
3266196 01-18T01:45:34.274487+00:00 livepop-shuffle-aggregator-modeltransform_v004 create_cluster_and_add_emr_steps rendered 2022-05-09T00:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2022-05-09T00:00:00+00:00')]
3266195 01-18T01:45:03.068908+00:00 publisher-s3-sync graph 2024-06-21T19:00:00+00:00 anonymous [('dag_id', 'publisher-s3-sync'), ('execution_date', '2024-06-21 19:00:00+00:00')]
3266194 01-18T01:44:29.164518+00:00 exchange-daily-revenue-report_v002 graph 01-16T09:00:00+00:00 anonymous [('dag_id', 'exchange-daily-revenue-report_v002'), ('execution_date', '2025-01-16 09:00:00+00:00')]
3266193 01-18T01:44:03.227734+00:00 vc-asset-import_v002 graph 01-02T12:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('execution_date', '2025-01-02 12:05:00+00:00')]
3266192 01-18T01:43:17.737088+00:00 livepop-shuffle-aggregator-modeltransform_v004 graph 2024-10-23T15:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2024-10-23T15:00:00+00:00')]
3266191 01-18T01:43:08.594860+00:00 livepop-shuffle-aggregator-modeltransform_v004 create_cluster_and_add_emr_steps xcom 2024-10-09T01:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2024-10-09T01:00:00+00:00')]
3266190 01-18T01:42:05.049713+00:00 cli_scheduler airflow {"host_name": "airflow-scheduler-676bff66f6-4tgfr", "full_command": "['/home/airflow/.local/bin/airflow', 'scheduler', '-n', '-1']"}
3266189 01-18T01:42:03.347335+00:00 cli_pool airflow {"host_name": "airflow-scheduler-676bff66f6-4tgfr", "full_command": "['/home/airflow/.local/bin/airflow', 'pool', '-i', '/home/airflow/variables-pools/pools.json']"}
3266188 01-18T01:42:01.739312+00:00 cli_variables airflow {"host_name": "airflow-scheduler-676bff66f6-4tgfr", "full_command": "['/home/airflow/.local/bin/airflow', 'variables', '-i', '/home/airflow/variables-pools/variables.json']"}
3266187 01-18T01:41:59.679895+00:00 cli_upgradedb airflow {"host_name": "airflow-scheduler-676bff66f6-4tgfr", "full_command": "['/home/airflow/.local/bin/airflow', 'upgradedb']"}
3266186 01-18T01:41:52.999454+00:00 booking-by-hour-model-transform_v002 check_cluster_status task 2024-10-22T01:30:00+00:00 anonymous [('dag_id', 'booking-by-hour-model-transform_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2024-10-22T01:30:00+00:00')]
3266185 01-18T01:41:40.633824+00:00 booking-processing-job_v002 create_emr_steps log 2021-04-08T04:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('task_id', 'create_emr_steps'), ('execution_date', '2021-04-08T04:00:00+00:00')]
3266184 01-18T01:40:40.651464+00:00 exchange-trade-summary_v1_v002 graph 01-17T22:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2025-01-17 22:00:00+00:00')]
3266183 01-18T01:40:39.065177+00:00 booking-processing-job_v002 graph 2024-12-30T11:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('execution_date', '2024-12-30 11:00:00+00:00')]
3266182 01-18T01:40:12.778171+00:00 livepop-shuffle-aggregator-modeltransform_v004 create_cluster_and_add_emr_steps log 2022-01-07T02:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2022-01-07T02:00:00+00:00')]
3266181 01-18T01:38:35.766927+00:00 campaign-flow-job_v002 create_emr_steps log 2021-05-27T13:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('task_id', 'create_emr_steps'), ('execution_date', '2021-05-27T13:00:00+00:00')]
3266180 01-18T01:38:22.464398+00:00 vc-asset-import_v002 graph 2023-09-23T18:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('execution_date', '2023-09-23T18:05:00+00:00')]
3266179 01-18T01:38:15.079432+00:00 livepop-shuffle-aggregator-modeltransform_v004 graph 2023-10-30T13:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2023-10-30T13:00:00+00:00')]
3266178 01-18T01:37:13.486218+00:00 livepop-shuffle-aggregator-modeltransform_v004 graph 2022-05-14T10:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('root', 'check_input_available'), ('execution_date', '2022-05-14T10:00:00+00:00')]
3266177 01-18T01:37:12.614545+00:00 livepop-shuffle-aggregator-modeltransform_v004 check_cluster_status log 2024-09-22T07:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('task_id', 'check_cluster_status'), ('execution_date', '2024-09-22T07:00:00+00:00')]
3266176 01-18T01:36:14.181598+00:00 livepop-shuffle-aggregator-modeltransform_v004 create_emr_steps task 2024-10-09T21:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('task_id', 'create_emr_steps'), ('execution_date', '2024-10-09T21:00:00+00:00')]
3266175 01-18T01:35:21.514305+00:00 livepop-shuffle-aggregator-modeltransform_v004 graph 2024-07-25T11:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2024-07-25T11:00:00+00:00')]
3266174 01-18T01:34:35.055244+00:00 cli_scheduler airflow {"host_name": "airflow-scheduler-676bff66f6-4tgfr", "full_command": "['/home/airflow/.local/bin/airflow', 'scheduler', '-n', '-1']"}
3266173 01-18T01:34:33.370269+00:00 cli_pool airflow {"host_name": "airflow-scheduler-676bff66f6-4tgfr", "full_command": "['/home/airflow/.local/bin/airflow', 'pool', '-i', '/home/airflow/variables-pools/pools.json']"}
3266172 01-18T01:34:31.623292+00:00 cli_variables airflow {"host_name": "airflow-scheduler-676bff66f6-4tgfr", "full_command": "['/home/airflow/.local/bin/airflow', 'variables', '-i', '/home/airflow/variables-pools/variables.json']"}
3266171 01-18T01:34:29.608722+00:00 cli_upgradedb airflow {"host_name": "airflow-scheduler-676bff66f6-4tgfr", "full_command": "['/home/airflow/.local/bin/airflow', 'upgradedb']"}
3266170 01-18T01:32:22.533331+00:00 vc-asset-import_v002 check_cluster_status xcom 2022-07-03T19:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2022-07-03T19:05:00+00:00')]
3266169 01-18T01:28:49.823128+00:00 booking-processing-job_v002 graph 2023-03-12T19:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('root', 'create_cluster_and_add_emr_steps'), ('execution_date', '2023-03-12T19:00:00+00:00')]
3266168 01-18T01:27:05.079004+00:00 cli_scheduler airflow {"host_name": "airflow-scheduler-676bff66f6-4tgfr", "full_command": "['/home/airflow/.local/bin/airflow', 'scheduler', '-n', '-1']"}
3266167 01-18T01:27:03.387477+00:00 cli_pool airflow {"host_name": "airflow-scheduler-676bff66f6-4tgfr", "full_command": "['/home/airflow/.local/bin/airflow', 'pool', '-i', '/home/airflow/variables-pools/pools.json']"}
3266166 01-18T01:27:01.657575+00:00 cli_variables airflow {"host_name": "airflow-scheduler-676bff66f6-4tgfr", "full_command": "['/home/airflow/.local/bin/airflow', 'variables', '-i', '/home/airflow/variables-pools/variables.json']"}
3266165 01-18T01:26:59.611710+00:00 cli_upgradedb airflow {"host_name": "airflow-scheduler-676bff66f6-4tgfr", "full_command": "['/home/airflow/.local/bin/airflow', 'upgradedb']"}