Logs


Id Dttm Dag Id Task Id Event Execution Date Owner Extra
3627030 04-11T17:35:51.341004+00:00 livepop-shuffle-aggregator-modeltransform_v004 check_cluster_status log 2023-10-17T04:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('task_id', 'check_cluster_status'), ('execution_date', '2023-10-17T04:00:00+00:00')]
3627029 04-11T17:35:50.761351+00:00 booking-processing-job_v002 check_cluster_status xcom 2024-11-12T03:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2024-11-12T03:00:00+00:00')]
3627028 04-11T17:35:28.040060+00:00 exchange-trade-summary_v1_v002 graph 2024-10-01T03:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('root', 'check_cluster_status'), ('execution_date', '2024-10-01T03:00:00+00:00')]
3627027 04-11T17:35:23.110858+00:00 campaign-history-job_v002 graph 2021-04-14T09:00:00+00:00 anonymous [('dag_id', 'campaign-history-job_v002'), ('root', 'create_emr_steps'), ('execution_date', '2021-04-14T09:00:00+00:00')]
3627026 04-11T17:35:21.630852+00:00 campaign-history-job_v002 graph 2021-04-21T18:00:00+00:00 anonymous [('dag_id', 'campaign-history-job_v002'), ('root', 'check_cluster_status'), ('execution_date', '2021-04-21T18:00:00+00:00')]
3627025 04-11T17:35:17.425004+00:00 vc-asset-import_v002 create_emr_steps log 2024-09-03T01:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('task_id', 'create_emr_steps'), ('execution_date', '2024-09-03T01:05:00+00:00')]
3627024 04-11T17:35:03.465960+00:00 vc-asset-import_v002 check_cluster_status task 2023-09-09T16:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2023-09-09T16:05:00+00:00')]
3627023 04-11T17:35:01.834082+00:00 vc-asset-import_v002 check_cluster_status task 2024-02-02T08:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2024-02-02T08:05:00+00:00')]
3627022 04-11T17:34:43.199829+00:00 livepop-shuffle-aggregator-modeltransform_v004 check_cluster_status log 2024-01-14T06:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('task_id', 'check_cluster_status'), ('execution_date', '2024-01-14T06:00:00+00:00')]
3627021 04-11T17:34:41.698094+00:00 booking-processing-job_v002 create_emr_steps log 2024-12-22T21:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('task_id', 'create_emr_steps'), ('execution_date', '2024-12-22T21:00:00+00:00')]
3627020 04-11T17:34:25.757554+00:00 cli_scheduler airflow {"host_name": "airflow-scheduler-676bff66f6-fbgmw", "full_command": "['/home/airflow/.local/bin/airflow', 'scheduler', '-n', '-1']"}
3627019 04-11T17:34:24.056214+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']"}
3627018 04-11T17:34:22.368251+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']"}
3627017 04-11T17:34:20.306468+00:00 cli_upgradedb airflow {"host_name": "airflow-scheduler-676bff66f6-fbgmw", "full_command": "['/home/airflow/.local/bin/airflow', 'upgradedb']"}
3627016 04-11T17:34:18.843448+00:00 vc-asset-import_v002 graph 2023-09-19T18:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('root', 'create_cluster_and_add_emr_steps'), ('execution_date', '2023-09-19T18:05:00+00:00')]
3627015 04-11T17:34:18.833412+00:00 livepop-shuffle-aggregator-modeltransform_v004 check_cluster_status task 2022-01-01T15:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('task_id', 'check_cluster_status'), ('execution_date', '2022-01-01T15:00:00+00:00')]
3627014 04-11T17:34:16.987568+00:00 campaign-history-job_v002 graph 2021-06-18T03:00:00+00:00 anonymous [('dag_id', 'campaign-history-job_v002'), ('execution_date', '2021-06-18 03:00:00+00:00')]
3627013 04-11T17:34:01.935834+00:00 vc-asset-import_v002 create_emr_steps log 2024-08-31T04:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('task_id', 'create_emr_steps'), ('execution_date', '2024-08-31T04:05:00+00:00')]
3627012 04-11T17:33:51.115984+00:00 vc-asset-import_v002 create_cluster_and_add_emr_steps task 2024-11-02T04:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2024-11-02T04:05:00+00:00')]
3627011 04-11T17:33:00.142693+00:00 exchange-trade-summary_v1_v002 create_emr_steps task 2024-11-16T14:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('task_id', 'create_emr_steps'), ('execution_date', '2024-11-16T14:00:00+00:00')]
3627010 04-11T17:32:47.635606+00:00 booking-processing-job_v002 create_emr_steps xcom 2024-11-23T17:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('task_id', 'create_emr_steps'), ('execution_date', '2024-11-23T17:00:00+00:00')]
3627009 04-11T17:32:46.365229+00:00 exchange-trade-summary_v1_v002 check_cluster_status xcom 2023-11-24T02:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2023-11-24T02:00:00+00:00')]
3627008 04-11T17:32:29.381623+00:00 vc-asset-import_v002 create_cluster_and_add_emr_steps task 2022-07-05T04:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2022-07-05T04:05:00+00:00')]
3627007 04-11T17:32:16.817977+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps task 2024-02-08T02:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2024-02-08T02:00:00+00:00')]
3627006 04-11T17:31:56.840579+00:00 vc-asset-import_v002 create_emr_steps task 2024-05-16T18:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('task_id', 'create_emr_steps'), ('execution_date', '2024-05-16T18:05:00+00:00')]
3627005 04-11T17:31:55.856986+00:00 vc-asset-import_v002 create_emr_steps xcom 2023-01-14T09:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('task_id', 'create_emr_steps'), ('execution_date', '2023-01-14T09:05:00+00:00')]
3627004 04-11T17:31:18.075354+00:00 vc-asset-import_v002 graph 2024-07-29T11:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('execution_date', '2024-07-29 11:05:00+00:00')]
3627003 04-11T17:31:15.807492+00:00 vc-asset-import_v002 create_emr_steps rendered 2024-07-22T18:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('task_id', 'create_emr_steps'), ('execution_date', '2024-07-22T18:05:00+00:00')]
3627002 04-11T17:30:18.907409+00:00 campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 task 2022-01-25T14:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('task_id', 'trigger_dagrun_campaign-history-job_v002'), ('execution_date', '2022-01-25T14:00:00+00:00')]
3627001 04-11T17:30:08.277506+00:00 livepop-shuffle-aggregator-modeltransform_v004 create_cluster_and_add_emr_steps task 2024-07-17T16:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2024-07-17T16:00:00+00:00')]
3627000 04-11T17:30:03.698841+00:00 booking-processing-job_v002 create_cluster_and_add_emr_steps task 2024-11-29T02:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2024-11-29T02:00:00+00:00')]
3626999 04-11T17:30:01.252124+00:00 livepop-shuffle-aggregator-modeltransform_v004 check_cluster_status log 2022-01-06T02:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('task_id', 'check_cluster_status'), ('execution_date', '2022-01-06T02:00:00+00:00')]
3626998 04-11T17:29:58.999454+00:00 campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 task 2021-08-11T16:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('task_id', 'trigger_dagrun_booking-processing-job_v002'), ('execution_date', '2021-08-11T16:00:00+00:00')]
3626997 04-11T17:27:45.559554+00:00 vc-asset-import_v002 check_cluster_status task 2024-06-14T16:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2024-06-14T16:05:00+00:00')]
3626996 04-11T17:27:24.241583+00:00 booking-processing-job_v002 create_emr_steps log 2021-12-31T04:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('task_id', 'create_emr_steps'), ('execution_date', '2021-12-31T04:00:00+00:00')]
3626995 04-11T17:27:03.959931+00:00 vc-asset-import_v002 create_cluster_and_add_emr_steps xcom 2024-08-27T00:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2024-08-27T00:05:00+00:00')]
3626994 04-11T17:26:57.322478+00:00 livepop-shuffle-aggregator-modeltransform_v004 create_emr_steps task 2024-01-05T16:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('task_id', 'create_emr_steps'), ('execution_date', '2024-01-05T16:00:00+00:00')]
3626993 04-11T17:26:55.658526+00:00 cli_scheduler airflow {"host_name": "airflow-scheduler-676bff66f6-fbgmw", "full_command": "['/home/airflow/.local/bin/airflow', 'scheduler', '-n', '-1']"}
3626992 04-11T17:26:53.955663+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']"}
3626991 04-11T17:26:52.263716+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']"}
3626990 04-11T17:26:50.193148+00:00 cli_upgradedb airflow {"host_name": "airflow-scheduler-676bff66f6-fbgmw", "full_command": "['/home/airflow/.local/bin/airflow', 'upgradedb']"}
3626989 04-11T17:26:42.614891+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps log 01-21T14:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2025-01-21T14:00:00+00:00')]
3626988 04-11T17:25:18.760872+00:00 vc-asset-import_v002 graph 2022-06-02T21:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('execution_date', '2022-06-02 21:05:00+00:00')]
3626987 04-11T17:25:05.725259+00:00 vc-asset-import_v002 check_cluster_status task 2024-11-11T18:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2024-11-11T18:05:00+00:00')]
3626986 04-11T17:24:37.389094+00:00 livepop-shuffle-aggregator-modeltransform_v004 create_emr_steps rendered 2024-10-07T10:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('task_id', 'create_emr_steps'), ('execution_date', '2024-10-07T10:00:00+00:00')]
3626985 04-11T17:24:26.920635+00:00 booking-processing-job_v002 check_cluster_status task 2021-06-26T03:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2021-06-26T03:00:00+00:00')]
3626984 04-11T17:24:19.379998+00:00 vc-asset-import_v002 create_cluster_and_add_emr_steps task 2024-01-14T13:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2024-01-14T13:05:00+00:00')]
3626983 04-11T17:24:01.271614+00:00 exchange-trade-summary_v1_v002 graph 2024-12-04T04:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('root', 'create_cluster_and_add_emr_steps'), ('execution_date', '2024-12-04T04:00:00+00:00')]
3626982 04-11T17:23:48.838218+00:00 livepop-shuffle-aggregator-modeltransform_v004 graph 2024-01-23T17:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('root', 'create_emr_steps'), ('execution_date', '2024-01-23T17:00:00+00:00')]
3626981 04-11T17:23:01.737787+00:00 vc-asset-import_v002 graph 2023-09-14T01:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('execution_date', '2023-09-14 01:05:00+00:00')]
3626980 04-11T17:22:59.576927+00:00 booking-processing-job_v002 graph 2021-10-12T13:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('root', 'create_emr_steps'), ('execution_date', '2021-10-12T13:00:00+00:00')]
3626979 04-11T17:22:20.717581+00:00 livepop-shuffle-aggregator-modeltransform_v004 create_emr_steps rendered 2023-10-01T20:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('task_id', 'create_emr_steps'), ('execution_date', '2023-10-01T20:00:00+00:00')]
3626978 04-11T17:22:02.354781+00:00 booking-processing-job_v002 create_emr_steps xcom 2021-12-13T11:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('task_id', 'create_emr_steps'), ('execution_date', '2021-12-13T11:00:00+00:00')]
3626977 04-11T17:21:39.347309+00:00 vc-asset-import_v002 graph 2023-06-27T09:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('root', 'create_emr_steps'), ('execution_date', '2023-06-27T09:05:00+00:00')]
3626976 04-11T17:21:23.283551+00:00 livepop-shuffle-aggregator-modeltransform_v004 check_cluster_status log 2024-01-08T05:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('task_id', 'check_cluster_status'), ('execution_date', '2024-01-08T05:00:00+00:00')]
3626975 04-11T17:21:19.468468+00:00 livepop-shuffle-aggregator-modeltransform_v004 create_cluster_and_add_emr_steps task 2023-02-28T21:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2023-02-28T21:00:00+00:00')]
3626974 04-11T17:20:50.425944+00:00 exchange-trade-summary_v1_v002 graph 2024-12-17T03:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('root', 'create_cluster_and_add_emr_steps'), ('execution_date', '2024-12-17T03:00:00+00:00')]
3626973 04-11T17:20:48.582335+00:00 booking-processing-job_v002 create_emr_steps log 2021-08-26T12:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('task_id', 'create_emr_steps'), ('execution_date', '2021-08-26T12:00:00+00:00')]
3626972 04-11T17:20:43.331902+00:00 livepop-shuffle-aggregator-modeltransform_v004 graph 2023-08-01T04:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2023-08-01 04:00:00+00:00')]
3626971 04-11T17:20:38.414269+00:00 exchange-trade-summary_v1_v002 graph 2024-01-06T09:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('run_id', 'scheduled__2024-01-06T09:00:00+00:00'), ('execution_date', '2024-01-06 09:00:00+00:00')]
3626970 04-11T17:20:25.049222+00:00 livepop-shuffle-aggregator-modeltransform_v004 check_cluster_status xcom 2024-10-08T23:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('task_id', 'check_cluster_status'), ('execution_date', '2024-10-08T23:00:00+00:00')]
3626969 04-11T17:20:22.109359+00:00 exchange-trade-summary_v1_v002 create_emr_steps task 2024-07-31T04:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('task_id', 'create_emr_steps'), ('execution_date', '2024-07-31T04:00:00+00:00')]
3626968 04-11T17:20:09.396118+00:00 booking-processing-job_v002 create_emr_steps xcom 2021-12-01T01:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('task_id', 'create_emr_steps'), ('execution_date', '2021-12-01T01:00:00+00:00')]
3626967 04-11T17:19:59.997295+00:00 livepop-shuffle-aggregator-modeltransform_v004 graph 2024-11-06T11:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('root', 'check_input_available'), ('execution_date', '2024-11-06T11:00:00+00:00')]
3626966 04-11T17:19:59.432520+00:00 booking-processing-job_v002 graph 2022-07-31T08:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('execution_date', '2022-07-31 08:00:00+00:00')]
3626965 04-11T17:19:49.875085+00:00 campaign-flow-job_v002 graph 2023-05-20T05:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('root', 'trigger_dagrun_campaign-history-job_v002'), ('execution_date', '2023-05-20T05:00:00+00:00')]
3626964 04-11T17:19:47.804744+00:00 campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 log 2022-04-16T06:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('task_id', 'trigger_dagrun_campaign-history-job_v002'), ('execution_date', '2022-04-16T06:00:00+00:00')]
3626963 04-11T17:19:46.806893+00:00 booking-processing-job_v002 graph 2022-06-02T02:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('execution_date', '2022-06-02 02:00:00+00:00')]
3626962 04-11T17:19:42.369396+00:00 exchange-trade-summary_v1_v002 create_emr_steps log 2023-12-02T04:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('task_id', 'create_emr_steps'), ('execution_date', '2023-12-02T04:00:00+00:00')]
3626961 04-11T17:19:40.897358+00:00 livepop-shuffle-aggregator-modeltransform_v004 create_emr_steps log 2024-02-06T22:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('task_id', 'create_emr_steps'), ('execution_date', '2024-02-06T22:00:00+00:00')]
3626960 04-11T17:19:27.499226+00:00 vc-asset-import_v002 create_cluster_and_add_emr_steps rendered 2022-01-26T19:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2022-01-26T19:05:00+00:00')]
3626959 04-11T17:19:26.264602+00:00 cli_scheduler airflow {"host_name": "airflow-scheduler-676bff66f6-fbgmw", "full_command": "['/home/airflow/.local/bin/airflow', 'scheduler', '-n', '-1']"}
3626958 04-11T17:19:24.565209+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']"}
3626957 04-11T17:19:22.805343+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']"}
3626956 04-11T17:19:20.419819+00:00 cli_upgradedb airflow {"host_name": "airflow-scheduler-676bff66f6-fbgmw", "full_command": "['/home/airflow/.local/bin/airflow', 'upgradedb']"}
3626955 04-11T17:19:00.398232+00:00 campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 log 2023-06-07T06:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('task_id', 'trigger_dagrun_campaign-history-job_v002'), ('execution_date', '2023-06-07T06:00:00+00:00')]
3626954 04-11T17:18:41.455954+00:00 booking-processing-job_v002 check_cluster_status log 2023-03-04T03:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2023-03-04T03:00:00+00:00')]
3626953 04-11T17:18:39.188452+00:00 booking-processing-job_v002 graph 2021-09-04T14:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('root', 'create_cluster_and_add_emr_steps'), ('execution_date', '2021-09-04T14:00:00+00:00')]
3626952 04-11T17:18:32.218933+00:00 exchange-daily-revenue-report_v002 create_cluster_and_add_emr_steps xcom 2024-09-03T09:00:00+00:00 anonymous [('dag_id', 'exchange-daily-revenue-report_v002'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2024-09-03T09:00:00+00:00')]
3626951 04-11T17:18:08.727828+00:00 vc-asset-import_v002 graph 2024-11-15T17:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('execution_date', '2024-11-15T17:05:00+00:00')]
3626950 04-11T17:17:38.820774+00:00 booking-processing-job_v002 check_cluster_status log 2021-07-24T05:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2021-07-24T05:00:00+00:00')]
3626949 04-11T17:17:30.271457+00:00 exchange-trade-summary_v1_v002 graph 2024-05-18T04:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('root', 'create_cluster_and_add_emr_steps'), ('execution_date', '2024-05-18T04:00:00+00:00')]
3626948 04-11T17:17:00.195955+00:00 campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 log 2021-12-17T00:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('task_id', 'trigger_dagrun_booking-processing-job_v002'), ('execution_date', '2021-12-17T00:00:00+00:00')]
3626947 04-11T17:16:59.031915+00:00 vc-asset-import_v002 graph 2022-10-02T12:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('root', 'create_cluster_and_add_emr_steps'), ('execution_date', '2022-10-02T12:05:00+00:00')]
3626946 04-11T17:16:22.955530+00:00 booking-processing-job_v002 graph 2023-06-02T21:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('root', 'create_cluster_and_add_emr_steps'), ('execution_date', '2023-06-02T21:00:00+00:00')]
3626945 04-11T17:16:22.332523+00:00 booking-processing-job_v002 create_cluster_and_add_emr_steps log 2021-06-01T21:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2021-06-01T21:00:00+00:00')]
3626944 04-11T17:16:16.348514+00:00 vc-asset-import_v002 create_cluster_and_add_emr_steps task 2024-11-08T01:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2024-11-08T01:05:00+00:00')]
3626943 04-11T17:16:10.309318+00:00 exchange-trade-summary_v1_v002 check_cluster_status success 04-11T16:00:00+00:00 data.engineers@viooh.com
3626942 04-11T17:15:28.362824+00:00 livepop-shuffle-aggregator-modeltransform_v004 graph 2024-10-25T19:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('root', 'check_input_available'), ('execution_date', '2024-10-25T19:00:00+00:00')]
3626941 04-11T17:15:21.254435+00:00 vc-asset-import_v002 graph 2024-07-02T00:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('root', 'create_emr_steps'), ('execution_date', '2024-07-02T00:05:00+00:00')]
3626940 04-11T17:15:20.703124+00:00 livepop-shuffle-aggregator-modeltransform_v004 check_input_available log 2022-07-29T06:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('task_id', 'check_input_available'), ('execution_date', '2022-07-29T06:00:00+00:00')]
3626939 04-11T17:15:19.212269+00:00 vc-asset-import_v002 create_emr_steps task 2024-02-06T02:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('task_id', 'create_emr_steps'), ('execution_date', '2024-02-06T02:05:00+00:00')]
3626938 04-11T17:15:18.414704+00:00 booking-processing-job_v002 create_cluster_and_add_emr_steps xcom 2021-04-09T17:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2021-04-09T17:00:00+00:00')]
3626937 04-11T17:14:49.907614+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps log 01-18T09:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2025-01-18T09:00:00+00:00')]
3626936 04-11T17:14:48.104506+00:00 booking-processing-job_v002 check_cluster_status log 2023-05-18T22:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2023-05-18T22:00:00+00:00')]
3626935 04-11T17:14:05.999897+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps rendered 2024-07-09T03:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2024-07-09T03:00:00+00:00')]
3626934 04-11T17:13:58.992869+00:00 livepop-shuffle-aggregator-modeltransform_v004 graph 2022-08-14T14:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2022-08-14 14:00:00+00:00')]
3626933 04-11T17:13:38.393061+00:00 exchange-trade-summary_v1_v002 check_cluster_status log 2024-09-19T03:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2024-09-19T03:00:00+00:00')]
3626932 04-11T17:12:58.960214+00:00 livepop-shuffle-aggregator-modeltransform_v004 create_emr_steps log 2024-03-02T04:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('task_id', 'create_emr_steps'), ('execution_date', '2024-03-02T04:00:00+00:00')]
3626931 04-11T17:12:36.163705+00:00 campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 log 2021-07-23T14:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('task_id', 'trigger_dagrun_booking-processing-job_v002'), ('execution_date', '2021-07-23T14:00:00+00:00')]