Logs

Id Dttm Dag Id Task Id Event Execution Date Owner Extra
3049622 11-25T11:16:23.673299+00:00 campaign-history-job_v002 graph 2022-04-15T08:00:00+00:00 anonymous [('dag_id', 'campaign-history-job_v002'), ('execution_date', '2022-04-15T08:00:00+00:00')]
3049621 11-25T11:16:22.901243+00:00 campaign-history-job_v002 graph 2022-04-24T10:00:00+00:00 anonymous [('dag_id', 'campaign-history-job_v002'), ('execution_date', '2022-04-24 10:00:00+00:00')]
3049620 11-25T11:16:20.960311+00:00 booking-processing-job_v002 graph 2022-04-21T02:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('execution_date', '2022-04-21 02:00:00+00:00')]
3049619 11-25T11:16:18.737278+00:00 livepop-shuffle-aggregator-modeltransform_v004 graph 2023-10-27T23:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2023-10-27T23:00:00+00:00')]
3049618 11-25T11:16:17.817374+00:00 publisher-s3-sync graph 03-21T12:00:00+00:00 anonymous [('dag_id', 'publisher-s3-sync'), ('execution_date', '2024-03-21 12:00:00+00:00')]
3049617 11-25T11:16:15.885580+00:00 booking-processing-job_v002 graph 2022-04-22T00:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('execution_date', '2022-04-22 00:00:00+00:00')]
3049616 11-25T11:16:01.286617+00:00 exchange-trade-summary_v1_v002 check_cluster_status failed 11-25T10:00:00+00:00 data.engineers@viooh.com
3049615 11-25T11:15:56.703347+00:00 campaign-flow-job_v002 graph 2022-04-02T15:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2022-04-02T15:00:00+00:00')]
3049614 11-25T11:15:55.032244+00:00 livepop-shuffle-aggregator-modeltransform_v004 graph 2022-07-21T04:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2022-07-21 04:00:00+00:00')]
3049613 11-25T11:15:53.953667+00:00 booking-by-hour-model-transform_v002 graph 2023-01-12T01:30:00+00:00 anonymous [('dag_id', 'booking-by-hour-model-transform_v002'), ('execution_date', '2023-01-12T01:30:00+00:00')]
3049612 11-25T11:15:53.158703+00:00 vc-asset-import_v002 check_cluster_status failed 11-25T10:05:00+00:00 data.engineers@viooh.com
3049611 11-25T11:15:47.823596+00:00 livepop-shuffle-aggregator-modeltransform_v004 graph 2023-10-25T09:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2023-10-25T09:00:00+00:00')]
3049610 11-25T11:15:41.735954+00:00 livepop-shuffle-aggregator-modeltransform_v004 graph 2022-07-24T09:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2022-07-24 09:00:00+00:00')]
3049609 11-25T11:15:39.799284+00:00 booking-processing-job_v002 graph 2022-04-22T06:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('execution_date', '2022-04-22 06:00:00+00:00')]
3049608 11-25T11:15:37.072634+00:00 vc-asset-import_v002 graph 06-17T04:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('execution_date', '2024-06-17T04:05:00+00:00')]
3049607 11-25T11:15:36.393361+00:00 booking-processing-job_v002 graph 2022-04-23T14:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('execution_date', '2022-04-23 14:00:00+00:00')]
3049606 11-25T11:15:35.125280+00:00 booking-processing-job_v002 graph 2021-08-06T11:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('execution_date', '2021-08-06T11:00:00+00:00')]
3049605 11-25T11:15:33.447272+00:00 booking-processing-job_v002 graph 2022-05-09T04:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('execution_date', '2022-05-09T04:00:00+00:00')]
3049604 11-25T11:15:30.521811+00:00 livepop-shuffle-aggregator-modeltransform_v004 graph 2022-07-26T16:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2022-07-26 16:00:00+00:00')]
3049603 11-25T11:15:30.329631+00:00 livepop-shuffle-aggregator-modeltransform_v004 graph 09-26T22:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2024-09-26T22:00:00+00:00')]
3049602 11-25T11:15:29.213113+00:00 campaign-history-job_v002 graph 2022-04-06T04:00:00+00:00 anonymous [('dag_id', 'campaign-history-job_v002'), ('execution_date', '2022-04-06T04:00:00+00:00')]
3049601 11-25T11:15:27.254391+00:00 campaign-flow-job_v002 graph 2022-04-03T07:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2022-04-03T07:00:00+00:00')]
3049600 11-25T11:15:26.686704+00:00 booking-processing-job_v002 graph 2022-05-09T03:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('execution_date', '2022-05-09T03:00:00+00:00')]
3049599 11-25T11:15:21.100524+00:00 livepop-shuffle-aggregator-modeltransform_v004 graph 2023-11-03T17:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2023-11-03T17:00:00+00:00')]
3049598 11-25T11:15:20.909652+00:00 campaign-flow-job_v002 graph 2022-04-06T08:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2022-04-06T08:00:00+00:00')]
3049597 11-25T11:15:19.729660+00:00 livepop-shuffle-aggregator-modeltransform_v004 graph 2022-07-25T23:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2022-07-25 23:00:00+00:00')]
3049596 11-25T11:15:17.966879+00:00 campaign-history-job_v002 graph 2022-04-12T06:00:00+00:00 anonymous [('dag_id', 'campaign-history-job_v002'), ('execution_date', '2022-04-12T06:00:00+00:00')]
3049595 11-25T11:15:17.820097+00:00 livepop-shuffle-aggregator-modeltransform_v004 graph 2022-07-12T00:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2022-07-12T00:00:00+00:00')]
3049594 11-25T11:15:14.596662+00:00 livepop-shuffle-aggregator-modeltransform_v004 graph 2022-07-21T10:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2022-07-21 10:00:00+00:00')]
3049593 11-25T11:15:13.355714+00:00 campaign-history-job_v002 graph 2022-04-11T18:00:00+00:00 anonymous [('dag_id', 'campaign-history-job_v002'), ('execution_date', '2022-04-11T18:00:00+00:00')]
3049592 11-25T11:14:48.058853+00:00 exchange-trade-summary_v1_v002 graph 09-15T11:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-09-15 11:00:00+00:00')]
3049591 11-25T11:14:17.505785+00:00 vc-asset-import_v002 check_cluster_status log 2022-11-20T02:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2022-11-20T02:05:00+00:00')]
3049590 11-25T11:13:49.709128+00:00 exchange-trade-summary_v1_v002 graph 09-12T13:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-09-12 13:00:00+00:00')]
3049589 11-25T11:11:35.288656+00:00 cli_scheduler airflow {"host_name": "airflow-scheduler-676bff66f6-5vwbj", "full_command": "['/home/airflow/.local/bin/airflow', 'scheduler', '-n', '-1']"}
3049588 11-25T11:11:32.583999+00:00 cli_pool airflow {"host_name": "airflow-scheduler-676bff66f6-5vwbj", "full_command": "['/home/airflow/.local/bin/airflow', 'pool', '-i', '/home/airflow/variables-pools/pools.json']"}
3049587 11-25T11:11:29.689697+00:00 cli_variables airflow {"host_name": "airflow-scheduler-676bff66f6-5vwbj", "full_command": "['/home/airflow/.local/bin/airflow', 'variables', '-i', '/home/airflow/variables-pools/variables.json']"}
3049586 11-25T11:11:26.472221+00:00 cli_upgradedb airflow {"host_name": "airflow-scheduler-676bff66f6-5vwbj", "full_command": "['/home/airflow/.local/bin/airflow', 'upgradedb']"}
3049585 11-25T11:10:51.996845+00:00 campaign-history-job_v002 graph 2023-03-22T23:00:00+00:00 anonymous [('dag_id', 'campaign-history-job_v002'), ('execution_date', '2023-03-22T23:00:00+00:00')]
3049584 11-25T11:10:30.152193+00:00 booking-processing-job_v002 check_cluster_status rendered 2021-04-04T06:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2021-04-04T06:00:00+00:00')]
3049583 11-25T11:10:27.941114+00:00 booking-processing-job_v002 graph 2021-05-01T14:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('execution_date', '2021-05-01 14:00:00+00:00')]
3049582 11-25T11:10:21.196491+00:00 exchange-trade-summary_v1_v002 graph 09-13T12:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-09-13 12:00:00+00:00')]
3049581 11-25T11:10:20.113179+00:00 campaign-history-job_v002 graph 2023-03-20T16:00:00+00:00 anonymous [('dag_id', 'campaign-history-job_v002'), ('execution_date', '2023-03-20T16:00:00+00:00')]
3049580 11-25T11:10:17.847145+00:00 livepop-shuffle-aggregator-modeltransform_v004 check_cluster_status success 11-25T10:00:00+00:00 data.engineers@viooh.com
3049579 11-25T11:09:13.446629+00:00 booking-processing-job_v002 check_cluster_status success 11-25T10:00:00+00:00 data.engineers@viooh.com
3049578 11-25T11:09:06.864485+00:00 livepop-shuffle-aggregator-modeltransform_v004 check_cluster_status log 2022-05-12T00:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('task_id', 'check_cluster_status'), ('execution_date', '2022-05-12T00:00:00+00:00')]
3049577 11-25T11:07:46.674177+00:00 pop-quality-check_v002 create_emr_steps rendered 2023-12-03T01:30:00+00:00 anonymous [('dag_id', 'pop-quality-check_v002'), ('task_id', 'create_emr_steps'), ('execution_date', '2023-12-03T01:30:00+00:00')]
3049576 11-25T11:06:53.643138+00:00 exchange-trade-summary_v1_v002 graph 09-20T17:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-09-20T17:00:00+00:00')]
3049575 11-25T11:06:07.075532+00:00 booking-processing-job_v002 create_emr_steps task 2023-04-06T04:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('task_id', 'create_emr_steps'), ('execution_date', '2023-04-06T04:00:00+00:00')]
3049574 11-25T11:05:59.274115+00:00 vc-asset-import_v002 check_cluster_status cli_run 11-25T10: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-11-25T10:05:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/campaign-compliance/vc-asset-import_v002.py']"}
3049573 11-25T11:05:59.226046+00:00 vc-asset-import_v002 check_cluster_status running 11-25T10:05:00+00:00 data.engineers@viooh.com
3049572 11-25T11:05:58.365940+00:00 vc-asset-import_v002 check_cluster_status cli_run 11-25T10: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-11-25T10:05:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/campaign-compliance/vc-asset-import_v002.py']"}
3049571 11-25T11:05:39.938515+00:00 vc-asset-import_v002 create_cluster_and_add_emr_steps success 11-25T10:05:00+00:00 data.engineers@viooh.com
3049570 11-25T11:05:39.027729+00:00 vc-asset-import_v002 create_cluster_and_add_emr_steps cli_run 11-25T10:05:00+00:00 airflow {"host_name": "airflow-worker-2", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'vc-asset-import_v002', 'create_cluster_and_add_emr_steps', '2024-11-25T10:05:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/campaign-compliance/vc-asset-import_v002.py']"}
3049569 11-25T11:05:38.981781+00:00 vc-asset-import_v002 create_cluster_and_add_emr_steps running 11-25T10:05:00+00:00 data.engineers@viooh.com
3049568 11-25T11:05:38.107289+00:00 vc-asset-import_v002 create_cluster_and_add_emr_steps cli_run 11-25T10:05:00+00:00 airflow {"host_name": "airflow-worker-2", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'vc-asset-import_v002', 'create_cluster_and_add_emr_steps', '2024-11-25T10:05:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/campaign-compliance/vc-asset-import_v002.py']"}
3049567 11-25T11:05:15.112959+00:00 vc-asset-import_v002 create_emr_steps success 11-25T10:05:00+00:00 data.engineers@viooh.com
3049566 11-25T11:05:13.577094+00:00 vc-asset-import_v002 create_emr_steps cli_run 11-25T10:05:00+00:00 airflow {"host_name": "airflow-worker-0", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'vc-asset-import_v002', 'create_emr_steps', '2024-11-25T10:05:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/campaign-compliance/vc-asset-import_v002.py']"}
3049565 11-25T11:05:13.516323+00:00 vc-asset-import_v002 create_emr_steps running 11-25T10:05:00+00:00 data.engineers@viooh.com
3049564 11-25T11:05:12.691088+00:00 vc-asset-import_v002 create_emr_steps cli_run 11-25T10:05:00+00:00 airflow {"host_name": "airflow-worker-0", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'vc-asset-import_v002', 'create_emr_steps', '2024-11-25T10:05:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/campaign-compliance/vc-asset-import_v002.py']"}
3049563 11-25T11:05:08.751204+00:00 booking-processing-job_v002 check_cluster_status log 2021-04-29T16:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2021-04-29T16:00:00+00:00')]
3049562 11-25T11:04:18.982930+00:00 booking-processing-job_v002 create_cluster_and_add_emr_steps rendered 2023-01-13T17:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2023-01-13T17:00:00+00:00')]
3049561 11-25T11:04:05.090060+00:00 cli_scheduler airflow {"host_name": "airflow-scheduler-676bff66f6-5vwbj", "full_command": "['/home/airflow/.local/bin/airflow', 'scheduler', '-n', '-1']"}
3049560 11-25T11:04:02.369538+00:00 cli_pool airflow {"host_name": "airflow-scheduler-676bff66f6-5vwbj", "full_command": "['/home/airflow/.local/bin/airflow', 'pool', '-i', '/home/airflow/variables-pools/pools.json']"}
3049559 11-25T11:03:59.684770+00:00 cli_variables airflow {"host_name": "airflow-scheduler-676bff66f6-5vwbj", "full_command": "['/home/airflow/.local/bin/airflow', 'variables', '-i', '/home/airflow/variables-pools/variables.json']"}
3049558 11-25T11:03:56.542833+00:00 cli_upgradedb airflow {"host_name": "airflow-scheduler-676bff66f6-5vwbj", "full_command": "['/home/airflow/.local/bin/airflow', 'upgradedb']"}
3049557 11-25T11:03:55.727715+00:00 cli_serve_logs airflow {"host_name": "airflow-worker-3", "full_command": "['/home/airflow/.local/bin/airflow', 'serve_logs']"}
3049556 11-25T11:03:55.015432+00:00 cli_serve_logs airflow {"host_name": "airflow-worker-4", "full_command": "['/home/airflow/.local/bin/airflow', 'serve_logs']"}
3049555 11-25T11:03:45.378721+00:00 cli_worker airflow {"host_name": "airflow-worker-3", "full_command": "['/home/airflow/.local/bin/airflow', 'worker']"}
3049554 11-25T11:03:44.798250+00:00 cli_worker airflow {"host_name": "airflow-worker-4", "full_command": "['/home/airflow/.local/bin/airflow', 'worker']"}
3049553 11-25T11:03:25.565099+00:00 livepop-shuffle-aggregator-modeltransform_v004 check_cluster_status rendered 2022-05-09T23:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('task_id', 'check_cluster_status'), ('execution_date', '2022-05-09T23:00:00+00:00')]
3049552 11-25T11:03:24.510661+00:00 livepop-shuffle-aggregator-modeltransform_v004 create_emr_steps task 2022-06-14T17:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('task_id', 'create_emr_steps'), ('execution_date', '2022-06-14T17:00:00+00:00')]
3049551 11-25T11:03:22.855490+00:00 exchange-trade-summary_v1_v002 graph 09-17T07:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-09-17 07:00:00+00:00')]
3049550 11-25T11:03:13.434037+00:00 vc-asset-import_v002 create_emr_steps task 2023-11-02T22:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('task_id', 'create_emr_steps'), ('execution_date', '2023-11-02T22:05:00+00:00')]
3049549 11-25T11:02:26.654652+00:00 vc-asset-import_v002 create_cluster_and_add_emr_steps log 08-05T20:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2024-08-05T20:05:00+00:00')]
3049548 11-25T11:02:01.476022+00:00 exchange-trade-summary_v1_v002 graph 09-24T08:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-09-24T08:00:00+00:00')]
3049547 11-25T11:01:56.211428+00:00 livepop-shuffle-aggregator-modeltransform_v004 check_cluster_status task 2022-05-04T09:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('task_id', 'check_cluster_status'), ('execution_date', '2022-05-04T09:00:00+00:00')]
3049546 11-25T11:01:32.041209+00:00 exchange-trade-summary_v1_v002 graph 2023-11-07T18:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2023-11-07T18:00:00+00:00')]
3049545 11-25T11:01:22.122761+00:00 exchange-trade-summary_v1_v002 graph 09-23T04:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-09-23T04:00:00+00:00')]
3049544 11-25T11:01:15.865706+00:00 livepop-shuffle-aggregator-modeltransform_v004 check_cluster_status cli_run 11-25T10:00:00+00:00 airflow {"host_name": "airflow-worker-2", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'livepop-shuffle-aggregator-modeltransform_v004', 'check_cluster_status', '2024-11-25T10:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/campaign-compliance/livepop-shuffle-aggregator-modeltransform_v004.py']"}
3049543 11-25T11:01:15.814960+00:00 livepop-shuffle-aggregator-modeltransform_v004 check_cluster_status running 11-25T10:00:00+00:00 data.engineers@viooh.com
3049542 11-25T11:01:14.925625+00:00 livepop-shuffle-aggregator-modeltransform_v004 check_cluster_status cli_run 11-25T10:00:00+00:00 airflow {"host_name": "airflow-worker-2", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'livepop-shuffle-aggregator-modeltransform_v004', 'check_cluster_status', '2024-11-25T10:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/campaign-compliance/livepop-shuffle-aggregator-modeltransform_v004.py']"}
3049541 11-25T11:01:11.649238+00:00 booking-processing-job_v002 check_cluster_status cli_run 11-25T10:00:00+00:00 airflow {"host_name": "airflow-worker-0", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'booking-processing-job_v002', 'check_cluster_status', '2024-11-25T10:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"}
3049540 11-25T11:01:11.578956+00:00 booking-processing-job_v002 check_cluster_status running 11-25T10:00:00+00:00 data.engineers@viooh.com
3049539 11-25T11:01:10.491556+00:00 booking-processing-job_v002 check_cluster_status cli_run 11-25T10:00:00+00:00 airflow {"host_name": "airflow-worker-0", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'booking-processing-job_v002', 'check_cluster_status', '2024-11-25T10:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"}
3049538 11-25T11:01:08.934723+00:00 exchange-trade-summary_v1_v002 graph 2023-11-10T12:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2023-11-10 12:00:00+00:00')]
3049537 11-25T11:01:07.922925+00:00 exchange-trade-summary_v1_v002 check_cluster_status cli_run 11-25T10:00:00+00:00 airflow {"host_name": "airflow-worker-2", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'exchange-trade-summary_v1_v002', 'check_cluster_status', '2024-11-25T10:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"}
3049536 11-25T11:01:07.868631+00:00 exchange-trade-summary_v1_v002 check_cluster_status running 11-25T10:00:00+00:00 data.engineers@viooh.com
3049535 11-25T11:01:06.886916+00:00 exchange-trade-summary_v1_v002 check_cluster_status cli_run 11-25T10:00:00+00:00 airflow {"host_name": "airflow-worker-2", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'exchange-trade-summary_v1_v002', 'check_cluster_status', '2024-11-25T10:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"}
3049534 11-25T11:00:56.598639+00:00 livepop-shuffle-aggregator-modeltransform_v004 create_cluster_and_add_emr_steps success 11-25T10:00:00+00:00 data.engineers@viooh.com
3049533 11-25T11:00:55.666473+00:00 livepop-shuffle-aggregator-modeltransform_v004 create_cluster_and_add_emr_steps cli_run 11-25T10:00:00+00:00 airflow {"host_name": "airflow-worker-2", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'livepop-shuffle-aggregator-modeltransform_v004', 'create_cluster_and_add_emr_steps', '2024-11-25T10:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/campaign-compliance/livepop-shuffle-aggregator-modeltransform_v004.py']"}
3049532 11-25T11:00:55.606290+00:00 livepop-shuffle-aggregator-modeltransform_v004 create_cluster_and_add_emr_steps running 11-25T10:00:00+00:00 data.engineers@viooh.com
3049531 11-25T11:00:54.656489+00:00 livepop-shuffle-aggregator-modeltransform_v004 create_cluster_and_add_emr_steps cli_run 11-25T10:00:00+00:00 airflow {"host_name": "airflow-worker-2", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'livepop-shuffle-aggregator-modeltransform_v004', 'create_cluster_and_add_emr_steps', '2024-11-25T10:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/campaign-compliance/livepop-shuffle-aggregator-modeltransform_v004.py']"}
3049530 11-25T11:00:46.973718+00:00 booking-processing-job_v002 create_cluster_and_add_emr_steps success 11-25T10:00:00+00:00 data.engineers@viooh.com
3049529 11-25T11:00:45.996773+00:00 booking-processing-job_v002 create_cluster_and_add_emr_steps cli_run 11-25T10:00:00+00:00 airflow {"host_name": "airflow-worker-0", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'booking-processing-job_v002', 'create_cluster_and_add_emr_steps', '2024-11-25T10:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"}
3049528 11-25T11:00:45.925606+00:00 booking-processing-job_v002 create_cluster_and_add_emr_steps running 11-25T10:00:00+00:00 data.engineers@viooh.com
3049527 11-25T11:00:45.125336+00:00 cli_serve_logs airflow {"host_name": "airflow-worker-2", "full_command": "['/home/airflow/.local/bin/airflow', 'serve_logs']"}
3049526 11-25T11:00:44.496548+00:00 booking-processing-job_v002 create_cluster_and_add_emr_steps cli_run 11-25T10:00:00+00:00 airflow {"host_name": "airflow-worker-0", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'booking-processing-job_v002', 'create_cluster_and_add_emr_steps', '2024-11-25T10:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"}
3049525 11-25T11:00:40.816605+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps success 11-25T10:00:00+00:00 data.engineers@viooh.com
3049523 11-25T11:00:39.681354+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps cli_run 11-25T10:00:00+00:00 airflow {"host_name": "airflow-worker-0", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'exchange-trade-summary_v1_v002', 'create_cluster_and_add_emr_steps', '2024-11-25T10:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"}
3049524 11-25T11:00:39.658972+00:00 cli_worker airflow {"host_name": "airflow-worker-2", "full_command": "['/home/airflow/.local/bin/airflow', 'worker']"}