Logs

Id Dttm Dag Id Task Id Event Execution Date Owner Extra
3626704 04-11T16:24:34.798283+00:00 vc-asset-import_v002 graph 2021-10-13T01:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('execution_date', '2021-10-13T01:05:00+00:00')]
3626703 04-11T16:24:32.192446+00:00 booking-processing-job_v002 create_cluster_and_add_emr_steps task 2024-12-20T18:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2024-12-20T18:00:00+00:00')]
3626702 04-11T16:24:17.068624+00:00 campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps log 2023-03-21T23:00:00+00:00 anonymous [('dag_id', 'campaign-delta-past-delete-job_v002'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2023-03-21T23:00:00+00:00')]
3626701 04-11T16:23:33.156406+00:00 vc-asset-import_v002 create_cluster_and_add_emr_steps log 2024-09-23T10:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2024-09-23T10:05:00+00:00')]
3626700 04-11T16:23:27.444804+00:00 vc-asset-import_v002 graph 2022-08-13T17:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('root', 'check_cluster_status'), ('execution_date', '2022-08-13T17:05:00+00:00')]
3626699 04-11T16:23:23.243523+00:00 livepop-shuffle-aggregator-modeltransform_v004 create_cluster_and_add_emr_steps xcom 2024-08-02T17:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2024-08-02T17:00:00+00:00')]
3626698 04-11T16:23:21.217866+00:00 campaign-history-job_v002 create_cluster_and_add_emr_steps task 2023-02-28T04:00:00+00:00 anonymous [('dag_id', 'campaign-history-job_v002'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2023-02-28T04:00:00+00:00')]
3626697 04-11T16:22:54.404960+00:00 livepop-shuffle-aggregator-modeltransform_v004 create_emr_steps log 2023-03-18T05:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('task_id', 'create_emr_steps'), ('execution_date', '2023-03-18T05:00:00+00:00')]
3626696 04-11T16:22:52.213124+00:00 vc-asset-import_v002 create_cluster_and_add_emr_steps log 2023-01-17T00:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2023-01-17T00:05:00+00:00')]
3626695 04-11T16:22:33.398608+00:00 livepop-shuffle-aggregator-modeltransform_v004 create_emr_steps rendered 2024-10-14T12:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('task_id', 'create_emr_steps'), ('execution_date', '2024-10-14T12:00:00+00:00')]
3626694 04-11T16:21:23.032189+00:00 exchange-trade-summary_v1_v002 check_cluster_status xcom 2023-11-23T10:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2023-11-23T10:00:00+00:00')]
3626693 04-11T16:21:10.049399+00:00 booking-processing-job_v002 create_emr_steps xcom 2024-12-03T02:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('task_id', 'create_emr_steps'), ('execution_date', '2024-12-03T02:00:00+00:00')]
3626692 04-11T16:20:42.758108+00:00 livepop-shuffle-aggregator-modeltransform_v004 graph 2022-09-13T06:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('root', 'check_input_available'), ('execution_date', '2022-09-13T06:00:00+00:00')]
3626691 04-11T16:20:22.109743+00:00 livepop-shuffle-aggregator-modeltransform_v004 create_emr_steps log 2024-06-12T11:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('task_id', 'create_emr_steps'), ('execution_date', '2024-06-12T11:00:00+00:00')]
3626690 04-11T16:20:02.698561+00:00 campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 task 2021-04-07T14:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('task_id', 'trigger_dagrun_campaign-history-job_v002'), ('execution_date', '2021-04-07T14:00:00+00:00')]
3626689 04-11T16:19:43.135446+00:00 exchange-daily-revenue-report_v002 graph 2024-09-28T09:00:00+00:00 anonymous [('dag_id', 'exchange-daily-revenue-report_v002'), ('root', 'create_emr_steps'), ('execution_date', '2024-09-28T09:00:00+00:00')]
3626688 04-11T16:19:38.408898+00:00 exchange-trade-summary_v1_v002 graph 2023-12-03T01:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2023-12-03 01:00:00+00:00')]
3626687 04-11T16:19:32.842115+00:00 livepop-shuffle-aggregator-modeltransform_v004 create_cluster_and_add_emr_steps task 2022-01-07T00:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2022-01-07T00:00:00+00:00')]
3626686 04-11T16:19:24.947885+00:00 cli_scheduler airflow {"host_name": "airflow-scheduler-676bff66f6-fbgmw", "full_command": "['/home/airflow/.local/bin/airflow', 'scheduler', '-n', '-1']"}
3626685 04-11T16:19:23.371022+00:00 cli_pool airflow {"host_name": "airflow-scheduler-676bff66f6-fbgmw", "full_command": "['/home/airflow/.local/bin/airflow', 'pool', '-i', '/home/airflow/variables-pools/pools.json']"}
3626684 04-11T16:19:21.842881+00:00 cli_variables airflow {"host_name": "airflow-scheduler-676bff66f6-fbgmw", "full_command": "['/home/airflow/.local/bin/airflow', 'variables', '-i', '/home/airflow/variables-pools/variables.json']"}
3626683 04-11T16:19:19.964858+00:00 cli_upgradedb airflow {"host_name": "airflow-scheduler-676bff66f6-fbgmw", "full_command": "['/home/airflow/.local/bin/airflow', 'upgradedb']"}
3626682 04-11T16:19:11.363722+00:00 livepop-shuffle-aggregator-modeltransform_v004 graph 2022-05-03T04:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2022-05-03 04:00:00+00:00')]
3626681 04-11T16:19:09.248235+00:00 livepop-shuffle-aggregator-modeltransform_v004 create_cluster_and_add_emr_steps task 2024-06-26T10:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2024-06-26T10:00:00+00:00')]
3626680 04-11T16:18:51.510704+00:00 booking-processing-job_v002 create_emr_steps log 2023-04-06T00:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('task_id', 'create_emr_steps'), ('execution_date', '2023-04-06T00:00:00+00:00')]
3626679 04-11T16:18:51.241675+00:00 exchange-trade-summary_v1_v002 check_cluster_status success 04-11T15:00:00+00:00 data.engineers@viooh.com
3626678 04-11T16:18:39.917395+00:00 livepop-shuffle-aggregator-modeltransform_v004 graph 2024-12-19T03:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2024-12-19T03:00:00+00:00')]
3626677 04-11T16:18:06.302830+00:00 campaign-flow-job_v002 create_cluster_and_add_emr_steps log 2021-05-08T17:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2021-05-08T17:00:00+00:00')]
3626676 04-11T16:17:32.398945+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps task 2024-05-04T00:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2024-05-04T00:00:00+00:00')]
3626675 04-11T16:16:47.980082+00:00 campaign-flow-job_v002 graph 2023-05-25T07:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('root', 'trigger_dagrun_campaign-history-job_v002'), ('execution_date', '2023-05-25T07:00:00+00:00')]
3626674 04-11T16:16:45.803568+00:00 exchange-trade-summary_v1_v002 check_cluster_status task 2023-12-05T23:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2023-12-05T23:00:00+00:00')]
3626673 04-11T16:16:22.703039+00:00 booking-processing-job_v002 check_cluster_status task 2022-12-22T17:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2022-12-22T17:00:00+00:00')]
3626672 04-11T16:16:08.010854+00:00 campaign-versioning-job_v002 graph 2021-11-10T10:43:21.850695+00:00 anonymous [('dag_id', 'campaign-versioning-job_v002'), ('root', 'create_emr_steps'), ('execution_date', '2021-11-10T10:43:21.850695+00:00')]
3626671 04-11T16:15:47.019099+00:00 booking-processing-job_v002 graph 2023-04-01T19:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('root', 'check_cluster_status'), ('execution_date', '2023-04-01T19:00:00+00:00')]
3626670 04-11T16:14:58.495145+00:00 booking-processing-job_v002 check_cluster_status log 2022-07-03T00:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2022-07-03T00:00:00+00:00')]
3626669 04-11T16:14:56.290659+00:00 exchange-trade-summary_v1_v002 graph 01-01T21:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2025-01-01T21:00:00+00:00')]
3626668 04-11T16:14:50.781975+00:00 vc-asset-import_v002 graph 2021-05-08T23:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('execution_date', '2021-05-08 23:05:00+00:00')]
3626667 04-11T16:14:30.599845+00:00 booking-processing-job_v002 check_cluster_status task 2024-11-07T12:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2024-11-07T12:00:00+00:00')]
3626666 04-11T16:14:14.898051+00:00 livepop-shuffle-aggregator-modeltransform_v004 create_emr_steps log 2024-08-12T12:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('task_id', 'create_emr_steps'), ('execution_date', '2024-08-12T12:00:00+00:00')]
3626665 04-11T16:14:02.998423+00:00 livepop-shuffle-aggregator-modeltransform_v004 create_emr_steps log 2024-12-09T18:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('task_id', 'create_emr_steps'), ('execution_date', '2024-12-09T18:00:00+00:00')]
3626664 04-11T16:13:56.960024+00:00 livepop-shuffle-aggregator-modeltransform_v004 create_emr_steps task 2023-10-22T12:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('task_id', 'create_emr_steps'), ('execution_date', '2023-10-22T12:00:00+00:00')]
3626663 04-11T16:13:17.821143+00:00 vc-asset-import_v002 check_cluster_status log 2024-09-10T17:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2024-09-10T17:05:00+00:00')]
3626662 04-11T16:13:02.383767+00:00 livepop-shuffle-aggregator-modeltransform_v004 check_cluster_status log 2023-10-20T10:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('task_id', 'check_cluster_status'), ('execution_date', '2023-10-20T10:00:00+00:00')]
3626661 04-11T16:13:01.711863+00:00 exchange-trade-summary_v1_v002 graph 02-21T09:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2025-02-21 09:00:00+00:00')]
3626660 04-11T16:12:47.623209+00:00 vc-asset-import_v002 graph 2024-02-22T04:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('execution_date', '2024-02-22 04:05:00+00:00')]
3626659 04-11T16:12:02.503257+00:00 livepop-shuffle-aggregator-modeltransform_v004 create_cluster_and_add_emr_steps xcom 2024-04-14T20:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2024-04-14T20:00:00+00:00')]
3626658 04-11T16:11:56.949498+00:00 livepop-shuffle-aggregator-modeltransform_v004 create_emr_steps task 2024-03-31T21:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('task_id', 'create_emr_steps'), ('execution_date', '2024-03-31T21:00:00+00:00')]
3626657 04-11T16:11:55.790314+00:00 cli_scheduler airflow {"host_name": "airflow-scheduler-676bff66f6-fbgmw", "full_command": "['/home/airflow/.local/bin/airflow', 'scheduler', '-n', '-1']"}
3626656 04-11T16:11:53.845043+00:00 cli_pool airflow {"host_name": "airflow-scheduler-676bff66f6-fbgmw", "full_command": "['/home/airflow/.local/bin/airflow', 'pool', '-i', '/home/airflow/variables-pools/pools.json']"}
3626655 04-11T16:11:52.158198+00:00 cli_variables airflow {"host_name": "airflow-scheduler-676bff66f6-fbgmw", "full_command": "['/home/airflow/.local/bin/airflow', 'variables', '-i', '/home/airflow/variables-pools/variables.json']"}
3626654 04-11T16:11:50.177309+00:00 cli_upgradedb airflow {"host_name": "airflow-scheduler-676bff66f6-fbgmw", "full_command": "['/home/airflow/.local/bin/airflow', 'upgradedb']"}
3626653 04-11T16:11:44.022679+00:00 livepop-shuffle-aggregator-modeltransform_v004 create_cluster_and_add_emr_steps task 2024-08-13T09:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2024-08-13T09:00:00+00:00')]
3626652 04-11T16:11:41.727981+00:00 livepop-shuffle-aggregator-modeltransform_v004 check_input_available task 2024-05-26T10:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('task_id', 'check_input_available'), ('execution_date', '2024-05-26T10:00:00+00:00')]
3626651 04-11T16:10:41.422612+00:00 booking-processing-job_v002 create_cluster_and_add_emr_steps xcom 2021-06-03T08:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2021-06-03T08:00:00+00:00')]
3626650 04-11T16:10:39.582916+00:00 booking-processing-job_v002 create_cluster_and_add_emr_steps log 2021-04-11T21:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2021-04-11T21:00:00+00:00')]
3626649 04-11T16:10:37.942086+00:00 livepop-shuffle-aggregator-modeltransform_v004 create_cluster_and_add_emr_steps rendered 2024-09-30T00:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2024-09-30T00:00:00+00:00')]
3626648 04-11T16:10:27.400754+00:00 vc-asset-import_v002 check_cluster_status log 2024-04-04T07:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2024-04-04T07:05:00+00:00')]
3626647 04-11T16:10:25.671154+00:00 booking-processing-job_v002 graph 2021-08-30T08:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('root', 'check_cluster_status'), ('execution_date', '2021-08-30T08:00:00+00:00')]
3626646 04-11T16:10:25.536631+00:00 Terminate_Custom_EMR_Clusters terminate_emr_clusters_task xcom 2024-08-13T18:30:00+00:00 anonymous [('dag_id', 'Terminate_Custom_EMR_Clusters'), ('task_id', 'terminate_emr_clusters_task'), ('execution_date', '2024-08-13T18:30:00+00:00')]
3626645 04-11T16:10:14.979687+00:00 booking-processing-job_v002 graph 2022-10-29T07:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('execution_date', '2022-10-29T07:00:00+00:00')]
3626644 04-11T16:09:24.471834+00:00 exchange-trade-summary_v1_v002 check_cluster_status task 03-05T09:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2025-03-05T09:00:00+00:00')]
3626643 04-11T16:09:22.365609+00:00 booking-processing-job_v002 create_cluster_and_add_emr_steps log 2024-12-21T09:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2024-12-21T09:00:00+00:00')]
3626642 04-11T16:09:06.029104+00:00 vc-asset-import_v002 create_cluster_and_add_emr_steps log 2024-03-17T11:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2024-03-17T11:05:00+00:00')]
3626641 04-11T16:08:53.624313+00:00 booking-processing-job_v002 create_cluster_and_add_emr_steps task 2022-02-16T11:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2022-02-16T11:00:00+00:00')]
3626640 04-11T16:08:42.915106+00:00 livepop-shuffle-aggregator-modeltransform_v004 check_input_available task 2023-01-04T11:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('task_id', 'check_input_available'), ('execution_date', '2023-01-04T11:00:00+00:00')]
3626639 04-11T16:08:16.712342+00:00 campaign-history-job_v002 check_cluster_status task 2022-07-10T20:00:00+00:00 anonymous [('dag_id', 'campaign-history-job_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2022-07-10T20:00:00+00:00')]
3626638 04-11T16:08:15.436759+00:00 vc-asset-import_v002 graph 2024-09-01T17:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('execution_date', '2024-09-01 17:05:00+00:00')]
3626637 04-11T16:08:13.096205+00:00 exchange-trade-summary_v1_v002 check_cluster_status xcom 2024-10-18T11:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2024-10-18T11:00:00+00:00')]
3626636 04-11T16:08:12.068207+00:00 booking-processing-job_v002 graph 2022-01-23T11:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('root', 'check_cluster_status'), ('execution_date', '2022-01-23T11:00:00+00:00')]
3626635 04-11T16:07:02.919552+00:00 campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 log 2021-04-04T05:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('task_id', 'trigger_dagrun_booking-processing-job_v002'), ('execution_date', '2021-04-04T05:00:00+00:00')]
3626634 04-11T16:06:32.845288+00:00 exchange-trade-summary_v1_v002 check_cluster_status task 2024-08-23T23:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2024-08-23T23:00:00+00:00')]
3626633 04-11T16:06:31.383743+00:00 exchange-trade-summary_v1_v002 create_emr_steps task 2023-12-02T06:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('task_id', 'create_emr_steps'), ('execution_date', '2023-12-02T06:00:00+00:00')]
3626632 04-11T16:06:24.134220+00:00 vc-asset-import_v002 graph 2022-09-26T02:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('execution_date', '2022-09-26 02:05:00+00:00')]
3626631 04-11T16:06:23.587382+00:00 vc-asset-import_v002 graph 2024-02-10T16:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('execution_date', '2024-02-10 16:05:00+00:00')]
3626630 04-11T16:06:22.326338+00:00 campaign-history-job_v002 graph 2022-12-06T10:00:00+00:00 anonymous [('dag_id', 'campaign-history-job_v002'), ('run_id', 'trig__2022-12-06T10:00:00+00:00'), ('execution_date', '2022-12-06 10:00:00+00:00')]
3626629 04-11T16:06:21.584996+00:00 livepop-shuffle-aggregator-modeltransform_v004 create_cluster_and_add_emr_steps rendered 2024-08-11T11:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2024-08-11T11:00:00+00:00')]
3626628 04-11T16:05:52.165106+00:00 livepop-shuffle-aggregator-modeltransform_v004 create_emr_steps log 2024-08-04T02:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('task_id', 'create_emr_steps'), ('execution_date', '2024-08-04T02:00:00+00:00')]
3626627 04-11T16:05:33.510374+00:00 booking-processing-job_v002 check_cluster_status log 2022-07-17T05:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2022-07-17T05:00:00+00:00')]
3626626 04-11T16:05:33.346318+00:00 vc-asset-import_v002 check_cluster_status task 2022-01-14T13:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2022-01-14T13:05:00+00:00')]
3626625 04-11T16:05:33.020499+00:00 exchange-trade-summary_v1_v002 graph 2024-09-17T09:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('root', 'check_cluster_status'), ('execution_date', '2024-09-17T09:00:00+00:00')]
3626624 04-11T16:04:26.154294+00:00 cli_scheduler airflow {"host_name": "airflow-scheduler-676bff66f6-fbgmw", "full_command": "['/home/airflow/.local/bin/airflow', 'scheduler', '-n', '-1']"}
3626623 04-11T16:04:24.358390+00:00 cli_pool airflow {"host_name": "airflow-scheduler-676bff66f6-fbgmw", "full_command": "['/home/airflow/.local/bin/airflow', 'pool', '-i', '/home/airflow/variables-pools/pools.json']"}
3626622 04-11T16:04:22.531986+00:00 cli_variables airflow {"host_name": "airflow-scheduler-676bff66f6-fbgmw", "full_command": "['/home/airflow/.local/bin/airflow', 'variables', '-i', '/home/airflow/variables-pools/variables.json']"}
3626621 04-11T16:04:20.439949+00:00 cli_upgradedb airflow {"host_name": "airflow-scheduler-676bff66f6-fbgmw", "full_command": "['/home/airflow/.local/bin/airflow', 'upgradedb']"}
3626620 04-11T16:04:05.903893+00:00 booking-processing-job_v002 graph 2023-05-17T11:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('root', 'create_cluster_and_add_emr_steps'), ('execution_date', '2023-05-17T11:00:00+00:00')]
3626619 04-11T16:04:04.361681+00:00 livepop-shuffle-aggregator-modeltransform_v004 create_emr_steps task 2024-05-30T04:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('task_id', 'create_emr_steps'), ('execution_date', '2024-05-30T04:00:00+00:00')]
3626618 04-11T16:03:03.606046+00:00 vc-asset-import_v002 graph 2024-05-12T02:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('root', 'create_emr_steps'), ('execution_date', '2024-05-12T02:05:00+00:00')]
3626617 04-11T16:03:01.714397+00:00 exchange-trade-summary_v1_v002 create_emr_steps task 03-04T22:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('task_id', 'create_emr_steps'), ('execution_date', '2025-03-04T22:00:00+00:00')]
3626616 04-11T16:02:30.862386+00:00 livepop-shuffle-aggregator-modeltransform_v004 graph 2022-05-03T08:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('run_id', 'scheduled__2022-05-03T08:00:00+00:00'), ('execution_date', '2022-05-03 08:00:00+00:00')]
3626615 04-11T16:02:23.547364+00:00 booking-processing-job_v002 check_cluster_status rendered 2021-04-23T13:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2021-04-23T13:00:00+00:00')]
3626614 04-11T16:02:21.907392+00:00 campaign-history-job_v002 create_cluster_and_add_emr_steps task 2022-02-23T16:00:00+00:00 anonymous [('dag_id', 'campaign-history-job_v002'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2022-02-23T16:00:00+00:00')]
3626613 04-11T16:02:20.969650+00:00 campaign-history-job_v002 graph 2022-03-01T09:00:00+00:00 anonymous [('dag_id', 'campaign-history-job_v002'), ('execution_date', '2022-03-01 09:00:00+00:00')]
3626612 04-11T16:02:01.340754+00:00 booking-processing-job_v002 check_cluster_status log 2024-11-08T17:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2024-11-08T17:00:00+00:00')]
3626611 04-11T16:01:02.060291+00:00 vc-asset-import_v002 graph 2024-10-03T23:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('execution_date', '2024-10-03T23:05:00+00:00')]
3626610 04-11T16:00:48.038352+00:00 exchange-trade-summary_v1_v002 check_cluster_status cli_run 04-11T15:00:00+00:00 airflow {"host_name": "airflow-worker-1", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'exchange-trade-summary_v1_v002', 'check_cluster_status', '2025-04-11T15:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"}
3626609 04-11T16:00:47.974071+00:00 exchange-trade-summary_v1_v002 check_cluster_status running 04-11T15:00:00+00:00 data.engineers@viooh.com
3626608 04-11T16:00:47.044259+00:00 exchange-trade-summary_v1_v002 check_cluster_status cli_run 04-11T15:00:00+00:00 airflow {"host_name": "airflow-worker-1", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'exchange-trade-summary_v1_v002', 'check_cluster_status', '2025-04-11T15:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"}
3626607 04-11T16:00:41.025548+00:00 livepop-shuffle-aggregator-modeltransform_v004 graph 2022-09-19T09:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('root', 'create_emr_steps'), ('execution_date', '2022-09-19T09:00:00+00:00')]
3626606 04-11T16:00:34.689578+00:00 booking-processing-job_v002 check_cluster_status task 2021-04-28T07:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2021-04-28T07:00:00+00:00')]
3626605 04-11T16:00:33.629445+00:00 booking-processing-job_v002 graph 2024-12-03T08:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('root', 'check_cluster_status'), ('execution_date', '2024-12-03T08:00:00+00:00')]