Logs

Id Dttm Dag Id Task Id Event Execution Date Owner Extra
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']"}
3626430 04-11T15:26:49.045246+00:00 campaign-history-job_v002 create_cluster_and_add_emr_steps rendered 2023-01-24T07:00:00+00:00 anonymous [('dag_id', 'campaign-history-job_v002'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2023-01-24T07:00:00+00:00')]
3626429 04-11T15:26:17.989249+00:00 vc-asset-import_v002 create_emr_steps log 2023-05-31T13:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('task_id', 'create_emr_steps'), ('execution_date', '2023-05-31T13:05:00+00:00')]
3626428 04-11T15:26:08.301427+00:00 livepop-shuffle-aggregator-modeltransform_v004 create_emr_steps xcom 2022-01-07T11:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('task_id', 'create_emr_steps'), ('execution_date', '2022-01-07T11:00:00+00:00')]
3626427 04-11T15:25:59.734009+00:00 livepop-shuffle-aggregator-modeltransform_v004 check_input_available log 2023-04-07T00:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('task_id', 'check_input_available'), ('execution_date', '2023-04-07T00:00:00+00:00')]
3626426 04-11T15:25:59.265623+00:00 booking-processing-job_v002 create_cluster_and_add_emr_steps task 2023-05-10T17:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2023-05-10T17:00:00+00:00')]
3626425 04-11T15:25:57.209287+00:00 booking-processing-job_v002 create_emr_steps log 2022-05-15T17:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('task_id', 'create_emr_steps'), ('execution_date', '2022-05-15T17:00:00+00:00')]
3626424 04-11T15:25:28.400045+00:00 vc-asset-import_v002 create_emr_steps task 2024-11-23T16:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('task_id', 'create_emr_steps'), ('execution_date', '2024-11-23T16:05:00+00:00')]
3626423 04-11T15:25:02.397307+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps log 2023-12-03T04:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2023-12-03T04:00:00+00:00')]
3626422 04-11T15:25:00.437786+00:00 livepop-shuffle-aggregator-modeltransform_v004 check_input_available log 2022-01-08T10:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('task_id', 'check_input_available'), ('execution_date', '2022-01-08T10:00:00+00:00')]
3626421 04-11T15:24:58.412452+00:00 vc-asset-import_v002 check_cluster_status log 2024-11-04T00:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2024-11-04T00:05:00+00:00')]
3626420 04-11T15:24:24.249012+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps task 2023-11-25T00:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2023-11-25T00:00:00+00:00')]
3626419 04-11T15:23:28.875167+00:00 vc-asset-import_v002 check_cluster_status log 2024-04-23T16:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2024-04-23T16:05:00+00:00')]
3626418 04-11T15:23:16.925854+00:00 vc-asset-import_v002 graph 2022-11-20T07:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('execution_date', '2022-11-20 07:05:00+00:00')]
3626417 04-11T15:22:39.606796+00:00 booking-processing-job_v002 check_cluster_status log 2021-06-21T09:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2021-06-21T09:00:00+00:00')]
3626416 04-11T15:22:18.318875+00:00 vc-asset-import_v002 create_cluster_and_add_emr_steps log 2024-08-14T12:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2024-08-14T12:05:00+00:00')]
3626415 04-11T15:22:02.199817+00:00 livepop-shuffle-aggregator-modeltransform_v004 check_cluster_status xcom 2024-11-25T02:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('task_id', 'check_cluster_status'), ('execution_date', '2024-11-25T02:00:00+00:00')]
3626414 04-11T15:21:32.233096+00:00 vc-asset-import_v002 graph 2023-05-22T00:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('root', 'check_cluster_status'), ('execution_date', '2023-05-22T00:05:00+00:00')]
3626413 04-11T15:21:27.413150+00:00 booking-processing-job_v002 create_emr_steps task 2021-12-29T00:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('task_id', 'create_emr_steps'), ('execution_date', '2021-12-29T00:00:00+00:00')]
3626412 04-11T15:21:24.621428+00:00 booking-processing-job_v002 check_cluster_status task 2021-05-15T19:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2021-05-15T19:00:00+00:00')]
3626411 04-11T15:20:17.683057+00:00 vc-asset-import_v002 check_cluster_status log 2023-12-14T17:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2023-12-14T17:05:00+00:00')]
3626410 04-11T15:19:55.551120+00:00 publisher-s3-sync publisher_sync_task log 2024-08-19T13:00:00+00:00 anonymous [('dag_id', 'publisher-s3-sync'), ('task_id', 'publisher_sync_task'), ('execution_date', '2024-08-19T13:00:00+00:00')]
3626409 04-11T15:19:53.204533+00:00 campaign-history-job_v002 check_cluster_status log 2023-03-12T22:00:00+00:00 anonymous [('dag_id', 'campaign-history-job_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2023-03-12T22:00:00+00:00')]
3626408 04-11T15:19:26.058980+00:00 cli_scheduler airflow {"host_name": "airflow-scheduler-676bff66f6-fbgmw", "full_command": "['/home/airflow/.local/bin/airflow', 'scheduler', '-n', '-1']"}
3626407 04-11T15:19:24.463742+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']"}
3626406 04-11T15:19:22.753239+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']"}
3626405 04-11T15:19:20.674189+00:00 cli_upgradedb airflow {"host_name": "airflow-scheduler-676bff66f6-fbgmw", "full_command": "['/home/airflow/.local/bin/airflow', 'upgradedb']"}