The scheduler does not appear to be running. Last heartbeat was received .

The DAGs list may not update, and new tasks will not be scheduled.

Task Instances

Reset Filters
  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-15T18:00:00+00:00 EmrCreateJobFlowOperator 2023-05-15T19:00:34.979405+00:00 2023-05-15T19:00:35.938137+00:00 0:00:00.958732 379785 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-15T19:00:32.659329+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-15T18:00:00+00:00 PythonOperator 2023-05-15T19:00:15.274655+00:00 2023-05-15T19:00:17.143091+00:00 0:00:01.868436 379783 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-15T19:00:12.636067+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-15T17:00:00+00:00 TriggerDagRunOperator 2023-05-15T18:11:06.111408+00:00 2023-05-15T18:11:06.578139+00:00 0:00:00.466731 379768 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-15T18:11:03.790895+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-15T17:00:00+00:00 TriggerDagRunOperator 2023-05-15T18:11:06.044049+00:00 2023-05-15T18:11:06.377763+00:00 0:00:00.333714 379767 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-15T18:11:03.790938+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-15T17:00:00+00:00 EmrJobFlowSensor 2023-05-15T18:00:56.843685+00:00 2023-05-15T18:10:58.793802+00:00 0:10:01.950117 379759 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-15T18:00:54.517014+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-15T17:00:00+00:00 EmrCreateJobFlowOperator 2023-05-15T18:00:34.699699+00:00 2023-05-15T18:00:35.626744+00:00 0:00:00.927045 379758 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-15T18:00:32.386064+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-15T17:00:00+00:00 PythonOperator 2023-05-15T18:00:15.158585+00:00 2023-05-15T18:00:16.211543+00:00 0:00:01.052958 379757 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-15T18:00:12.343852+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-15T16:00:00+00:00 TriggerDagRunOperator 2023-05-15T17:11:21.913728+00:00 2023-05-15T17:11:22.375150+00:00 0:00:00.461422 379742 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-15T17:11:18.911686+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-15T16:00:00+00:00 TriggerDagRunOperator 2023-05-15T17:11:21.735806+00:00 2023-05-15T17:11:22.181261+00:00 0:00:00.445455 379741 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-15T17:11:18.911640+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-15T16:00:00+00:00 EmrJobFlowSensor 2023-05-15T17:01:01.121521+00:00 2023-05-15T17:11:02.997337+00:00 0:10:01.875816 379731 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-15T17:00:58.940522+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-15T16:00:00+00:00 EmrCreateJobFlowOperator 2023-05-15T17:00:39.386693+00:00 2023-05-15T17:00:40.124896+00:00 0:00:00.738203 379730 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-15T17:00:36.983384+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-15T16:00:00+00:00 PythonOperator 2023-05-15T17:00:17.280359+00:00 2023-05-15T17:00:18.735524+00:00 0:00:01.455165 379729 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-15T17:00:14.903883+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-15T15:00:00+00:00 TriggerDagRunOperator 2023-05-15T16:25:56.913288+00:00 2023-05-15T16:25:57.354802+00:00 0:00:00.441514 379717 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-15T16:25:54.321946+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-15T15:00:00+00:00 TriggerDagRunOperator 2023-05-15T16:25:56.888598+00:00 2023-05-15T16:25:57.265604+00:00 0:00:00.377006 379716 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-15T16:25:54.322001+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-15T15:00:00+00:00 EmrJobFlowSensor 2023-05-15T16:05:37.729829+00:00 2023-05-15T16:15:39.492807+00:00 0:10:01.762978 379712 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-15T16:05:35.420920+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-15T15:00:00+00:00 EmrCreateJobFlowOperator 2023-05-15T16:05:15.556428+00:00 2023-05-15T16:05:16.477840+00:00 0:00:00.921412 379709 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-15T16:05:13.270451+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-15T15:00:00+00:00 PythonOperator 2023-05-15T16:04:55.893686+00:00 2023-05-15T16:04:56.961481+00:00 0:00:01.067795 379706 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-15T16:04:53.252811+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-15T14:00:00+00:00 TriggerDagRunOperator 2023-05-15T15:16:06.102406+00:00 2023-05-15T15:16:06.450246+00:00 0:00:00.347840 379691 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-15T15:16:03.800753+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-15T14:00:00+00:00 TriggerDagRunOperator 2023-05-15T15:16:06.124791+00:00 2023-05-15T15:16:06.624115+00:00 0:00:00.499324 379690 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-15T15:16:03.800719+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-15T14:00:00+00:00 EmrJobFlowSensor 2023-05-15T15:01:06.431026+00:00 2023-05-15T15:12:08.358182+00:00 0:11:01.927156 379686 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-15T15:01:03.990409+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-15T14:00:00+00:00 EmrCreateJobFlowOperator 2023-05-15T15:00:44.203367+00:00 2023-05-15T15:00:45.146848+00:00 0:00:00.943481 379684 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-15T15:00:41.897470+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-15T14:00:00+00:00 PythonOperator 2023-05-15T15:00:24.914938+00:00 2023-05-15T15:00:25.929655+00:00 0:00:01.014717 379682 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-15T15:00:21.816520+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-15T13:00:00+00:00 TriggerDagRunOperator 2023-05-15T14:20:29.264251+00:00 2023-05-15T14:20:29.727589+00:00 0:00:00.463338 379671 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-15T14:20:26.785083+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-15T13:00:00+00:00 TriggerDagRunOperator 2023-05-15T14:20:29.168962+00:00 2023-05-15T14:20:29.517480+00:00 0:00:00.348518 379670 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-15T14:20:26.785112+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-15T13:00:00+00:00 EmrJobFlowSensor 2023-05-15T14:10:19.929470+00:00 2023-05-15T14:20:21.697546+00:00 0:10:01.768076 379665 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-15T14:10:17.606422+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-15T13:00:00+00:00 EmrCreateJobFlowOperator 2023-05-15T14:10:00.317376+00:00 2023-05-15T14:10:02.049694+00:00 0:00:01.732318 379663 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-15T14:09:57.523172+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-15T13:00:00+00:00 PythonOperator 2023-05-15T14:09:38.838810+00:00 2023-05-15T14:09:40.932668+00:00 0:00:02.093858 379659 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-15T14:09:35.508082+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-15T12:00:00+00:00 TriggerDagRunOperator 2023-05-15T13:14:07.298926+00:00 2023-05-15T13:14:07.636483+00:00 0:00:00.337557 379647 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-15T13:14:04.479771+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-15T12:00:00+00:00 TriggerDagRunOperator 2023-05-15T13:14:07.325086+00:00 2023-05-15T13:14:07.756577+00:00 0:00:00.431491 379646 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-15T13:14:04.479803+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-15T12:00:00+00:00 EmrJobFlowSensor 2023-05-15T13:00:47.385800+00:00 2023-05-15T13:10:49.269130+00:00 0:10:01.883330 379639 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-15T13:00:45.126798+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-15T12:00:00+00:00 EmrCreateJobFlowOperator 2023-05-15T13:00:25.228736+00:00 2023-05-15T13:00:26.068665+00:00 0:00:00.839929 379637 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-15T13:00:23.086669+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-15T12:00:00+00:00 PythonOperator 2023-05-15T13:00:05.336578+00:00 2023-05-15T13:00:06.394557+00:00 0:00:01.057979 379635 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-15T13:00:03.063769+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-15T11:00:00+00:00 TriggerDagRunOperator 2023-05-15T12:17:02.609988+00:00 2023-05-15T12:17:03.051324+00:00 0:00:00.441336 379620 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-15T12:16:59.675193+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-15T11:00:00+00:00 TriggerDagRunOperator 2023-05-15T12:17:02.386593+00:00 2023-05-15T12:17:02.739927+00:00 0:00:00.353334 379619 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-15T12:16:59.675223+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-15T11:00:00+00:00 EmrJobFlowSensor 2023-05-15T12:01:00.980761+00:00 2023-05-15T12:11:03.055389+00:00 0:10:02.074628 379615 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-15T12:00:58.482344+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-15T11:00:00+00:00 EmrCreateJobFlowOperator 2023-05-15T12:00:40.849475+00:00 2023-05-15T12:00:41.801356+00:00 0:00:00.951881 379613 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-15T12:00:38.393388+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-15T11:00:00+00:00 PythonOperator 2023-05-15T12:00:19.856684+00:00 2023-05-15T12:00:21.204679+00:00 0:00:01.347995 379611 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-15T12:00:16.314479+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-15T10:00:00+00:00 TriggerDagRunOperator 2023-05-15T11:15:56.233314+00:00 2023-05-15T11:15:56.578509+00:00 0:00:00.345195 379597 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-15T11:15:52.398122+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-15T10:00:00+00:00 TriggerDagRunOperator 2023-05-15T11:15:55.095893+00:00 2023-05-15T11:15:55.536657+00:00 0:00:00.440764 379596 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-15T11:15:52.398169+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-15T10:00:00+00:00 EmrJobFlowSensor 2023-05-15T11:05:38.457511+00:00 2023-05-15T11:15:40.346842+00:00 0:10:01.889331 379591 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-15T11:05:36.228666+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-15T10:00:00+00:00 EmrCreateJobFlowOperator 2023-05-15T11:05:18.335782+00:00 2023-05-15T11:05:19.117480+00:00 0:00:00.781698 379588 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-15T11:05:16.203558+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-15T10:00:00+00:00 PythonOperator 2023-05-15T11:04:56.421804+00:00 2023-05-15T11:04:57.522901+00:00 0:00:01.101097 379585 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-15T11:04:54.168513+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-15T09:00:00+00:00 TriggerDagRunOperator 2023-05-15T10:16:35.820178+00:00 2023-05-15T10:16:36.310376+00:00 0:00:00.490198 379572 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-15T10:16:32.912412+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-15T09:00:00+00:00 TriggerDagRunOperator 2023-05-15T10:16:35.597418+00:00 2023-05-15T10:16:35.953526+00:00 0:00:00.356108 379571 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-15T10:16:32.912440+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-15T09:00:00+00:00 EmrJobFlowSensor 2023-05-15T10:06:27.677342+00:00 2023-05-15T10:16:29.448766+00:00 0:10:01.771424 379566 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-15T10:06:25.510931+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-15T09:00:00+00:00 EmrCreateJobFlowOperator 2023-05-15T10:06:07.532965+00:00 2023-05-15T10:06:08.270467+00:00 0:00:00.737502 379563 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-15T10:06:05.440542+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-15T09:00:00+00:00 PythonOperator 2023-05-15T10:05:46.104790+00:00 2023-05-15T10:05:47.130868+00:00 0:00:01.026078 379560 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-15T10:05:43.423840+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-15T08:00:00+00:00 TriggerDagRunOperator 2023-05-15T09:16:59.706183+00:00 2023-05-15T09:17:00.335747+00:00 0:00:00.629564 379548 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-15T09:16:56.900371+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-15T08:00:00+00:00 TriggerDagRunOperator 2023-05-15T09:16:59.751646+00:00 2023-05-15T09:17:00.452094+00:00 0:00:00.700448 379547 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-15T09:16:56.900414+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-15T08:00:00+00:00 EmrJobFlowSensor 2023-05-15T09:00:51.782744+00:00 2023-05-15T09:10:53.627141+00:00 0:10:01.844397 379539 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-15T09:00:49.414198+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-15T08:00:00+00:00 EmrCreateJobFlowOperator 2023-05-15T09:00:29.627169+00:00 2023-05-15T09:00:30.637698+00:00 0:00:01.010529 379537 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-15T09:00:27.386214+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-15T08:00:00+00:00 PythonOperator 2023-05-15T09:00:09.916199+00:00 2023-05-15T09:00:10.951505+00:00 0:00:01.035306 379535 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-15T09:00:07.316138+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-15T07:00:00+00:00 TriggerDagRunOperator 2023-05-15T08:14:11.610078+00:00 2023-05-15T08:14:11.956201+00:00 0:00:00.346123 379523 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-15T08:14:08.910286+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-15T07:00:00+00:00 TriggerDagRunOperator 2023-05-15T08:14:11.613812+00:00 2023-05-15T08:14:12.067616+00:00 0:00:00.453804 379522 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-15T08:14:08.910257+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-15T07:00:00+00:00 EmrJobFlowSensor 2023-05-15T08:00:58.855378+00:00 2023-05-15T08:11:00.778762+00:00 0:10:01.923384 379516 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-15T08:00:56.108238+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-15T07:00:00+00:00 EmrCreateJobFlowOperator 2023-05-15T08:00:36.685022+00:00 2023-05-15T08:00:37.491187+00:00 0:00:00.806165 379514 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-15T08:00:34.031881+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-15T07:00:00+00:00 PythonOperator 2023-05-15T08:00:16.759693+00:00 2023-05-15T08:00:17.786425+00:00 0:00:01.026732 379512 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-15T08:00:14.018068+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-15T06:00:00+00:00 TriggerDagRunOperator 2023-05-15T07:11:12.419131+00:00 2023-05-15T07:11:12.878228+00:00 0:00:00.459097 379498 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-15T07:11:09.207598+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-15T06:00:00+00:00 TriggerDagRunOperator 2023-05-15T07:11:12.286948+00:00 2023-05-15T07:11:12.669381+00:00 0:00:00.382433 379497 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-15T07:11:09.207570+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-15T06:00:00+00:00 EmrJobFlowSensor 2023-05-15T07:00:55.334331+00:00 2023-05-15T07:10:57.113133+00:00 0:10:01.778802 379489 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-15T07:00:53.000928+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-15T06:00:00+00:00 EmrCreateJobFlowOperator 2023-05-15T07:00:35.183261+00:00 2023-05-15T07:00:35.981419+00:00 0:00:00.798158 379487 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-15T07:00:32.914798+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-15T06:00:00+00:00 PythonOperator 2023-05-15T07:00:13.122357+00:00 2023-05-15T07:00:14.162016+00:00 0:00:01.039659 379485 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-15T07:00:10.868988+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-15T05:00:00+00:00 TriggerDagRunOperator 2023-05-15T06:19:14.449229+00:00 2023-05-15T06:19:14.909862+00:00 0:00:00.460633 379474 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-15T06:19:11.684356+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-15T05:00:00+00:00 TriggerDagRunOperator 2023-05-15T06:19:14.378631+00:00 2023-05-15T06:19:14.702979+00:00 0:00:00.324348 379473 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-15T06:19:11.684386+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-15T05:00:00+00:00 EmrJobFlowSensor 2023-05-15T06:01:18.972216+00:00 2023-05-15T06:11:20.840707+00:00 0:10:01.868491 379466 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-15T06:01:16.782238+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-15T05:00:00+00:00 EmrCreateJobFlowOperator 2023-05-15T06:00:56.896796+00:00 2023-05-15T06:00:57.810471+00:00 0:00:00.913675 379464 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-15T06:00:54.762895+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-15T05:00:00+00:00 PythonOperator 2023-05-15T06:00:37.566918+00:00 2023-05-15T06:00:38.645447+00:00 0:00:01.078529 379462 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-15T06:00:34.780338+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-15T04:00:00+00:00 TriggerDagRunOperator 2023-05-15T05:11:05.118074+00:00 2023-05-15T05:11:05.552808+00:00 0:00:00.434734 379447 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-15T05:11:02.323721+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-15T04:00:00+00:00 TriggerDagRunOperator 2023-05-15T05:11:05.037274+00:00 2023-05-15T05:11:05.385814+00:00 0:00:00.348540 379446 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-15T05:11:02.323764+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-15T04:00:00+00:00 EmrJobFlowSensor 2023-05-15T05:00:51.627700+00:00 2023-05-15T05:10:53.381902+00:00 0:10:01.754202 379439 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-15T05:00:49.203629+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-15T04:00:00+00:00 EmrCreateJobFlowOperator 2023-05-15T05:00:31.421697+00:00 2023-05-15T05:00:32.235204+00:00 0:00:00.813507 379437 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-15T05:00:29.110577+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-15T04:00:00+00:00 PythonOperator 2023-05-15T05:00:09.360196+00:00 2023-05-15T05:00:10.415448+00:00 0:00:01.055252 379435 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-15T05:00:07.090502+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-15T03:00:00+00:00 TriggerDagRunOperator 2023-05-15T04:11:09.947125+00:00 2023-05-15T04:11:10.395744+00:00 0:00:00.448619 379421 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-15T04:11:06.895600+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-15T03:00:00+00:00 TriggerDagRunOperator 2023-05-15T04:11:09.816336+00:00 2023-05-15T04:11:10.170910+00:00 0:00:00.354574 379420 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-15T04:11:06.895571+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-15T03:00:00+00:00 EmrJobFlowSensor 2023-05-15T04:00:51.238056+00:00 2023-05-15T04:10:53.010762+00:00 0:10:01.772706 379413 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-15T04:00:49.059980+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-15T03:00:00+00:00 EmrCreateJobFlowOperator 2023-05-15T04:00:31.234873+00:00 2023-05-15T04:00:32.088686+00:00 0:00:00.853813 379411 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-15T04:00:29.039365+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-15T03:00:00+00:00 PythonOperator 2023-05-15T04:00:09.650726+00:00 2023-05-15T04:00:10.701168+00:00 0:00:01.050442 379409 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-15T04:00:07.075651+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-15T02:00:00+00:00 TriggerDagRunOperator 2023-05-15T03:12:23.238280+00:00 2023-05-15T03:12:23.726515+00:00 0:00:00.488235 379396 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-15T03:12:20.724984+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-15T02:00:00+00:00 TriggerDagRunOperator 2023-05-15T03:12:23.111916+00:00 2023-05-15T03:12:23.452074+00:00 0:00:00.340158 379395 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-15T03:12:20.725026+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-15T02:00:00+00:00 EmrJobFlowSensor 2023-05-15T03:02:02.626901+00:00 2023-05-15T03:12:04.547297+00:00 0:10:01.920396 379388 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-15T03:02:00.441330+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-15T02:00:00+00:00 EmrCreateJobFlowOperator 2023-05-15T03:01:42.734335+00:00 2023-05-15T03:01:43.825357+00:00 0:00:01.091022 379386 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-15T03:01:40.424447+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-15T02:00:00+00:00 PythonOperator 2023-05-15T03:00:19.508411+00:00 2023-05-15T03:00:20.554885+00:00 0:00:01.046474 379383 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-15T03:00:17.023085+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-15T01:00:00+00:00 TriggerDagRunOperator 2023-05-15T02:12:19.349066+00:00 2023-05-15T02:12:19.793102+00:00 0:00:00.444036 379369 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-15T02:12:16.894343+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-15T01:00:00+00:00 TriggerDagRunOperator 2023-05-15T02:12:19.251566+00:00 2023-05-15T02:12:19.608834+00:00 0:00:00.357268 379368 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-15T02:12:16.894314+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-15T01:00:00+00:00 EmrJobFlowSensor 2023-05-15T02:01:53.034446+00:00 2023-05-15T02:11:54.887895+00:00 0:10:01.853449 379361 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-15T02:01:50.912319+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-15T01:00:00+00:00 EmrCreateJobFlowOperator 2023-05-15T02:01:31.286767+00:00 2023-05-15T02:01:32.217787+00:00 0:00:00.931020 379360 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-15T02:01:28.890783+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-15T01:00:00+00:00 PythonOperator 2023-05-15T02:01:11.611514+00:00 2023-05-15T02:01:12.655542+00:00 0:00:01.044028 379357 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-15T02:01:08.911518+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-15T00:00:00+00:00 TriggerDagRunOperator 2023-05-15T01:12:23.595497+00:00 2023-05-15T01:12:24.085145+00:00 0:00:00.489648 379337 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-15T01:12:20.582035+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-15T00:00:00+00:00 TriggerDagRunOperator 2023-05-15T01:12:23.436805+00:00 2023-05-15T01:12:23.841754+00:00 0:00:00.404949 379336 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-15T01:12:20.581994+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-15T00:00:00+00:00 EmrJobFlowSensor 2023-05-15T01:01:57.048809+00:00 2023-05-15T01:11:58.863940+00:00 0:10:01.815131 379330 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-15T01:01:54.907510+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-15T00:00:00+00:00 EmrCreateJobFlowOperator 2023-05-15T01:01:35.528934+00:00 2023-05-15T01:01:36.453709+00:00 0:00:00.924775 379328 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-15T01:01:32.834008+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-15T00:00:00+00:00 PythonOperator 2023-05-15T01:01:15.030660+00:00 2023-05-15T01:01:16.103369+00:00 0:00:01.072709 379326 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-15T01:01:12.815122+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-14T23:00:00+00:00 TriggerDagRunOperator 2023-05-15T00:11:29.411040+00:00 2023-05-15T00:11:29.924034+00:00 0:00:00.512994 379311 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-15T00:11:26.753564+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-14T23:00:00+00:00 TriggerDagRunOperator 2023-05-15T00:11:29.276478+00:00 2023-05-15T00:11:29.618777+00:00 0:00:00.342299 379310 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-15T00:11:26.753537+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-14T23:00:00+00:00 EmrJobFlowSensor 2023-05-15T00:01:18.373153+00:00 2023-05-15T00:11:20.701086+00:00 0:10:02.327933 379302 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-15T00:01:16.243015+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-14T23:00:00+00:00 EmrCreateJobFlowOperator 2023-05-15T00:00:58.779980+00:00 2023-05-15T00:00:59.708086+00:00 0:00:00.928106 379301 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-15T00:00:56.228652+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-14T23:00:00+00:00 PythonOperator 2023-05-15T00:00:05.794805+00:00 2023-05-15T00:00:06.879004+00:00 0:00:01.084199 379298 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-15T00:00:02.617701+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-14T22:00:00+00:00 TriggerDagRunOperator 2023-05-14T23:11:42.411121+00:00 2023-05-14T23:11:42.852663+00:00 0:00:00.441542 379284 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-14T23:11:39.499781+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-14T22:00:00+00:00 TriggerDagRunOperator 2023-05-14T23:11:42.279872+00:00 2023-05-14T23:11:42.651228+00:00 0:00:00.371356 379283 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-14T23:11:39.499736+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-14T22:00:00+00:00 EmrJobFlowSensor 2023-05-14T23:01:20.613649+00:00 2023-05-14T23:11:22.421338+00:00 0:10:01.807689 379276 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-14T23:01:18.299051+00:00 2 default_pool