Logs

Id Dttm Dag Id Task Id Event Execution Date Owner Extra
3626530 04-11T15:48:37.012875+00:00 vc-asset-import_v002 graph 2024-03-09T22:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('root', 'check_cluster_status'), ('execution_date', '2024-03-09T22:05:00+00:00')]
3626529 04-11T15:48:36.234090+00:00 livepop-shuffle-aggregator-modeltransform_v004 graph 2024-12-14T12:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('run_id', 'scheduled__2024-12-14T12:00:00+00:00'), ('execution_date', '2024-12-14 12:00:00+00:00')]
3626528 04-11T15:48:34.215300+00:00 vc-asset-import_v002 create_cluster_and_add_emr_steps task 2024-10-04T18:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2024-10-04T18:05:00+00:00')]
3626527 04-11T15:48:28.600413+00:00 vc-asset-import_v002 graph 2022-07-19T23:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('root', 'create_emr_steps'), ('execution_date', '2022-07-19T23:05:00+00:00')]
3626526 04-11T15:48:20.302610+00:00 livepop-shuffle-aggregator-modeltransform_v004 create_emr_steps task 2023-01-21T00:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('task_id', 'create_emr_steps'), ('execution_date', '2023-01-21T00:00:00+00:00')]
3626525 04-11T15:48:03.795485+00:00 livepop-shuffle-aggregator-modeltransform_v004 check_cluster_status xcom 2024-09-24T18:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('task_id', 'check_cluster_status'), ('execution_date', '2024-09-24T18:00:00+00:00')]
3626524 04-11T15:48:02.853497+00:00 vc-asset-import_v002 graph 2023-08-06T07:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('execution_date', '2023-08-06 07:05:00+00:00')]
3626523 04-11T15:48:02.471481+00:00 exchange-trade-summary_v1_v002 check_cluster_status log 2024-03-06T14:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2024-03-06T14:00:00+00:00')]
3626522 04-11T15:47:58.966855+00:00 livepop-shuffle-aggregator-modeltransform_v004 graph 2024-10-13T02:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2024-10-13T02:00:00+00:00')]
3626521 04-11T15:47:24.505772+00:00 publisher-s3-sync publisher_sync_task log 2024-08-10T08:00:00+00:00 anonymous [('dag_id', 'publisher-s3-sync'), ('task_id', 'publisher_sync_task'), ('execution_date', '2024-08-10T08:00:00+00:00')]
3626520 04-11T15:47:20.399287+00:00 booking-processing-job_v002 check_cluster_status rendered 2021-04-27T13:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2021-04-27T13:00:00+00:00')]
3626519 04-11T15:47:12.731504+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')]
3626518 04-11T15:47:05.009615+00:00 publisher-s3-sync publisher_sync_task log 03-02T14:00:00+00:00 anonymous [('dag_id', 'publisher-s3-sync'), ('task_id', 'publisher_sync_task'), ('execution_date', '2025-03-02T14:00:00+00:00')]
3626517 04-11T15:47:03.537306+00:00 livepop-shuffle-aggregator-modeltransform_v004 create_cluster_and_add_emr_steps log 2023-08-29T04:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2023-08-29T04:00:00+00:00')]
3626516 04-11T15:47:00.574381+00:00 booking-processing-job_v002 graph 2021-04-02T23:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('root', 'create_emr_steps'), ('execution_date', '2021-04-02T23:00:00+00:00')]
3626515 04-11T15:46:58.688160+00:00 vc-asset-import_v002 check_cluster_status log 2024-03-14T07:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2024-03-14T07:05:00+00:00')]
3626514 04-11T15:46:34.296332+00:00 livepop-shuffle-aggregator-modeltransform_v004 create_cluster_and_add_emr_steps log 2024-05-28T05:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2024-05-28T05:00:00+00:00')]
3626513 04-11T15:46:30.235818+00:00 booking-processing-job_v002 create_emr_steps log 2022-01-10T06:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('task_id', 'create_emr_steps'), ('execution_date', '2022-01-10T06:00:00+00:00')]
3626512 04-11T15:46:10.418049+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps log 2024-06-20T09:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2024-06-20T09:00:00+00:00')]
3626511 04-11T15:45:54.354824+00:00 booking-processing-job_v002 create_cluster_and_add_emr_steps rendered 2022-02-11T20:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2022-02-11T20:00:00+00:00')]
3626510 04-11T15:45:04.017169+00:00 vc-asset-import_v002 graph 2023-05-07T15:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('root', 'create_emr_steps'), ('execution_date', '2023-05-07T15:05:00+00:00')]
3626509 04-11T15:44:58.560645+00:00 campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 task 2021-03-21T10:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('task_id', 'trigger_dagrun_booking-processing-job_v002'), ('execution_date', '2021-03-21T10:00:00+00:00')]
3626508 04-11T15:44:53.466651+00:00 booking-processing-job_v002 graph 2021-05-11T08:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('execution_date', '2021-05-11 08:00:00+00:00')]
3626507 04-11T15:44:49.716127+00:00 exchange-trade-summary_v1_v002 check_cluster_status rendered 2023-11-12T01:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2023-11-12T01:00:00+00:00')]
3626506 04-11T15:44:38.473474+00:00 campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 rendered 2021-10-29T10:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('task_id', 'trigger_dagrun_campaign-history-job_v002'), ('execution_date', '2021-10-29T10:00:00+00:00')]
3626505 04-11T15:44:18.743011+00:00 booking-processing-job_v002 check_cluster_status log 2021-07-20T20:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2021-07-20T20:00:00+00:00')]
3626504 04-11T15:43:54.104333+00:00 livepop-shuffle-aggregator-modeltransform_v004 create_emr_steps log 2024-02-03T18:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('task_id', 'create_emr_steps'), ('execution_date', '2024-02-03T18:00:00+00:00')]
3626503 04-11T15:43:51.768846+00:00 booking-processing-job_v002 graph 2021-12-27T05:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('execution_date', '2021-12-27 05:00:00+00:00')]
3626502 04-11T15:43:50.639353+00:00 exchange-trade-summary_v1_v002 graph 2024-11-08T11:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('run_id', 'scheduled__2024-11-08T11:00:00+00:00'), ('execution_date', '2024-11-08 11:00:00+00:00')]
3626501 04-11T15:43:09.102333+00:00 booking-processing-job_v002 create_cluster_and_add_emr_steps task 2024-11-29T04:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2024-11-29T04:00:00+00:00')]
3626500 04-11T15:42:48.876953+00:00 campaign-delta-past-delete-job_v002 check_cluster_status log 2021-10-24T23:00:00+00:00 anonymous [('dag_id', 'campaign-delta-past-delete-job_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2021-10-24T23:00:00+00:00')]
3626499 04-11T15:41:56.104633+00:00 cli_scheduler airflow {"host_name": "airflow-scheduler-676bff66f6-fbgmw", "full_command": "['/home/airflow/.local/bin/airflow', 'scheduler', '-n', '-1']"}
3626498 04-11T15:41:54.188218+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']"}
3626497 04-11T15:41:52.454679+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']"}
3626496 04-11T15:41:50.299712+00:00 cli_upgradedb airflow {"host_name": "airflow-scheduler-676bff66f6-fbgmw", "full_command": "['/home/airflow/.local/bin/airflow', 'upgradedb']"}
3626495 04-11T15:41:17.915822+00:00 campaign-history-job_v002 check_cluster_status xcom 2021-03-20T23:00:00+00:00 anonymous [('dag_id', 'campaign-history-job_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2021-03-20T23:00:00+00:00')]
3626494 04-11T15:41:11.751442+00:00 Terminate_Custom_EMR_Clusters terminate_emr_clusters_task rendered 2024-08-20T18:30:00+00:00 anonymous [('dag_id', 'Terminate_Custom_EMR_Clusters'), ('task_id', 'terminate_emr_clusters_task'), ('execution_date', '2024-08-20T18:30:00+00:00')]
3626493 04-11T15:41:08.228955+00:00 vc-asset-import_v002 check_cluster_status rendered 2024-07-14T04:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2024-07-14T04:05:00+00:00')]
3626492 04-11T15:40:59.512496+00:00 exchange-trade-summary_v1_v002 graph 2024-10-15T05:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('root', 'check_cluster_status'), ('execution_date', '2024-10-15T05:00:00+00:00')]
3626491 04-11T15:40:58.871952+00:00 livepop-shuffle-aggregator-modeltransform_v004 create_emr_steps log 2022-01-21T04:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('task_id', 'create_emr_steps'), ('execution_date', '2022-01-21T04:00:00+00:00')]
3626490 04-11T15:40:47.358072+00:00 booking-processing-job_v002 graph 2022-03-16T19:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('run_id', 'trig__2022-03-16T19:00:00+00:00'), ('execution_date', '2022-03-16 19:00:00+00:00')]
3626489 04-11T15:40:32.623532+00:00 booking-processing-job_v002 graph 2024-12-01T15:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('root', 'create_cluster_and_add_emr_steps'), ('execution_date', '2024-12-01T15:00:00+00:00')]
3626488 04-11T15:40:20.505263+00:00 booking-processing-job_v002 check_cluster_status log 2021-04-20T18:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2021-04-20T18:00:00+00:00')]
3626487 04-11T15:40:18.623571+00:00 exchange-dsp-reporting_v002 graph 2024-02-23T04:00:00+00:00 anonymous [('dag_id', 'exchange-dsp-reporting_v002'), ('root', 'check_cluster_status'), ('execution_date', '2024-02-23T04:00:00+00:00')]
3626486 04-11T15:40:11.354600+00:00 vc-asset-import_v002 check_cluster_status log 2023-08-05T02:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2023-08-05T02:05:00+00:00')]
3626485 04-11T15:40:09.092194+00:00 vc-asset-import_v002 create_cluster_and_add_emr_steps log 2023-10-12T00:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2023-10-12T00:05:00+00:00')]
3626484 04-11T15:39:29.586216+00:00 livepop-shuffle-aggregator-modeltransform_v004 create_emr_steps xcom 2024-08-05T04:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('task_id', 'create_emr_steps'), ('execution_date', '2024-08-05T04:00:00+00:00')]
3626483 04-11T15:39:19.428408+00:00 exchange-trade-summary_v1_v002 graph 03-06T19:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('run_id', 'scheduled__2025-03-06T19:00:00+00:00'), ('execution_date', '2025-03-06 19:00:00+00:00')]
3626482 04-11T15:39:11.862925+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps task 2024-03-20T15:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2024-03-20T15:00:00+00:00')]
3626481 04-11T15:38:59.195225+00:00 vc-asset-import_v002 create_cluster_and_add_emr_steps log 2024-01-20T07:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2024-01-20T07:05:00+00:00')]
3626480 04-11T15:37:36.571007+00:00 livepop-shuffle-aggregator-modeltransform_v004 graph 2022-01-24T08:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('root', 'create_emr_steps'), ('execution_date', '2022-01-24T08:00:00+00:00')]
3626479 04-11T15:37:29.351904+00:00 exchange-trade-summary_v1_v002 graph 2024-08-25T11:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('root', 'check_cluster_status'), ('execution_date', '2024-08-25T11:00:00+00:00')]
3626478 04-11T15:37:13.249301+00:00 booking-processing-job_v002 graph 2024-11-13T22:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('root', 'create_emr_steps'), ('execution_date', '2024-11-13T22:00:00+00:00')]
3626477 04-11T15:37:09.969388+00:00 vc-asset-import_v002 graph 2022-06-21T08:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('root', 'create_emr_steps'), ('execution_date', '2022-06-21T08:05:00+00:00')]
3626476 04-11T15:36:59.659956+00:00 vc-asset-import_v002 create_cluster_and_add_emr_steps task 2024-07-21T06:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2024-07-21T06:05:00+00:00')]
3626475 04-11T15:36:38.639956+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')]
3626474 04-11T15:36:29.193037+00:00 booking-processing-job_v002 check_cluster_status log 2021-05-27T19:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2021-05-27T19:00:00+00:00')]
3626473 04-11T15:35:28.672042+00:00 vc-asset-import_v002 create_cluster_and_add_emr_steps task 2024-12-06T18:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2024-12-06T18:05:00+00:00')]
3626472 04-11T15:35:18.000687+00:00 vc-asset-import_v002 check_cluster_status rendered 2024-02-21T01:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2024-02-21T01:05:00+00:00')]
3626471 04-11T15:35:09.647328+00:00 livepop-shuffle-aggregator-modeltransform_v004 check_input_available task 2024-06-16T17:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('task_id', 'check_input_available'), ('execution_date', '2024-06-16T17:00:00+00:00')]
3626470 04-11T15:34:26.158627+00:00 cli_scheduler airflow {"host_name": "airflow-scheduler-676bff66f6-fbgmw", "full_command": "['/home/airflow/.local/bin/airflow', 'scheduler', '-n', '-1']"}
3626469 04-11T15:34:24.446426+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']"}
3626468 04-11T15:34:22.460873+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']"}
3626467 04-11T15:34:20.302174+00:00 cli_upgradedb airflow {"host_name": "airflow-scheduler-676bff66f6-fbgmw", "full_command": "['/home/airflow/.local/bin/airflow', 'upgradedb']"}
3626466 04-11T15:34:09.834492+00:00 booking-processing-job_v002 graph 2022-06-04T01:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('root', 'check_cluster_status'), ('execution_date', '2022-06-04T01:00:00+00:00')]
3626465 04-11T15:33:08.414037+00:00 booking-processing-job_v002 create_cluster_and_add_emr_steps task 2024-12-24T18:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2024-12-24T18:00:00+00:00')]
3626464 04-11T15:32:50.577523+00:00 vc-asset-import_v002 create_emr_steps task 2023-03-19T13:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('task_id', 'create_emr_steps'), ('execution_date', '2023-03-19T13:05:00+00:00')]
3626463 04-11T15:32:49.053628+00:00 campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 log 2023-05-28T19:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('task_id', 'trigger_dagrun_campaign-history-job_v002'), ('execution_date', '2023-05-28T19:00:00+00:00')]
3626462 04-11T15:32:27.812138+00:00 campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 log 2023-01-10T23:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('task_id', 'trigger_dagrun_campaign-history-job_v002'), ('execution_date', '2023-01-10T23:00:00+00:00')]
3626461 04-11T15:32:18.008960+00:00 vc-asset-import_v002 graph 2021-05-28T04:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('root', 'create_emr_steps'), ('execution_date', '2021-05-28T04:05:00+00:00')]
3626460 04-11T15:31:59.148257+00:00 exchange-trade-summary_v1_v002 check_cluster_status task 2024-05-09T15:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2024-05-09T15:00:00+00:00')]
3626459 04-11T15:31:56.204169+00:00 exchange-trade-summary_v1_v002 check_cluster_status xcom 2023-11-08T13:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2023-11-08T13:00:00+00:00')]
3626458 04-11T15:31:28.899986+00:00 livepop-shuffle-aggregator-modeltransform_v004 check_input_available task 2024-07-15T11:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('task_id', 'check_input_available'), ('execution_date', '2024-07-15T11:00:00+00:00')]
3626457 04-11T15:31:26.977342+00:00 campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 log 2021-03-20T16:00:00+00:00 anonymous [('dag_id', 'campaign-flow-job_v002'), ('task_id', 'trigger_dagrun_campaign-history-job_v002'), ('execution_date', '2021-03-20T16:00:00+00:00')]
3626456 04-11T15:31:26.555775+00:00 booking-processing-job_v002 create_emr_steps rendered 2024-11-25T20:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('task_id', 'create_emr_steps'), ('execution_date', '2024-11-25T20:00:00+00:00')]
3626455 04-11T15:31:23.311029+00:00 livepop-invalid-flow_v002 graph 2022-05-12T02:00:00+00:00 anonymous [('dag_id', 'livepop-invalid-flow_v002'), ('execution_date', '2022-05-12T02:00:00+00:00')]
3626454 04-11T15:31:21.918746+00:00 livepop-shuffle-aggregator-modeltransform_v004 check_cluster_status xcom 2024-10-10T10:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('task_id', 'check_cluster_status'), ('execution_date', '2024-10-10T10:00:00+00:00')]
3626453 04-11T15:30:56.062881+00:00 exchange-trade-summary_v1_v002 graph 2024-07-08T16:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('root', 'create_cluster_and_add_emr_steps'), ('execution_date', '2024-07-08T16:00:00+00:00')]
3626452 04-11T15:30:35.362805+00:00 exchange-trade-summary_v1_v002 graph 03-15T02:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('run_id', 'scheduled__2025-03-15T02:00:00+00:00'), ('execution_date', '2025-03-15 02:00:00+00:00')]
3626451 04-11T15:30:19.922720+00:00 vc-asset-import_v002 create_cluster_and_add_emr_steps log 2024-05-02T07:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2024-05-02T07:05:00+00:00')]
3626450 04-11T15:30:16.479562+00:00 livepop-shuffle-aggregator-modeltransform_v004 create_cluster_and_add_emr_steps rendered 2022-01-22T03:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2022-01-22T03:00:00+00:00')]
3626449 04-11T15:30:01.549002+00:00 booking-processing-job_v002 create_cluster_and_add_emr_steps task 2024-12-08T19:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2024-12-08T19:00:00+00:00')]
3626448 04-11T15:29:58.793926+00:00 vc-asset-import_v002 check_cluster_status log 2021-10-21T11:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2021-10-21T11:05:00+00:00')]
3626447 04-11T15:29:33.350138+00:00 exchange-trade-summary_v1_v002 create_emr_steps task 2023-12-10T00:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('task_id', 'create_emr_steps'), ('execution_date', '2023-12-10T00:00:00+00:00')]
3626446 04-11T15:29:33.349553+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps xcom 01-14T22:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2025-01-14T22:00:00+00:00')]
3626445 04-11T15:29:28.198845+00:00 vc-asset-import_v002 create_cluster_and_add_emr_steps task 2021-12-16T00:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2021-12-16T00:05:00+00:00')]
3626444 04-11T15:29:12.638179+00:00 vc-asset-import_v002 create_cluster_and_add_emr_steps log 2024-05-11T23:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2024-05-11T23:05:00+00:00')]
3626443 04-11T15:29:02.225056+00:00 booking-processing-job_v002 check_cluster_status rendered 2023-02-24T19:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2023-02-24T19:00:00+00:00')]
3626442 04-11T15:29:01.074404+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps xcom 2024-06-05T12:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2024-06-05T12:00:00+00:00')]
3626441 04-11T15:28:59.420653+00:00 booking-processing-job_v002 create_cluster_and_add_emr_steps task 2024-12-27T19:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2024-12-27T19:00:00+00:00')]
3626440 04-11T15:28:44.428970+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps log 02-16T15:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2025-02-16T15:00:00+00:00')]
3626439 04-11T15:28:36.685719+00:00 vc-asset-import_v002 graph 2024-04-20T01:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('execution_date', '2024-04-20 01:05:00+00:00')]
3626438 04-11T15:28:29.200300+00:00 vc-asset-import_v002 create_emr_steps task 2023-12-16T17:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('task_id', 'create_emr_steps'), ('execution_date', '2023-12-16T17:05:00+00:00')]
3626437 04-11T15:27:38.118328+00:00 exchange-trade-summary_v1_v002 check_cluster_status log 2024-09-14T04:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2024-09-14T04:00:00+00:00')]
3626436 04-11T15:27:25.399305+00:00 booking-processing-job_v002 create_cluster_and_add_emr_steps task 2021-06-15T02:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2021-06-15T02:00:00+00:00')]
3626435 04-11T15:27:09.879007+00:00 exchange-trade-summary_v1_v002 check_cluster_status task 2023-12-06T10:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2023-12-06T10:00:00+00:00')]
3626434 04-11T15:26:56.248099+00:00 cli_scheduler airflow {"host_name": "airflow-scheduler-676bff66f6-fbgmw", "full_command": "['/home/airflow/.local/bin/airflow', 'scheduler', '-n', '-1']"}
3626433 04-11T15:26:54.394645+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']"}
3626432 04-11T15:26:52.454267+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']"}
3626431 04-11T15:26:50.313419+00:00 cli_upgradedb airflow {"host_name": "airflow-scheduler-676bff66f6-fbgmw", "full_command": "['/home/airflow/.local/bin/airflow', 'upgradedb']"}