Logs

Id Dttm Dag Id Task Id Event Execution Date Owner Extra
3595960 04-06T20:34:01.889867+00:00 booking-processing-job_v002 check_cluster_status rendered 2024-12-19T00:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2024-12-19T00:00:00+00:00')]
3595959 04-06T20:33:40.518321+00:00 vc-asset-import_v002 graph 2023-10-03T15:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('execution_date', '2023-10-03 15:05:00+00:00')]
3595958 04-06T20:33:24.914930+00:00 campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 task 2023-05-30T08:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('task_id', 'trigger_dagrun_booking-processing-job_v002'), ('execution_date', '2023-05-30T08:00:00+00:00')]
3595957 04-06T20:33:21.831550+00:00 publisher-s3-sync graph 02-27T13:00:00+00:00 anonymous [('dag_id', 'publisher-s3-sync'), ('run_id', 'scheduled__2025-02-27T13:00:00+00:00'), ('execution_date', '2025-02-27 13:00:00+00:00')]
3595956 04-06T20:32:58.488272+00:00 booking-processing-job_v002 create_cluster_and_add_emr_steps log 2021-05-31T11:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2021-05-31T11:00:00+00:00')]
3595955 04-06T20:32:46.742146+00:00 campaign-history-job_v002 check_cluster_status log 2023-04-30T06:00:00+00:00 anonymous [('dag_id', 'campaign-history-job_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2023-04-30T06:00:00+00:00')]
3595954 04-06T20:32:45.846317+00:00 livepop-shuffle-aggregator-modeltransform_v004 create_cluster_and_add_emr_steps task 2024-12-06T17:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2024-12-06T17:00:00+00:00')]
3595953 04-06T20:32:43.817306+00:00 livepop-shuffle-aggregator-modeltransform_v004 check_cluster_status task 2022-01-21T21:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('task_id', 'check_cluster_status'), ('execution_date', '2022-01-21T21:00:00+00:00')]
3595952 04-06T20:32:38.956574+00:00 exchange-trade-summary_v1_v002 graph 2024-11-13T00:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('root', 'create_cluster_and_add_emr_steps'), ('execution_date', '2024-11-13T00:00:00+00:00')]
3595951 04-06T20:32:07.810556+00:00 booking-processing-job_v002 create_cluster_and_add_emr_steps xcom 2021-05-04T19:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2021-05-04T19:00:00+00:00')]
3595950 04-06T20:31:59.418883+00:00 livepop-shuffle-aggregator-modeltransform_v004 check_input_available xcom 2022-06-17T09:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('task_id', 'check_input_available'), ('execution_date', '2022-06-17T09:00:00+00:00')]
3595949 04-06T20:31:17.721517+00:00 livepop-shuffle-aggregator-modeltransform_v004 create_emr_steps rendered 2024-10-02T21:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('task_id', 'create_emr_steps'), ('execution_date', '2024-10-02T21:00:00+00:00')]
3595948 04-06T20:30:05.270741+00:00 booking-processing-job_v002 check_cluster_status log 2021-12-16T22:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2021-12-16T22:00:00+00:00')]
3595947 04-06T20:30:04.689358+00:00 cli_scheduler airflow {"host_name": "airflow-scheduler-676bff66f6-4tgfr", "full_command": "['/home/airflow/.local/bin/airflow', 'scheduler', '-n', '-1']"}
3595946 04-06T20:30:03.077964+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']"}
3595945 04-06T20:30:01.652988+00:00 livepop-shuffle-aggregator-modeltransform_v004 check_input_available task 2024-03-20T09:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('task_id', 'check_input_available'), ('execution_date', '2024-03-20T09:00:00+00:00')]
3595944 04-06T20:30:01.481629+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']"}
3595943 04-06T20:29:59.519192+00:00 cli_upgradedb airflow {"host_name": "airflow-scheduler-676bff66f6-4tgfr", "full_command": "['/home/airflow/.local/bin/airflow', 'upgradedb']"}
3595942 04-06T20:29:57.544927+00:00 exchange-trade-summary_v1_v002 check_cluster_status log 2024-01-11T05:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2024-01-11T05:00:00+00:00')]
3595941 04-06T20:28:40.861919+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps task 2024-09-01T19:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2024-09-01T19:00:00+00:00')]
3595940 04-06T20:28:19.404896+00:00 vc-asset-import_v002 graph 2024-02-03T20:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('root', 'create_emr_steps'), ('execution_date', '2024-02-03T20:05:00+00:00')]
3595939 04-06T20:28:10.003012+00:00 campaign-history-job_v002 check_cluster_status log 2023-03-03T21:00:00+00:00 anonymous [('dag_id', 'campaign-history-job_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2023-03-03T21:00:00+00:00')]
3595938 04-06T20:27:42.745175+00:00 campaign-flow-job_v002 check_cluster_status log 2021-05-11T06:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2021-05-11T06:00:00+00:00')]
3595937 04-06T20:27:09.127414+00:00 vc-asset-import_v002 graph 2024-07-13T14:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('root', 'create_cluster_and_add_emr_steps'), ('execution_date', '2024-07-13T14:05:00+00:00')]
3595936 04-06T20:27:07.885191+00:00 booking-processing-job_v002 check_cluster_status log 2021-06-29T23:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2021-06-29T23:00:00+00:00')]
3595935 04-06T20:26:58.050534+00:00 vc-asset-import_v002 create_cluster_and_add_emr_steps task 2024-03-19T16:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2024-03-19T16:05:00+00:00')]
3595934 04-06T20:26:49.615022+00:00 exchange-trade-summary_v1_v002 graph 01-12T09:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('root', 'check_cluster_status'), ('execution_date', '2025-01-12T09:00:00+00:00')]
3595933 04-06T20:26:38.800169+00:00 vc-asset-import_v002 check_cluster_status rendered 2024-07-05T08:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2024-07-05T08:05:00+00:00')]
3595932 04-06T20:26:17.207130+00:00 campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 log 2021-07-27T01:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('task_id', 'trigger_dagrun_booking-processing-job_v002'), ('execution_date', '2021-07-27T01:00:00+00:00')]
3595931 04-06T20:26:08.289190+00:00 publisher-s3-sync graph 03-05T14:00:00+00:00 anonymous [('dag_id', 'publisher-s3-sync'), ('run_id', 'scheduled__2025-03-05T14:00:00+00:00'), ('execution_date', '2025-03-05 14:00:00+00:00')]
3595930 04-06T20:25:58.223031+00:00 campaign-flow-job_v002 graph 2022-08-17T03:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2022-08-17T03:00:00+00:00')]
3595929 04-06T20:25:49.034845+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps task 2024-07-08T08:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2024-07-08T08:00:00+00:00')]
3595928 04-06T20:25:39.845065+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps xcom 2024-01-17T01:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2024-01-17T01:00:00+00:00')]
3595927 04-06T20:24:59.178608+00:00 campaign-flow-job_v002 create_cluster_and_add_emr_steps log 2021-10-04T14:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2021-10-04T14:00:00+00:00')]
3595926 04-06T20:24:29.711551+00:00 booking-by-hour-model-transform_v002 create_cluster_and_add_emr_steps task 2022-12-25T01:30:00+00:00 anonymous [('dag_id', 'booking-by-hour-model-transform_v002'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2022-12-25T01:30:00+00:00')]
3595925 04-06T20:24:27.441760+00:00 livepop-shuffle-aggregator-modeltransform_v004 check_cluster_status task 2023-06-20T15:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('task_id', 'check_cluster_status'), ('execution_date', '2023-06-20T15:00:00+00:00')]
3595924 04-06T20:23:48.172941+00:00 livepop-shuffle-aggregator-modeltransform_v004 create_cluster_and_add_emr_steps task 2024-01-17T07:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2024-01-17T07:00:00+00:00')]
3595923 04-06T20:23:39.821175+00:00 pop-quality-check_v002 check_cluster_status rendered 2023-08-27T01:30:00+00:00 anonymous [('dag_id', 'pop-quality-check_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2023-08-27T01:30:00+00:00')]
3595922 04-06T20:23:20.890742+00:00 booking-processing-job_v002 graph 2022-12-06T16:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('run_id', 'trig__2022-12-06T16:00:00+00:00'), ('execution_date', '2022-12-06 16:00:00+00:00')]
3595921 04-06T20:23:19.989787+00:00 livepop-shuffle-aggregator-modeltransform_v004 create_emr_steps log 2023-11-06T17:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('task_id', 'create_emr_steps'), ('execution_date', '2023-11-06T17:00:00+00:00')]
3595920 04-06T20:23:19.499953+00:00 livepop-shuffle-aggregator-modeltransform_v004 create_emr_steps rendered 2024-09-02T15:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('task_id', 'create_emr_steps'), ('execution_date', '2024-09-02T15:00:00+00:00')]
3595919 04-06T20:23:17.417469+00:00 livepop-shuffle-aggregator-modeltransform_v004 create_emr_steps log 2024-07-30T13:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('task_id', 'create_emr_steps'), ('execution_date', '2024-07-30T13:00:00+00:00')]
3595918 04-06T20:22:38.153349+00:00 livepop-shuffle-aggregator-modeltransform_v004 check_input_available task 2024-12-28T16:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('task_id', 'check_input_available'), ('execution_date', '2024-12-28T16:00:00+00:00')]
3595917 04-06T20:22:34.800894+00:00 cli_scheduler airflow {"host_name": "airflow-scheduler-676bff66f6-4tgfr", "full_command": "['/home/airflow/.local/bin/airflow', 'scheduler', '-n', '-1']"}
3595916 04-06T20:22:33.175424+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']"}
3595915 04-06T20:22:31.487839+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']"}
3595914 04-06T20:22:29.545536+00:00 cli_upgradedb airflow {"host_name": "airflow-scheduler-676bff66f6-4tgfr", "full_command": "['/home/airflow/.local/bin/airflow', 'upgradedb']"}
3595913 04-06T20:21:50.994044+00:00 livepop-shuffle-aggregator-modeltransform_v004 create_cluster_and_add_emr_steps rendered 2024-02-19T12:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2024-02-19T12:00:00+00:00')]
3595912 04-06T20:21:46.936744+00:00 booking-processing-job_v002 check_cluster_status xcom 2023-05-21T06:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2023-05-21T06:00:00+00:00')]
3595911 04-06T20:21:26.725795+00:00 exchange-dsp-reporting_v002 create_emr_steps rendered 2024-05-18T04:00:00+00:00 anonymous [('dag_id', 'exchange-dsp-reporting_v002'), ('task_id', 'create_emr_steps'), ('execution_date', '2024-05-18T04:00:00+00:00')]
3595910 04-06T20:21:17.663855+00:00 vc-asset-import_v002 create_emr_steps task 2024-12-15T20:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('task_id', 'create_emr_steps'), ('execution_date', '2024-12-15T20:05:00+00:00')]
3595909 04-06T20:20:22.188549+00:00 livepop-shuffle-aggregator-modeltransform_v004 create_emr_steps task 2024-05-26T14:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('task_id', 'create_emr_steps'), ('execution_date', '2024-05-26T14:00:00+00:00')]
3595908 04-06T20:20:16.748236+00:00 campaign-history-job_v002 create_cluster_and_add_emr_steps log 2021-04-09T12:00:00+00:00 anonymous [('dag_id', 'campaign-history-job_v002'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2021-04-09T12:00:00+00:00')]
3595907 04-06T20:20:15.867714+00:00 campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 rendered 2023-05-16T00:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('task_id', 'trigger_dagrun_booking-processing-job_v002'), ('execution_date', '2023-05-16T00:00:00+00:00')]
3595906 04-06T20:20:07.868505+00:00 livepop-shuffle-aggregator-modeltransform_v004 check_cluster_status rendered 2024-09-02T21:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('task_id', 'check_cluster_status'), ('execution_date', '2024-09-02T21:00:00+00:00')]
3595905 04-06T20:20:07.440907+00:00 vc-asset-import_v002 check_cluster_status log 2023-09-17T01:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2023-09-17T01:05:00+00:00')]
3595904 04-06T20:19:31.067118+00:00 booking-processing-job_v002 create_emr_steps task 2021-11-29T17:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('task_id', 'create_emr_steps'), ('execution_date', '2021-11-29T17:00:00+00:00')]
3595903 04-06T20:19:30.016380+00:00 exchange-trade-summary_v1_v002 check_cluster_status xcom 2023-11-24T04:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2023-11-24T04:00:00+00:00')]
3595902 04-06T20:19:27.820071+00:00 campaign-history-job_v002 check_cluster_status log 2021-04-05T20:00:00+00:00 anonymous [('dag_id', 'campaign-history-job_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2021-04-05T20:00:00+00:00')]
3595901 04-06T20:18:26.999998+00:00 exchange-trade-summary_v1_v002 check_cluster_status log 2024-03-01T05:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2024-03-01T05:00:00+00:00')]
3595900 04-06T20:18:19.258635+00:00 booking-processing-job_v002 check_cluster_status task 2021-10-29T09:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2021-10-29T09:00:00+00:00')]
3595899 04-06T20:17:01.246025+00:00 exchange-trade-summary_v1_v002 check_cluster_status success 04-06T19:00:00+00:00 data.engineers@viooh.com
3595898 04-06T20:16:47.317237+00:00 livepop-shuffle-aggregator-modeltransform_v004 check_cluster_status log 2024-08-02T03:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('task_id', 'check_cluster_status'), ('execution_date', '2024-08-02T03:00:00+00:00')]
3595897 04-06T20:16:13.155435+00:00 livepop-shuffle-aggregator-modeltransform_v004 check_cluster_status log 2024-12-27T07:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('task_id', 'check_cluster_status'), ('execution_date', '2024-12-27T07:00:00+00:00')]
3595896 04-06T20:16:12.062465+00:00 livepop-shuffle-aggregator-modeltransform_v004 check_cluster_status task 2022-01-04T09:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('task_id', 'check_cluster_status'), ('execution_date', '2022-01-04T09:00:00+00:00')]
3595895 04-06T20:15:49.093887+00:00 livepop-shuffle-aggregator-modeltransform_v004 create_cluster_and_add_emr_steps log 2023-07-31T15:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2023-07-31T15:00:00+00:00')]
3595894 04-06T20:15:47.000087+00:00 booking-processing-job_v002 check_cluster_status task 2022-11-05T10:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2022-11-05T10:00:00+00:00')]
3595893 04-06T20:15:26.793354+00:00 booking-processing-job_v002 check_cluster_status log 2023-03-30T00:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2023-03-30T00:00:00+00:00')]
3595892 04-06T20:15:17.243682+00:00 vc-asset-import_v002 check_cluster_status log 2022-12-21T18:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2022-12-21T18:05:00+00:00')]
3595891 04-06T20:15:16.051506+00:00 exchange-trade-summary_v1_v002 check_cluster_status task 2024-09-30T08:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2024-09-30T08:00:00+00:00')]
3595890 04-06T20:15:04.682057+00:00 cli_scheduler airflow {"host_name": "airflow-scheduler-676bff66f6-4tgfr", "full_command": "['/home/airflow/.local/bin/airflow', 'scheduler', '-n', '-1']"}
3595889 04-06T20:15:03.077975+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']"}
3595888 04-06T20:15:01.473508+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']"}
3595887 04-06T20:14:59.603570+00:00 cli_upgradedb airflow {"host_name": "airflow-scheduler-676bff66f6-4tgfr", "full_command": "['/home/airflow/.local/bin/airflow', 'upgradedb']"}
3595886 04-06T20:14:35.976153+00:00 exchange-dsp-reporting_v002 check_cluster_status rendered 2024-06-30T04:00:00+00:00 anonymous [('dag_id', 'exchange-dsp-reporting_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2024-06-30T04:00:00+00:00')]
3595885 04-06T20:14:20.389534+00:00 campaign-history-job_v002 check_cluster_status task 2021-04-11T14:00:00+00:00 anonymous [('dag_id', 'campaign-history-job_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2021-04-11T14:00:00+00:00')]
3595884 04-06T20:14:18.689640+00:00 vc-asset-import_v002 create_cluster_and_add_emr_steps log 2024-07-11T07:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2024-07-11T07:05:00+00:00')]
3595883 04-06T20:14:16.585762+00:00 livepop-shuffle-aggregator-modeltransform_v004 create_emr_steps log 2023-07-23T12:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('task_id', 'create_emr_steps'), ('execution_date', '2023-07-23T12:00:00+00:00')]
3595882 04-06T20:13:06.009143+00:00 exchange-trade-summary_v1_v002 graph 2024-10-31T09:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('root', 'create_cluster_and_add_emr_steps'), ('execution_date', '2024-10-31T09:00:00+00:00')]
3595881 04-06T20:12:35.590666+00:00 booking-processing-job_v002 create_cluster_and_add_emr_steps log 2023-01-04T09:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2023-01-04T09:00:00+00:00')]
3595880 04-06T20:12:07.384550+00:00 vc-asset-import_v002 create_cluster_and_add_emr_steps xcom 2024-12-16T16:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2024-12-16T16:05:00+00:00')]
3595879 04-06T20:11:26.800672+00:00 booking-processing-job_v002 create_cluster_and_add_emr_steps log 2022-11-03T04:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2022-11-03T04:00:00+00:00')]
3595878 04-06T20:11:07.711434+00:00 booking-processing-job_v002 create_emr_steps log 2023-03-29T16:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('task_id', 'create_emr_steps'), ('execution_date', '2023-03-29T16:00:00+00:00')]
3595877 04-06T20:10:45.010378+00:00 booking-processing-job_v002 check_cluster_status xcom 2021-04-25T11:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2021-04-25T11:00:00+00:00')]
3595876 04-06T20:10:26.869867+00:00 booking-processing-job_v002 check_cluster_status task 2021-12-04T06:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2021-12-04T06:00:00+00:00')]
3595875 04-06T20:10:20.200929+00:00 livepop-shuffle-aggregator-modeltransform_v004 check_input_available task 2024-12-09T03:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('task_id', 'check_input_available'), ('execution_date', '2024-12-09T03:00:00+00:00')]
3595874 04-06T20:10:15.522875+00:00 booking-processing-job_v002 check_cluster_status xcom 2021-06-03T14:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2021-06-03T14:00:00+00:00')]
3595873 04-06T20:08:47.546660+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps log 2024-12-06T16:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2024-12-06T16:00:00+00:00')]
3595872 04-06T20:08:17.088142+00:00 booking-processing-job_v002 create_emr_steps log 2024-11-18T14:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('task_id', 'create_emr_steps'), ('execution_date', '2024-11-18T14:00:00+00:00')]
3595871 04-06T20:08:04.574090+00:00 booking-processing-job_v002 create_emr_steps log 2024-12-13T14:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('task_id', 'create_emr_steps'), ('execution_date', '2024-12-13T14:00:00+00:00')]
3595870 04-06T20:07:50.332534+00:00 booking-processing-job_v002 graph 2024-12-06T05:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('execution_date', '2024-12-06 05:00:00+00:00')]
3595869 04-06T20:07:49.701652+00:00 booking-processing-job_v002 graph 2021-05-13T10:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('execution_date', '2021-05-13 10:00:00+00:00')]
3595868 04-06T20:07:48.408955+00:00 exchange-trade-summary_v1_v002 graph 02-14T11:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('run_id', 'scheduled__2025-02-14T11:00:00+00:00'), ('execution_date', '2025-02-14 11:00:00+00:00')]
3595867 04-06T20:07:45.589050+00:00 livepop-shuffle-aggregator-modeltransform_v004 check_cluster_status xcom 2024-12-19T18:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('task_id', 'check_cluster_status'), ('execution_date', '2024-12-19T18:00:00+00:00')]
3595866 04-06T20:07:34.777665+00:00 cli_scheduler airflow {"host_name": "airflow-scheduler-676bff66f6-4tgfr", "full_command": "['/home/airflow/.local/bin/airflow', 'scheduler', '-n', '-1']"}
3595865 04-06T20:07:33.184170+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']"}
3595864 04-06T20:07:31.572797+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']"}
3595863 04-06T20:07:29.617192+00:00 cli_upgradedb airflow {"host_name": "airflow-scheduler-676bff66f6-4tgfr", "full_command": "['/home/airflow/.local/bin/airflow', 'upgradedb']"}
3595862 04-06T20:07:26.883613+00:00 vc-asset-import_v002 check_cluster_status log 2024-02-19T18:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2024-02-19T18:05:00+00:00')]
3595861 04-06T20:07:25.985904+00:00 campaign-delta-past-delete-job_v002 create_emr_steps xcom 2024-12-25T23:00:00+00:00 anonymous [('dag_id', 'campaign-delta-past-delete-job_v002'), ('task_id', 'create_emr_steps'), ('execution_date', '2024-12-25T23:00:00+00:00')]