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-12T10:00:00+00:00 EmrCreateJobFlowOperator 2023-05-12T11:00:43.023974+00:00 2023-05-12T11:00:43.843326+00:00 0:00:00.819352 377793 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-12T11:00:40.869924+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-12T10:00:00+00:00 PythonOperator 2023-05-12T11:00:23.025835+00:00 2023-05-12T11:00:24.055839+00:00 0:00:01.030004 377791 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-12T11:00:20.850426+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-12T09:00:00+00:00 TriggerDagRunOperator 2023-05-12T10:12:27.541933+00:00 2023-05-12T10:12:27.991970+00:00 0:00:00.450037 377778 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-12T10:12:25.087970+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-12T09:00:00+00:00 TriggerDagRunOperator 2023-05-12T10:12:27.412429+00:00 2023-05-12T10:12:27.759668+00:00 0:00:00.347239 377777 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-12T10:12:25.087917+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-12T09:00:00+00:00 EmrJobFlowSensor 2023-05-12T10:01:03.146722+00:00 2023-05-12T10:12:05.162461+00:00 0:11:02.015739 377770 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-12T10:01:00.990623+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-12T09:00:00+00:00 EmrCreateJobFlowOperator 2023-05-12T10:00:43.224556+00:00 2023-05-12T10:00:44.084789+00:00 0:00:00.860233 377768 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-12T10:00:40.972319+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-12T09:00:00+00:00 PythonOperator 2023-05-12T10:00:21.922474+00:00 2023-05-12T10:00:22.952597+00:00 0:00:01.030123 377766 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-12T10:00:18.937406+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-12T08:00:00+00:00 TriggerDagRunOperator 2023-05-12T09:14:41.290402+00:00 2023-05-12T09:14:41.832588+00:00 0:00:00.542186 377757 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-12T09:14:38.314575+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-12T08:00:00+00:00 TriggerDagRunOperator 2023-05-12T09:14:41.218701+00:00 2023-05-12T09:14:41.607220+00:00 0:00:00.388519 377756 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-12T09:14:38.314545+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-12T08:00:00+00:00 EmrJobFlowSensor 2023-05-12T09:04:22.146850+00:00 2023-05-12T09:14:24.131228+00:00 0:10:01.984378 377749 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-12T09:04:19.874398+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-12T08:00:00+00:00 EmrCreateJobFlowOperator 2023-05-12T09:04:00.410833+00:00 2023-05-12T09:04:01.399798+00:00 0:00:00.988965 377747 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-12T09:03:57.852329+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-12T08:00:00+00:00 PythonOperator 2023-05-12T09:03:40.561871+00:00 2023-05-12T09:03:41.552795+00:00 0:00:00.990924 377745 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-12T09:03:37.836933+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-12T07:00:00+00:00 TriggerDagRunOperator 2023-05-12T08:20:05.495384+00:00 2023-05-12T08:20:05.932110+00:00 0:00:00.436726 377733 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-12T08:20:02.922706+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-12T07:00:00+00:00 TriggerDagRunOperator 2023-05-12T08:20:05.360209+00:00 2023-05-12T08:20:05.709507+00:00 0:00:00.349298 377732 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-12T08:20:02.922657+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-12T07:00:00+00:00 EmrJobFlowSensor 2023-05-12T08:19:43.053668+00:00 2023-05-12T08:19:43.608718+00:00 0:00:00.555050 377731 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-12T08:19:40.834111+00:00 3 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-12T07:00:00+00:00 EmrCreateJobFlowOperator 2023-05-12T08:07:18.249854+00:00 2023-05-12T08:07:19.237329+00:00 0:00:00.987475 377722 airflow-worker-2.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-12T08:07:14.977872+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-12T07:00:00+00:00 PythonOperator 2023-05-12T08:00:22.800904+00:00 2023-05-12T08:00:24.768121+00:00 0:00:01.967217 377717 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-12T08:00:19.513212+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-12T06:00:00+00:00 TriggerDagRunOperator 2023-05-12T07:18:59.945794+00:00 2023-05-12T07:19:00.612362+00:00 0:00:00.666568 377706 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-12T07:18:56.701995+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-12T06:00:00+00:00 TriggerDagRunOperator 2023-05-12T07:18:59.885215+00:00 2023-05-12T07:19:00.449871+00:00 0:00:00.564656 377705 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-12T07:18:56.701951+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-12T06:00:00+00:00 EmrJobFlowSensor 2023-05-12T07:06:16.633515+00:00 2023-05-12T07:16:18.719360+00:00 0:10:02.085845 377701 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-12T07:06:14.401821+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-12T06:00:00+00:00 EmrCreateJobFlowOperator 2023-05-12T07:05:55.396235+00:00 2023-05-12T07:05:56.228826+00:00 0:00:00.832591 377698 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-12T07:05:52.321655+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-12T06:00:00+00:00 PythonOperator 2023-05-12T07:05:34.461155+00:00 2023-05-12T07:05:35.545393+00:00 0:00:01.084238 377695 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-12T07:05:32.300966+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-12T05:00:00+00:00 TriggerDagRunOperator 2023-05-12T06:11:22.439338+00:00 2023-05-12T06:11:22.899328+00:00 0:00:00.459990 377680 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-12T06:11:20.082614+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-12T05:00:00+00:00 TriggerDagRunOperator 2023-05-12T06:11:22.388987+00:00 2023-05-12T06:11:22.760062+00:00 0:00:00.371075 377679 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-12T06:11:20.082649+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-12T05:00:00+00:00 EmrJobFlowSensor 2023-05-12T06:01:03.208527+00:00 2023-05-12T06:11:05.185260+00:00 0:10:01.976733 377673 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-12T06:01:01.033524+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-12T05:00:00+00:00 EmrCreateJobFlowOperator 2023-05-12T06:00:43.449094+00:00 2023-05-12T06:00:44.400697+00:00 0:00:00.951603 377671 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-12T06:00:41.088895+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-12T05:00:00+00:00 PythonOperator 2023-05-12T06:00:21.140329+00:00 2023-05-12T06:00:22.100131+00:00 0:00:00.959802 377669 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-12T06:00:18.935973+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-12T04:00:00+00:00 TriggerDagRunOperator 2023-05-12T05:14:27.704137+00:00 2023-05-12T05:14:28.050737+00:00 0:00:00.346600 377655 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-12T05:14:25.210317+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-12T04:00:00+00:00 TriggerDagRunOperator 2023-05-12T05:14:27.711601+00:00 2023-05-12T05:14:28.159090+00:00 0:00:00.447489 377654 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-12T05:14:25.210350+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-12T04:00:00+00:00 EmrJobFlowSensor 2023-05-12T05:01:44.827753+00:00 2023-05-12T05:12:47.024869+00:00 0:11:02.197116 377647 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-12T05:01:42.557432+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-12T04:00:00+00:00 EmrCreateJobFlowOperator 2023-05-12T05:01:23.026419+00:00 2023-05-12T05:01:23.939016+00:00 0:00:00.912597 377646 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-12T05:01:20.602359+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-12T04:00:00+00:00 PythonOperator 2023-05-12T05:01:03.319610+00:00 2023-05-12T05:01:04.401662+00:00 0:00:01.082052 377644 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-12T05:01:00.300916+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-12T03:00:00+00:00 TriggerDagRunOperator 2023-05-12T04:11:12.830757+00:00 2023-05-12T04:11:13.256063+00:00 0:00:00.425306 377630 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-12T04:11:10.406713+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-12T03:00:00+00:00 TriggerDagRunOperator 2023-05-12T04:11:12.712437+00:00 2023-05-12T04:11:13.034611+00:00 0:00:00.322174 377629 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-12T04:11:10.406743+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-12T03:00:00+00:00 EmrJobFlowSensor 2023-05-12T04:00:59.279157+00:00 2023-05-12T04:11:01.343123+00:00 0:10:02.063966 377621 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-12T04:00:57.089069+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-12T03:00:00+00:00 EmrCreateJobFlowOperator 2023-05-12T04:00:39.157027+00:00 2023-05-12T04:00:40.025505+00:00 0:00:00.868478 377619 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-12T04:00:37.019326+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-12T03:00:00+00:00 PythonOperator 2023-05-12T04:00:17.217743+00:00 2023-05-12T04:00:18.243694+00:00 0:00:01.025951 377617 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-12T04:00:15.005830+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-12T02:00:00+00:00 TriggerDagRunOperator 2023-05-12T03:12:05.134237+00:00 2023-05-12T03:12:05.574334+00:00 0:00:00.440097 377604 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-12T03:12:02.043389+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-12T02:00:00+00:00 TriggerDagRunOperator 2023-05-12T03:12:05.018787+00:00 2023-05-12T03:12:05.340983+00:00 0:00:00.322196 377603 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-12T03:12:02.043434+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-12T02:00:00+00:00 EmrJobFlowSensor 2023-05-12T03:00:49.539591+00:00 2023-05-12T03:11:51.494160+00:00 0:11:01.954569 377595 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-12T03:00:47.195518+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-12T02:00:00+00:00 EmrCreateJobFlowOperator 2023-05-12T03:00:27.248129+00:00 2023-05-12T03:00:27.985324+00:00 0:00:00.737195 377593 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-12T03:00:25.103937+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-12T02:00:00+00:00 PythonOperator 2023-05-12T03:00:07.402487+00:00 2023-05-12T03:00:08.383759+00:00 0:00:00.981272 377591 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-12T03:00:05.085618+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-12T01:00:00+00:00 TriggerDagRunOperator 2023-05-12T02:10:23.705875+00:00 2023-05-12T02:10:24.213312+00:00 0:00:00.507437 377577 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-12T02:10:20.879886+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-12T01:00:00+00:00 TriggerDagRunOperator 2023-05-12T02:10:23.446058+00:00 2023-05-12T02:10:24.111996+00:00 0:00:00.665938 377576 airflow-worker-2.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-12T02:10:20.879858+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-12T01:00:00+00:00 EmrJobFlowSensor 2023-05-12T02:01:06.880318+00:00 2023-05-12T02:10:08.631928+00:00 0:09:01.751610 377569 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-12T02:01:04.590946+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-12T01:00:00+00:00 EmrCreateJobFlowOperator 2023-05-12T02:00:44.753436+00:00 2023-05-12T02:00:45.605141+00:00 0:00:00.851705 377567 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-12T02:00:42.470383+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-12T01:00:00+00:00 PythonOperator 2023-05-12T02:00:24.689038+00:00 2023-05-12T02:00:25.661087+00:00 0:00:00.972049 377565 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-12T02:00:22.454223+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-12T00:00:00+00:00 TriggerDagRunOperator 2023-05-12T01:11:27.647829+00:00 2023-05-12T01:11:28.077243+00:00 0:00:00.429414 377545 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-12T01:11:24.811580+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-12T00:00:00+00:00 TriggerDagRunOperator 2023-05-12T01:11:27.506651+00:00 2023-05-12T01:11:27.848848+00:00 0:00:00.342197 377544 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-12T01:11:24.811536+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-12T00:00:00+00:00 EmrJobFlowSensor 2023-05-12T01:01:07.041948+00:00 2023-05-12T01:11:08.997446+00:00 0:10:01.955498 377537 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-12T01:01:04.782373+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-12T00:00:00+00:00 EmrCreateJobFlowOperator 2023-05-12T01:00:44.891855+00:00 2023-05-12T01:00:45.815115+00:00 0:00:00.923260 377535 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-12T01:00:42.723882+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-12T00:00:00+00:00 PythonOperator 2023-05-12T01:00:24.897511+00:00 2023-05-12T01:00:25.941363+00:00 0:00:01.043852 377533 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-12T01:00:22.706546+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-11T23:00:00+00:00 TriggerDagRunOperator 2023-05-12T00:11:31.741783+00:00 2023-05-12T00:11:32.182304+00:00 0:00:00.440521 377519 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-12T00:11:28.682992+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-11T23:00:00+00:00 TriggerDagRunOperator 2023-05-12T00:11:31.686847+00:00 2023-05-12T00:11:32.027787+00:00 0:00:00.340940 377518 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-12T00:11:28.683041+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-11T23:00:00+00:00 EmrJobFlowSensor 2023-05-12T00:01:05.112503+00:00 2023-05-12T00:11:07.136538+00:00 0:10:02.024035 377510 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-12T00:01:02.682890+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-11T23:00:00+00:00 EmrCreateJobFlowOperator 2023-05-12T00:00:44.945751+00:00 2023-05-12T00:00:46.005910+00:00 0:00:01.060159 377509 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-12T00:00:42.611702+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-11T23:00:00+00:00 PythonOperator 2023-05-12T00:00:23.048822+00:00 2023-05-12T00:00:24.127049+00:00 0:00:01.078227 377507 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-12T00:00:20.553084+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-11T22:00:00+00:00 TriggerDagRunOperator 2023-05-11T23:11:05.004880+00:00 2023-05-11T23:11:05.456346+00:00 0:00:00.451466 377493 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-11T23:11:02.390760+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-11T22:00:00+00:00 TriggerDagRunOperator 2023-05-11T23:11:04.943847+00:00 2023-05-11T23:11:05.299346+00:00 0:00:00.355499 377492 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-11T23:11:02.390805+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-11T22:00:00+00:00 EmrJobFlowSensor 2023-05-11T23:00:51.856349+00:00 2023-05-11T23:10:53.658873+00:00 0:10:01.802524 377485 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-11T23:00:49.626950+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-11T22:00:00+00:00 EmrCreateJobFlowOperator 2023-05-11T23:00:30.209035+00:00 2023-05-11T23:00:31.034361+00:00 0:00:00.825326 377482 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-11T23:00:27.684643+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-11T22:00:00+00:00 PythonOperator 2023-05-11T23:00:09.641275+00:00 2023-05-11T23:00:10.684402+00:00 0:00:01.043127 377479 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-11T23:00:07.528321+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-11T21:00:00+00:00 TriggerDagRunOperator 2023-05-11T22:11:42.248900+00:00 2023-05-11T22:11:42.736642+00:00 0:00:00.487742 377464 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-11T22:11:39.372766+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-11T21:00:00+00:00 TriggerDagRunOperator 2023-05-11T22:11:42.143128+00:00 2023-05-11T22:11:42.499987+00:00 0:00:00.356859 377463 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-11T22:11:39.372709+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-11T21:00:00+00:00 EmrJobFlowSensor 2023-05-11T22:00:52.833183+00:00 2023-05-11T22:10:54.637710+00:00 0:10:01.804527 377455 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-11T22:00:50.510084+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-11T21:00:00+00:00 EmrCreateJobFlowOperator 2023-05-11T22:00:30.774628+00:00 2023-05-11T22:00:31.622603+00:00 0:00:00.847975 377453 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-11T22:00:28.413193+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-11T21:00:00+00:00 PythonOperator 2023-05-11T22:00:11.066156+00:00 2023-05-11T22:00:12.103529+00:00 0:00:01.037373 377451 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-11T22:00:08.402925+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-11T20:00:00+00:00 TriggerDagRunOperator 2023-05-11T21:12:15.948637+00:00 2023-05-11T21:12:16.394377+00:00 0:00:00.445740 377437 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-11T21:12:13.213684+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-11T20:00:00+00:00 TriggerDagRunOperator 2023-05-11T21:12:15.821426+00:00 2023-05-11T21:12:16.173378+00:00 0:00:00.351952 377436 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-11T21:12:13.213641+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-11T20:00:00+00:00 EmrJobFlowSensor 2023-05-11T21:00:50.294876+00:00 2023-05-11T21:11:52.134873+00:00 0:11:01.839997 377428 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-11T21:00:48.104543+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-11T20:00:00+00:00 EmrCreateJobFlowOperator 2023-05-11T21:00:28.922517+00:00 2023-05-11T21:00:29.952257+00:00 0:00:01.029740 377426 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-11T21:00:26.100935+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-11T20:00:00+00:00 PythonOperator 2023-05-11T21:00:08.321472+00:00 2023-05-11T21:00:09.416890+00:00 0:00:01.095418 377424 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-11T21:00:06.019111+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-11T19:00:00+00:00 TriggerDagRunOperator 2023-05-11T20:11:53.685118+00:00 2023-05-11T20:11:54.063349+00:00 0:00:00.378231 377409 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-11T20:11:51.252912+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-11T19:00:00+00:00 TriggerDagRunOperator 2023-05-11T20:11:53.663482+00:00 2023-05-11T20:11:54.133784+00:00 0:00:00.470302 377408 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-11T20:11:51.252882+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-11T19:00:00+00:00 EmrJobFlowSensor 2023-05-11T20:00:55.930199+00:00 2023-05-11T20:10:57.919358+00:00 0:10:01.989159 377401 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-11T20:00:53.617544+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-11T19:00:00+00:00 EmrCreateJobFlowOperator 2023-05-11T20:00:34.006420+00:00 2023-05-11T20:00:34.800644+00:00 0:00:00.794224 377399 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-11T20:00:31.606160+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-11T19:00:00+00:00 PythonOperator 2023-05-11T20:00:13.666349+00:00 2023-05-11T20:00:14.696867+00:00 0:00:01.030518 377397 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-11T20:00:11.529353+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-11T18:00:00+00:00 TriggerDagRunOperator 2023-05-11T19:12:12.882520+00:00 2023-05-11T19:12:13.353847+00:00 0:00:00.471327 377381 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-11T19:12:10.298499+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-11T18:00:00+00:00 TriggerDagRunOperator 2023-05-11T19:12:12.631100+00:00 2023-05-11T19:12:12.972694+00:00 0:00:00.341594 377380 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-11T19:12:10.298528+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-11T18:00:00+00:00 EmrJobFlowSensor 2023-05-11T19:01:01.600275+00:00 2023-05-11T19:12:03.802227+00:00 0:11:02.201952 377372 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-11T19:00:59.315868+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-11T18:00:00+00:00 EmrCreateJobFlowOperator 2023-05-11T19:00:39.663152+00:00 2023-05-11T19:00:40.632237+00:00 0:00:00.969085 377371 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-11T19:00:37.295397+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-11T18:00:00+00:00 PythonOperator 2023-05-11T19:00:19.849513+00:00 2023-05-11T19:00:20.955870+00:00 0:00:01.106357 377369 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-11T19:00:17.214037+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-11T17:00:00+00:00 TriggerDagRunOperator 2023-05-11T18:11:04.441053+00:00 2023-05-11T18:11:04.904629+00:00 0:00:00.463576 377353 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-11T18:11:01.994883+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-11T17:00:00+00:00 TriggerDagRunOperator 2023-05-11T18:11:04.344963+00:00 2023-05-11T18:11:04.692812+00:00 0:00:00.347849 377352 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-11T18:11:01.994933+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-11T17:00:00+00:00 EmrJobFlowSensor 2023-05-11T18:00:48.320787+00:00 2023-05-11T18:10:50.135196+00:00 0:10:01.814409 377345 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-11T18:00:46.217857+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-11T17:00:00+00:00 EmrCreateJobFlowOperator 2023-05-11T18:00:26.428048+00:00 2023-05-11T18:00:27.300107+00:00 0:00:00.872059 377344 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-11T18:00:24.211707+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-11T17:00:00+00:00 PythonOperator 2023-05-11T18:00:06.387294+00:00 2023-05-11T18:00:07.392821+00:00 0:00:01.005527 377342 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-11T18:00:04.131133+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-11T16:00:00+00:00 TriggerDagRunOperator 2023-05-11T17:15:54.578067+00:00 2023-05-11T17:15:55.049120+00:00 0:00:00.471053 377329 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-11T17:15:51.511791+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-11T16:00:00+00:00 TriggerDagRunOperator 2023-05-11T17:15:54.429097+00:00 2023-05-11T17:15:54.780831+00:00 0:00:00.351734 377328 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-11T17:15:51.511749+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-11T16:00:00+00:00 EmrJobFlowSensor 2023-05-11T17:05:32.813991+00:00 2023-05-11T17:15:34.596235+00:00 0:10:01.782244 377323 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-11T17:05:30.493689+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-11T16:00:00+00:00 EmrCreateJobFlowOperator 2023-05-11T17:05:12.045306+00:00 2023-05-11T17:05:12.968212+00:00 0:00:00.922906 377320 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-11T17:05:08.453447+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-11T16:00:00+00:00 PythonOperator 2023-05-11T17:04:48.607415+00:00 2023-05-11T17:04:49.653245+00:00 0:00:01.045830 377318 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-11T17:04:46.319672+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-11T15:00:00+00:00 TriggerDagRunOperator 2023-05-11T16:11:51.641059+00:00 2023-05-11T16:11:52.068111+00:00 0:00:00.427052 377303 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-11T16:11:48.691247+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-11T15:00:00+00:00 TriggerDagRunOperator 2023-05-11T16:11:51.578984+00:00 2023-05-11T16:11:51.928204+00:00 0:00:00.349220 377302 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-11T16:11:48.691189+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-11T15:00:00+00:00 EmrJobFlowSensor 2023-05-11T16:01:33.432337+00:00 2023-05-11T16:11:35.207743+00:00 0:10:01.775406 377296 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-11T16:01:31.229953+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-11T15:00:00+00:00 EmrCreateJobFlowOperator 2023-05-11T16:01:13.441340+00:00 2023-05-11T16:01:14.449300+00:00 0:00:01.007960 377294 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-11T16:01:11.209844+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-11T15:00:00+00:00 PythonOperator 2023-05-11T16:00:51.247257+00:00 2023-05-11T16:00:52.333733+00:00 0:00:01.086476 377292 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-11T16:00:49.131434+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-11T14:00:00+00:00 TriggerDagRunOperator 2023-05-11T15:24:50.574137+00:00 2023-05-11T15:24:51.136829+00:00 0:00:00.562692 377281 airflow-worker-4.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-11T15:24:47.928570+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-11T14:00:00+00:00 TriggerDagRunOperator 2023-05-11T15:24:50.410121+00:00 2023-05-11T15:24:50.868482+00:00 0:00:00.458361 377280 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-11T15:24:47.928533+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-11T14:00:00+00:00 EmrJobFlowSensor 2023-05-11T15:14:38.133691+00:00 2023-05-11T15:24:39.932132+00:00 0:10:01.798441 377275 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-11T15:14:35.961212+00:00 2 default_pool