Logs

Id Dttm Dag Id Task Id Event Execution Date Owner Extra
3042666 11-25T08:01:43.699701+00:00 livepop-shuffle-aggregator-modeltransform_v004 graph 2023-12-06T09:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2023-12-06 09:00:00+00:00')]
3042665 11-25T08:01:40.814118+00:00 exchange-trade-summary_v1_v002 graph 10-20T16:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-10-20 16:00:00+00:00')]
3042664 11-25T08:01:40.247460+00:00 booking-processing-job_v002 graph 2021-07-24T03:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('execution_date', '2021-07-24 03:00:00+00:00')]
3042663 11-25T08:01:40.003443+00:00 campaign-flow-job_v002 graph 2022-03-24T01:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2022-03-24 01:00:00+00:00')]
3042662 11-25T08:01:39.653453+00:00 booking-processing-job_v002 graph 2023-05-15T05:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('root', 'create_cluster_and_add_emr_steps'), ('execution_date', '2023-05-15T05:00:00+00:00')]
3042661 11-25T08:01:29.916477+00:00 livepop-shuffle-aggregator-modeltransform_v004 check_cluster_status cli_run 11-25T07:00:00+00:00 airflow {"host_name": "airflow-worker-1", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'livepop-shuffle-aggregator-modeltransform_v004', 'check_cluster_status', '2024-11-25T07:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/campaign-compliance/livepop-shuffle-aggregator-modeltransform_v004.py']"}
3042660 11-25T08:01:29.867617+00:00 livepop-shuffle-aggregator-modeltransform_v004 check_cluster_status running 11-25T07:00:00+00:00 data.engineers@viooh.com
3042659 11-25T08:01:29.508813+00:00 livepop-shuffle-aggregator-modeltransform_v004 graph 2022-06-18T08:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2022-06-18T08:00:00+00:00')]
3042658 11-25T08:01:29.298131+00:00 livepop-shuffle-aggregator-modeltransform_v004 graph 2022-06-09T20:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2022-06-09T20:00:00+00:00')]
3042657 11-25T08:01:29.107454+00:00 livepop-shuffle-aggregator-modeltransform_v004 graph 2023-11-07T00:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2023-11-07 00:00:00+00:00')]
3042656 11-25T08:01:29.103642+00:00 livepop-shuffle-aggregator-modeltransform_v004 graph 2023-12-06T08:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2023-12-06 08:00:00+00:00')]
3042655 11-25T08:01:28.993924+00:00 livepop-shuffle-aggregator-modeltransform_v004 check_cluster_status cli_run 11-25T07:00:00+00:00 airflow {"host_name": "airflow-worker-1", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'livepop-shuffle-aggregator-modeltransform_v004', 'check_cluster_status', '2024-11-25T07:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/campaign-compliance/livepop-shuffle-aggregator-modeltransform_v004.py']"}
3042654 11-25T08:01:19.431084+00:00 publisher-s3-sync graph 03-22T17:00:00+00:00 anonymous [('dag_id', 'publisher-s3-sync'), ('execution_date', '2024-03-22T17:00:00+00:00')]
3042653 11-25T08:01:18.672486+00:00 vc-asset-import_v002 graph 07-10T18:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('execution_date', '2024-07-10T18:05:00+00:00')]
3042652 11-25T08:01:18.671422+00:00 booking-processing-job_v002 graph 2021-07-12T06:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('execution_date', '2021-07-12T06:00:00+00:00')]
3042651 11-25T08:01:16.597065+00:00 campaign-history-job_v002 graph 2022-03-30T23:00:00+00:00 anonymous [('dag_id', 'campaign-history-job_v002'), ('execution_date', '2022-03-30 23:00:00+00:00')]
3042650 11-25T08:01:14.387833+00:00 booking-processing-job_v002 graph 2022-05-17T15:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('execution_date', '2022-05-17 15:00:00+00:00')]
3042649 11-25T08:01:13.336156+00:00 vc-asset-import_v002 graph 06-29T05:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('execution_date', '2024-06-29 05:05:00+00:00')]
3042648 11-25T08:01:10.095012+00:00 livepop-shuffle-aggregator-modeltransform_v004 graph 2022-07-01T04:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2022-07-01 04:00:00+00:00')]
3042647 11-25T08:01:09.674771+00:00 livepop-shuffle-aggregator-modeltransform_v004 graph 2023-12-14T03:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2023-12-14T03:00:00+00:00')]
3042646 11-25T08:01:09.121106+00:00 livepop-shuffle-aggregator-modeltransform_v004 graph 2022-06-22T13:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2022-06-22 13:00:00+00:00')]
3042645 11-25T08:01:09.056658+00:00 livepop-shuffle-aggregator-modeltransform_v004 graph 2023-11-08T22:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2023-11-08 22:00:00+00:00')]
3042644 11-25T08:01:08.796942+00:00 livepop-shuffle-aggregator-modeltransform_v004 create_cluster_and_add_emr_steps success 11-25T07:00:00+00:00 data.engineers@viooh.com
3042643 11-25T08:01:08.684899+00:00 campaign-flow-job_v002 graph 2022-03-27T13:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2022-03-27 13:00:00+00:00')]
3042642 11-25T08:01:07.950422+00:00 exchange-trade-summary_v1_v002 check_cluster_status cli_run 11-25T07: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', '2024-11-25T07:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"}
3042641 11-25T08:01:07.887596+00:00 exchange-trade-summary_v1_v002 check_cluster_status running 11-25T07:00:00+00:00 data.engineers@viooh.com
3042640 11-25T08:01:07.840847+00:00 livepop-shuffle-aggregator-modeltransform_v004 create_cluster_and_add_emr_steps cli_run 11-25T07:00:00+00:00 airflow {"host_name": "airflow-worker-1", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'livepop-shuffle-aggregator-modeltransform_v004', 'create_cluster_and_add_emr_steps', '2024-11-25T07:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/campaign-compliance/livepop-shuffle-aggregator-modeltransform_v004.py']"}
3042639 11-25T08:01:07.777464+00:00 livepop-shuffle-aggregator-modeltransform_v004 create_cluster_and_add_emr_steps running 11-25T07:00:00+00:00 data.engineers@viooh.com
3042638 11-25T08:01:07.649957+00:00 livepop-shuffle-aggregator-modeltransform_v004 graph 2022-06-29T05:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2022-06-29 05:00:00+00:00')]
3042637 11-25T08:01:06.806041+00:00 exchange-trade-summary_v1_v002 check_cluster_status cli_run 11-25T07: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', '2024-11-25T07:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"}
3042636 11-25T08:01:06.782751+00:00 livepop-shuffle-aggregator-modeltransform_v004 create_cluster_and_add_emr_steps cli_run 11-25T07:00:00+00:00 airflow {"host_name": "airflow-worker-1", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'livepop-shuffle-aggregator-modeltransform_v004', 'create_cluster_and_add_emr_steps', '2024-11-25T07:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/campaign-compliance/livepop-shuffle-aggregator-modeltransform_v004.py']"}
3042635 11-25T08:00:59.750642+00:00 booking-processing-job_v002 check_cluster_status cli_run 11-25T07:00:00+00:00 airflow {"host_name": "airflow-worker-1", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'booking-processing-job_v002', 'check_cluster_status', '2024-11-25T07:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"}
3042634 11-25T08:00:59.697341+00:00 booking-processing-job_v002 check_cluster_status running 11-25T07:00:00+00:00 data.engineers@viooh.com
3042633 11-25T08:00:59.015095+00:00 livepop-shuffle-aggregator-modeltransform_v004 graph 2022-06-23T04:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2022-06-23 04:00:00+00:00')]
3042632 11-25T08:00:59.012953+00:00 livepop-shuffle-aggregator-modeltransform_v004 graph 2023-12-31T09:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2023-12-31T09:00:00+00:00')]
3042631 11-25T08:00:58.807574+00:00 livepop-shuffle-aggregator-modeltransform_v004 graph 2022-06-16T18:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2022-06-16T18:00:00+00:00')]
3042630 11-25T08:00:58.695178+00:00 booking-processing-job_v002 check_cluster_status cli_run 11-25T07:00:00+00:00 airflow {"host_name": "airflow-worker-1", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'booking-processing-job_v002', 'check_cluster_status', '2024-11-25T07:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"}
3042629 11-25T08:00:58.013314+00:00 publisher-s3-sync graph 03-22T19:00:00+00:00 anonymous [('dag_id', 'publisher-s3-sync'), ('execution_date', '2024-03-22T19:00:00+00:00')]
3042628 11-25T08:00:57.524028+00:00 booking-processing-job_v002 graph 2022-05-30T22:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('execution_date', '2022-05-30T22:00:00+00:00')]
3042627 11-25T08:00:56.930341+00:00 livepop-shuffle-aggregator-modeltransform_v004 graph 2023-11-06T08:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2023-11-06 08:00:00+00:00')]
3042626 11-25T08:00:56.626197+00:00 livepop-shuffle-aggregator-modeltransform_v004 graph 2022-06-22T06:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2022-06-22 06:00:00+00:00')]
3042625 11-25T08:00:56.441257+00:00 vc-asset-import_v002 graph 07-03T02:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('execution_date', '2024-07-03 02:05:00+00:00')]
3042624 11-25T08:00:50.987123+00:00 vc-asset-import_v002 graph 07-02T12:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('execution_date', '2024-07-02 12:05:00+00:00')]
3042623 11-25T08:00:48.705698+00:00 livepop-shuffle-aggregator-modeltransform_v004 graph 2023-12-17T04:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2023-12-17T04:00:00+00:00')]
3042622 11-25T08:00:47.097934+00:00 livepop-shuffle-aggregator-modeltransform_v004 create_emr_steps success 11-25T07:00:00+00:00 data.engineers@viooh.com
3042621 11-25T08:00:46.597909+00:00 livepop-shuffle-aggregator-modeltransform_v004 graph 2023-12-14T08:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2023-12-14T08:00:00+00:00')]
3042620 11-25T08:00:45.819072+00:00 livepop-shuffle-aggregator-modeltransform_v004 create_emr_steps cli_run 11-25T07:00:00+00:00 airflow {"host_name": "airflow-worker-1", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'livepop-shuffle-aggregator-modeltransform_v004', 'create_emr_steps', '2024-11-25T07:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/campaign-compliance/livepop-shuffle-aggregator-modeltransform_v004.py']"}
3042619 11-25T08:00:45.755113+00:00 livepop-shuffle-aggregator-modeltransform_v004 create_emr_steps running 11-25T07:00:00+00:00 data.engineers@viooh.com
3042618 11-25T08:00:44.905669+00:00 livepop-shuffle-aggregator-modeltransform_v004 create_emr_steps cli_run 11-25T07:00:00+00:00 airflow {"host_name": "airflow-worker-1", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'livepop-shuffle-aggregator-modeltransform_v004', 'create_emr_steps', '2024-11-25T07:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/campaign-compliance/livepop-shuffle-aggregator-modeltransform_v004.py']"}
3042617 11-25T08:00:44.899980+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps success 11-25T07:00:00+00:00 data.engineers@viooh.com
3042616 11-25T08:00:44.407913+00:00 booking-processing-job_v002 graph 2022-05-22T15:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('execution_date', '2022-05-22 15:00:00+00:00')]
3042615 11-25T08:00:43.832967+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps cli_run 11-25T07: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-25T07:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"}
3042614 11-25T08:00:43.791238+00:00 booking-processing-job_v002 graph 2021-07-10T19:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('execution_date', '2021-07-10T19:00:00+00:00')]
3042613 11-25T08:00:43.767106+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps running 11-25T07:00:00+00:00 data.engineers@viooh.com
3042612 11-25T08:00:43.645468+00:00 campaign-flow-job_v002 graph 2022-03-12T19:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2022-03-12T19:00:00+00:00')]
3042611 11-25T08:00:43.559636+00:00 cli_serve_logs airflow {"host_name": "airflow-worker-2", "full_command": "['/home/airflow/.local/bin/airflow', 'serve_logs']"}
3042610 11-25T08:00:43.311776+00:00 booking-processing-job_v002 graph 2022-05-18T13:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('execution_date', '2022-05-18 13:00:00+00:00')]
3042609 11-25T08:00:42.816582+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps cli_run 11-25T07: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-25T07:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"}
3042608 11-25T08:00:42.585295+00:00 campaign-history-job_v002 graph 2022-04-02T06:00:00+00:00 anonymous [('dag_id', 'campaign-history-job_v002'), ('execution_date', '2022-04-02 06:00:00+00:00')]
3042607 11-25T08:00:42.319269+00:00 campaign-history-job_v002 graph 2022-03-14T14:00:00+00:00 anonymous [('dag_id', 'campaign-history-job_v002'), ('execution_date', '2022-03-14T14:00:00+00:00')]
3042606 11-25T08:00:41.531672+00:00 booking-processing-job_v002 graph 2022-05-16T13:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('execution_date', '2022-05-16 13:00:00+00:00')]
3042605 11-25T08:00:40.205820+00:00 livepop-shuffle-aggregator-modeltransform_v004 graph 2022-06-18T17:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2022-06-18T17:00:00+00:00')]
3042604 11-25T08:00:40.204447+00:00 campaign-history-job_v002 graph 2022-03-18T21:00:00+00:00 anonymous [('dag_id', 'campaign-history-job_v002'), ('execution_date', '2022-03-18T21:00:00+00:00')]
3042603 11-25T08:00:38.781931+00:00 livepop-shuffle-aggregator-modeltransform_v004 graph 2023-12-06T06:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2023-12-06 06:00:00+00:00')]
3042602 11-25T08:00:38.320351+00:00 cli_worker airflow {"host_name": "airflow-worker-2", "full_command": "['/home/airflow/.local/bin/airflow', 'worker']"}
3042601 11-25T08:00:37.187050+00:00 campaign-history-job_v002 graph 2022-03-13T18:00:00+00:00 anonymous [('dag_id', 'campaign-history-job_v002'), ('execution_date', '2022-03-13T18:00:00+00:00')]
3042600 11-25T08:00:36.534423+00:00 booking-processing-job_v002 create_cluster_and_add_emr_steps success 11-25T07:00:00+00:00 data.engineers@viooh.com
3042599 11-25T08:00:35.387385+00:00 booking-processing-job_v002 create_cluster_and_add_emr_steps cli_run 11-25T07:00:00+00:00 airflow {"host_name": "airflow-worker-1", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'booking-processing-job_v002', 'create_cluster_and_add_emr_steps', '2024-11-25T07:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"}
3042598 11-25T08:00:35.337595+00:00 booking-processing-job_v002 create_cluster_and_add_emr_steps running 11-25T07:00:00+00:00 data.engineers@viooh.com
3042597 11-25T08:00:33.888827+00:00 booking-processing-job_v002 create_cluster_and_add_emr_steps cli_run 11-25T07:00:00+00:00 airflow {"host_name": "airflow-worker-1", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'booking-processing-job_v002', 'create_cluster_and_add_emr_steps', '2024-11-25T07:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"}
3042596 11-25T08:00:33.291594+00:00 booking-processing-job_v002 graph 2021-07-07T17:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('execution_date', '2021-07-07T17:00:00+00:00')]
3042595 11-25T08:00:30.961674+00:00 booking-processing-job_v002 graph 2022-05-17T17:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('execution_date', '2022-05-17 17:00:00+00:00')]
3042594 11-25T08:00:30.727973+00:00 livepop-shuffle-aggregator-modeltransform_v004 graph 11-24T07:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2024-11-24 07:00:00+00:00')]
3042593 11-25T08:00:30.205399+00:00 livepop-shuffle-aggregator-modeltransform_v004 graph 2022-06-16T13:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2022-06-16T13:00:00+00:00')]
3042592 11-25T08:00:29.572987+00:00 livepop-shuffle-aggregator-modeltransform_v004 graph 2023-12-29T22:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2023-12-29T22:00:00+00:00')]
3042591 11-25T08:00:28.517565+00:00 livepop-shuffle-aggregator-modeltransform_v004 check_input_available success 11-25T07:00:00+00:00 data.engineers@viooh.com
3042590 11-25T08:00:27.708603+00:00 livepop-shuffle-aggregator-modeltransform_v004 check_input_available cli_run 11-25T07:00:00+00:00 airflow {"host_name": "airflow-worker-1", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'livepop-shuffle-aggregator-modeltransform_v004', 'check_input_available', '2024-11-25T07:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/campaign-compliance/livepop-shuffle-aggregator-modeltransform_v004.py']"}
3042589 11-25T08:00:27.643984+00:00 livepop-shuffle-aggregator-modeltransform_v004 check_input_available running 11-25T07:00:00+00:00 data.engineers@viooh.com
3042588 11-25T08:00:27.140193+00:00 livepop-shuffle-aggregator-modeltransform_v004 graph 2023-11-06T21:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2023-11-06 21:00:00+00:00')]
3042587 11-25T08:00:26.825088+00:00 livepop-shuffle-aggregator-modeltransform_v004 check_input_available cli_run 11-25T07:00:00+00:00 airflow {"host_name": "airflow-worker-1", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'livepop-shuffle-aggregator-modeltransform_v004', 'check_input_available', '2024-11-25T07:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/campaign-compliance/livepop-shuffle-aggregator-modeltransform_v004.py']"}
3042586 11-25T08:00:26.807311+00:00 exchange-trade-summary_v1_v002 create_emr_steps success 11-25T07:00:00+00:00 data.engineers@viooh.com
3042585 11-25T08:00:24.440449+00:00 booking-processing-job_v002 graph 2021-07-14T13:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('execution_date', '2021-07-14T13:00:00+00:00')]
3042584 11-25T08:00:23.285690+00:00 campaign-flow-job_v002 graph 2022-03-13T12:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2022-03-13T12:00:00+00:00')]
3042583 11-25T08:00:21.737912+00:00 exchange-trade-summary_v1_v002 create_emr_steps cli_run 11-25T07: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', '2024-11-25T07:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"}
3042582 11-25T08:00:21.691496+00:00 exchange-trade-summary_v1_v002 create_emr_steps running 11-25T07:00:00+00:00 data.engineers@viooh.com
3042581 11-25T08:00:21.065069+00:00 livepop-shuffle-aggregator-modeltransform_v004 graph 2022-06-12T07:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2022-06-12T07:00:00+00:00')]
3042580 11-25T08:00:20.789721+00:00 exchange-trade-summary_v1_v002 create_emr_steps cli_run 11-25T07: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', '2024-11-25T07:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"}
3042579 11-25T08:00:19.231806+00:00 livepop-shuffle-aggregator-modeltransform_v004 graph 2022-06-08T01:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2022-06-08T01:00:00+00:00')]
3042578 11-25T08:00:19.230288+00:00 livepop-shuffle-aggregator-modeltransform_v004 graph 2022-06-13T09:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2022-06-13T09:00:00+00:00')]
3042577 11-25T08:00:19.179233+00:00 campaign-history-job_v002 graph 2022-04-02T13:00:00+00:00 anonymous [('dag_id', 'campaign-history-job_v002'), ('execution_date', '2022-04-02 13:00:00+00:00')]
3042576 11-25T08:00:19.142306+00:00 campaign-flow-job_v002 graph 2022-03-25T20:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2022-03-25 20:00:00+00:00')]
3042575 11-25T08:00:18.253267+00:00 livepop-shuffle-aggregator-modeltransform_v004 graph 2022-07-01T19:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2022-07-01 19:00:00+00:00')]
3042574 11-25T08:00:17.845340+00:00 livepop-shuffle-aggregator-modeltransform_v004 graph 2022-06-17T09:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2022-06-17T09:00:00+00:00')]
3042573 11-25T08:00:17.610598+00:00 campaign-flow-job_v002 graph 2022-03-16T08:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2022-03-16 08:00:00+00:00')]
3042572 11-25T08:00:16.850342+00:00 publisher-s3-sync publisher_sync_task success 11-25T07:00:00+00:00 data.engineers@viooh.com
3042571 11-25T08:00:16.659732+00:00 booking-processing-job_v002 graph 2022-05-18T22:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('execution_date', '2022-05-18 22:00:00+00:00')]
3042570 11-25T08:00:16.098139+00:00 booking-processing-job_v002 graph 2021-07-12T13:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('execution_date', '2021-07-12T13:00:00+00:00')]
3042569 11-25T08:00:16.097053+00:00 livepop-shuffle-aggregator-modeltransform_v004 graph 2023-12-06T21:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2023-12-06 21:00:00+00:00')]
3042568 11-25T08:00:15.761575+00:00 publisher-s3-sync publisher_sync_task cli_run 11-25T07:00:00+00:00 airflow {"host_name": "airflow-worker-0", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'publisher-s3-sync', 'publisher_sync_task', '2024-11-25T07:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/publisher_service/publisher_service_sync.py']"}
3042567 11-25T08:00:15.694404+00:00 publisher-s3-sync publisher_sync_task running 11-25T07:00:00+00:00 data.engineers@viooh.com