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 check_cluster_status 2023-03-13T03:00:00+00:00 EmrJobFlowSensor 2023-03-13T04:01:07.567842+00:00 2023-03-13T04:11:09.337908+00:00 0:10:01.770066 352736 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-13T04:01:05.190249+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-13T03:00:00+00:00 EmrCreateJobFlowOperator 2023-03-13T04:00:43.970562+00:00 2023-03-13T04:00:44.941302+00:00 0:00:00.970740 352735 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-13T04:00:41.214544+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-13T03:00:00+00:00 PythonOperator 2023-03-13T04:00:22.087765+00:00 2023-03-13T04:00:25.487386+00:00 0:00:03.399621 352732 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-13T04:00:19.103457+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-13T02:00:00+00:00 TriggerDagRunOperator 2023-03-13T03:19:40.104628+00:00 2023-03-13T03:19:40.562421+00:00 0:00:00.457793 352723 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-13T03:19:37.133803+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-13T02:00:00+00:00 TriggerDagRunOperator 2023-03-13T03:19:39.840400+00:00 2023-03-13T03:19:40.299600+00:00 0:00:00.459200 352722 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-13T03:19:37.133844+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-13T02:00:00+00:00 EmrJobFlowSensor 2023-03-13T03:09:12.110136+00:00 2023-03-13T03:19:13.976195+00:00 0:10:01.866059 352719 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-13T03:09:09.746286+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-13T02:00:00+00:00 EmrCreateJobFlowOperator 2023-03-13T03:08:50.082736+00:00 2023-03-13T03:08:51.009170+00:00 0:00:00.926434 352715 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-13T03:08:47.718032+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-13T02:00:00+00:00 PythonOperator 2023-03-13T03:00:16.288194+00:00 2023-03-13T03:00:19.436007+00:00 0:00:03.147813 352711 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-13T03:00:13.729375+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-13T01:00:00+00:00 TriggerDagRunOperator 2023-03-13T02:12:43.012470+00:00 2023-03-13T02:12:43.494711+00:00 0:00:00.482241 352700 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-13T02:12:40.625811+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-13T01:00:00+00:00 TriggerDagRunOperator 2023-03-13T02:12:43.001963+00:00 2023-03-13T02:12:43.525844+00:00 0:00:00.523881 352699 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-13T02:12:40.625782+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-13T01:00:00+00:00 EmrJobFlowSensor 2023-03-13T02:02:35.856666+00:00 2023-03-13T02:12:37.695108+00:00 0:10:01.838442 352692 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-13T02:02:33.470400+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-13T01:00:00+00:00 EmrCreateJobFlowOperator 2023-03-13T02:02:16.224381+00:00 2023-03-13T02:02:17.094028+00:00 0:00:00.869647 352690 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-13T02:02:13.454852+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-13T01:00:00+00:00 PythonOperator 2023-03-13T02:00:14.821008+00:00 2023-03-13T02:00:20.256933+00:00 0:00:05.435925 352687 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-13T02:00:12.008751+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-13T00:00:00+00:00 TriggerDagRunOperator 2023-03-13T01:12:16.186552+00:00 2023-03-13T01:12:16.797811+00:00 0:00:00.611259 352671 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-13T01:12:13.690998+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-13T00:00:00+00:00 TriggerDagRunOperator 2023-03-13T01:12:16.082070+00:00 2023-03-13T01:12:16.751333+00:00 0:00:00.669263 352670 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-13T01:12:13.691028+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-13T00:00:00+00:00 EmrJobFlowSensor 2023-03-13T01:01:51.601273+00:00 2023-03-13T01:11:53.438391+00:00 0:10:01.837118 352664 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-13T01:01:49.144663+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-13T00:00:00+00:00 EmrCreateJobFlowOperator 2023-03-13T01:01:33.831083+00:00 2023-03-13T01:01:35.109916+00:00 0:00:01.278833 352662 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-13T01:01:29.136562+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-13T00:00:00+00:00 PythonOperator 2023-03-13T01:00:22.527173+00:00 2023-03-13T01:00:26.036161+00:00 0:00:03.508988 352659 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-13T01:00:19.499163+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-12T23:00:00+00:00 TriggerDagRunOperator 2023-03-13T00:12:25.789261+00:00 2023-03-13T00:12:26.462159+00:00 0:00:00.672898 352648 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-13T00:12:23.242474+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-12T23:00:00+00:00 TriggerDagRunOperator 2023-03-13T00:12:25.607949+00:00 2023-03-13T00:12:26.336366+00:00 0:00:00.728417 352647 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-13T00:12:23.242503+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-12T23:00:00+00:00 EmrJobFlowSensor 2023-03-13T00:02:12.742280+00:00 2023-03-13T00:12:14.631297+00:00 0:10:01.889017 352640 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-13T00:02:10.539824+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-12T23:00:00+00:00 EmrCreateJobFlowOperator 2023-03-13T00:01:50.838606+00:00 2023-03-13T00:01:51.740759+00:00 0:00:00.902153 352638 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-13T00:01:48.513885+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-12T23:00:00+00:00 PythonOperator 2023-03-13T00:01:31.238534+00:00 2023-03-13T00:01:35.387611+00:00 0:00:04.149077 352636 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-13T00:01:28.545416+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-12T22:00:00+00:00 TriggerDagRunOperator 2023-03-12T23:11:24.561895+00:00 2023-03-12T23:11:25.132238+00:00 0:00:00.570343 352624 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-12T23:11:22.012397+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-12T22:00:00+00:00 TriggerDagRunOperator 2023-03-12T23:11:24.405430+00:00 2023-03-12T23:11:24.861746+00:00 0:00:00.456316 352623 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-12T23:11:22.012369+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-12T22:00:00+00:00 EmrJobFlowSensor 2023-03-12T23:01:18.721896+00:00 2023-03-12T23:11:20.404162+00:00 0:10:01.682266 352615 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-12T23:01:16.406673+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-12T22:00:00+00:00 EmrCreateJobFlowOperator 2023-03-12T23:00:56.781304+00:00 2023-03-12T23:00:58.075550+00:00 0:00:01.294246 352612 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-12T23:00:54.357276+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-12T22:00:00+00:00 PythonOperator 2023-03-12T23:00:37.636547+00:00 2023-03-12T23:00:43.305171+00:00 0:00:05.668624 352610 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-12T23:00:34.236018+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-12T21:00:00+00:00 TriggerDagRunOperator 2023-03-12T22:11:35.143669+00:00 2023-03-12T22:11:35.622483+00:00 0:00:00.478814 352598 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-12T22:11:32.447461+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-12T21:00:00+00:00 TriggerDagRunOperator 2023-03-12T22:11:34.899436+00:00 2023-03-12T22:11:35.372308+00:00 0:00:00.472872 352597 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-12T22:11:32.447433+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-12T21:00:00+00:00 EmrJobFlowSensor 2023-03-12T22:01:16.786534+00:00 2023-03-12T22:11:18.587152+00:00 0:10:01.800618 352590 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-12T22:01:14.491423+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-12T21:00:00+00:00 EmrCreateJobFlowOperator 2023-03-12T22:00:57.001589+00:00 2023-03-12T22:00:57.865110+00:00 0:00:00.863521 352588 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-12T22:00:54.461116+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-12T21:00:00+00:00 PythonOperator 2023-03-12T22:00:35.065897+00:00 2023-03-12T22:00:39.101167+00:00 0:00:04.035270 352586 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-12T22:00:32.435744+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-12T20:00:00+00:00 TriggerDagRunOperator 2023-03-12T21:11:28.545847+00:00 2023-03-12T21:11:29.020532+00:00 0:00:00.474685 352575 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-12T21:11:25.722821+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-12T20:00:00+00:00 TriggerDagRunOperator 2023-03-12T21:11:28.324882+00:00 2023-03-12T21:11:28.783778+00:00 0:00:00.458896 352574 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-12T21:11:25.722864+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-12T20:00:00+00:00 EmrJobFlowSensor 2023-03-12T21:01:12.375731+00:00 2023-03-12T21:11:14.144813+00:00 0:10:01.769082 352568 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-12T21:01:09.868909+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-12T20:00:00+00:00 EmrCreateJobFlowOperator 2023-03-12T21:00:54.099817+00:00 2023-03-12T21:00:55.327494+00:00 0:00:01.227677 352566 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-12T21:00:49.850695+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-12T20:00:00+00:00 PythonOperator 2023-03-12T21:00:30.171091+00:00 2023-03-12T21:00:34.311830+00:00 0:00:04.140739 352564 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-12T21:00:27.833009+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-12T19:00:00+00:00 TriggerDagRunOperator 2023-03-12T20:11:13.803890+00:00 2023-03-12T20:11:14.316084+00:00 0:00:00.512194 352552 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-12T20:11:11.352272+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-12T19:00:00+00:00 TriggerDagRunOperator 2023-03-12T20:11:13.630502+00:00 2023-03-12T20:11:14.085279+00:00 0:00:00.454777 352551 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-12T20:11:11.352237+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-12T19:00:00+00:00 EmrJobFlowSensor 2023-03-12T20:00:57.502274+00:00 2023-03-12T20:10:59.309327+00:00 0:10:01.807053 352544 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-12T20:00:55.261761+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-12T19:00:00+00:00 EmrCreateJobFlowOperator 2023-03-12T20:00:37.349717+00:00 2023-03-12T20:00:38.153868+00:00 0:00:00.804151 352542 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-12T20:00:35.125363+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-12T19:00:00+00:00 PythonOperator 2023-03-12T20:00:15.955445+00:00 2023-03-12T20:00:19.350497+00:00 0:00:03.395052 352540 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-12T20:00:13.105827+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-12T18:00:00+00:00 TriggerDagRunOperator 2023-03-12T19:11:08.586844+00:00 2023-03-12T19:11:09.226834+00:00 0:00:00.639990 352530 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-12T19:11:05.890982+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-12T18:00:00+00:00 TriggerDagRunOperator 2023-03-12T19:11:08.542952+00:00 2023-03-12T19:11:09.137025+00:00 0:00:00.594073 352529 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-12T19:11:05.890915+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-12T18:00:00+00:00 EmrJobFlowSensor 2023-03-12T19:00:57.471403+00:00 2023-03-12T19:10:59.201955+00:00 0:10:01.730552 352521 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-12T19:00:55.108296+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-12T18:00:00+00:00 EmrCreateJobFlowOperator 2023-03-12T19:00:35.597362+00:00 2023-03-12T19:00:36.492782+00:00 0:00:00.895420 352519 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-12T19:00:33.081082+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-12T18:00:00+00:00 PythonOperator 2023-03-12T19:00:13.942109+00:00 2023-03-12T19:00:18.210706+00:00 0:00:04.268597 352517 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-12T19:00:11.105596+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-12T17:00:00+00:00 TriggerDagRunOperator 2023-03-12T18:11:06.534429+00:00 2023-03-12T18:11:06.998467+00:00 0:00:00.464038 352507 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-12T18:11:03.552259+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-12T17:00:00+00:00 TriggerDagRunOperator 2023-03-12T18:11:05.953260+00:00 2023-03-12T18:11:06.456051+00:00 0:00:00.502791 352506 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-12T18:11:03.552216+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-12T17:00:00+00:00 EmrJobFlowSensor 2023-03-12T18:00:59.159080+00:00 2023-03-12T18:11:01.030690+00:00 0:10:01.871610 352496 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-12T18:00:56.958036+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-12T17:00:00+00:00 EmrCreateJobFlowOperator 2023-03-12T18:00:37.132772+00:00 2023-03-12T18:00:38.019375+00:00 0:00:00.886603 352495 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-12T18:00:34.933195+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-12T17:00:00+00:00 PythonOperator 2023-03-12T18:00:15.279841+00:00 2023-03-12T18:00:19.180635+00:00 0:00:03.900794 352493 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-12T18:00:12.913317+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-12T16:00:00+00:00 TriggerDagRunOperator 2023-03-12T17:14:38.671169+00:00 2023-03-12T17:14:39.150065+00:00 0:00:00.478896 352483 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-12T17:14:35.690766+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-12T16:00:00+00:00 TriggerDagRunOperator 2023-03-12T17:14:38.424097+00:00 2023-03-12T17:14:38.876159+00:00 0:00:00.452062 352482 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-12T17:14:35.690832+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-12T16:00:00+00:00 EmrJobFlowSensor 2023-03-12T17:04:21.054832+00:00 2023-03-12T17:14:22.739285+00:00 0:10:01.684453 352476 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-12T17:04:18.779600+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-12T16:00:00+00:00 EmrCreateJobFlowOperator 2023-03-12T17:03:59.118541+00:00 2023-03-12T17:04:00.107006+00:00 0:00:00.988465 352473 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-12T17:03:56.760695+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-12T16:00:00+00:00 PythonOperator 2023-03-12T17:03:37.159774+00:00 2023-03-12T17:03:41.099586+00:00 0:00:03.939812 352472 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-12T17:03:34.738114+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-12T15:00:00+00:00 TriggerDagRunOperator 2023-03-12T16:13:23.310122+00:00 2023-03-12T16:13:23.812807+00:00 0:00:00.502685 352463 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-12T16:13:20.726143+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-12T15:00:00+00:00 TriggerDagRunOperator 2023-03-12T16:13:23.191647+00:00 2023-03-12T16:13:23.666995+00:00 0:00:00.475348 352462 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-12T16:13:20.726114+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-12T15:00:00+00:00 EmrJobFlowSensor 2023-03-12T16:03:13.374256+00:00 2023-03-12T16:13:15.178336+00:00 0:10:01.804080 352455 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-12T16:03:11.128989+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-12T15:00:00+00:00 EmrCreateJobFlowOperator 2023-03-12T16:02:53.476684+00:00 2023-03-12T16:02:54.341844+00:00 0:00:00.865160 352453 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-12T16:02:51.064257+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-12T15:00:00+00:00 PythonOperator 2023-03-12T16:02:31.570400+00:00 2023-03-12T16:02:36.021167+00:00 0:00:04.450767 352451 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-12T16:02:29.098025+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-12T14:00:00+00:00 TriggerDagRunOperator 2023-03-12T15:16:09.399195+00:00 2023-03-12T15:16:09.921737+00:00 0:00:00.522542 352444 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-12T15:16:06.486941+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-12T14:00:00+00:00 TriggerDagRunOperator 2023-03-12T15:16:09.320101+00:00 2023-03-12T15:16:09.809439+00:00 0:00:00.489338 352443 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-12T15:16:06.486907+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-12T14:00:00+00:00 EmrJobFlowSensor 2023-03-12T15:00:58.156081+00:00 2023-03-12T15:10:59.950666+00:00 0:10:01.794585 352436 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-12T15:00:55.889713+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-12T14:00:00+00:00 EmrCreateJobFlowOperator 2023-03-12T15:00:38.715818+00:00 2023-03-12T15:00:39.711682+00:00 0:00:00.995864 352434 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-12T15:00:33.887610+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-12T14:00:00+00:00 PythonOperator 2023-03-12T15:00:14.056243+00:00 2023-03-12T15:00:18.188028+00:00 0:00:04.131785 352432 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-12T15:00:11.837087+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-12T13:00:00+00:00 TriggerDagRunOperator 2023-03-12T14:11:59.207019+00:00 2023-03-12T14:11:59.691908+00:00 0:00:00.484889 352423 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-12T14:11:56.708016+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-12T13:00:00+00:00 TriggerDagRunOperator 2023-03-12T14:11:59.114666+00:00 2023-03-12T14:11:59.586221+00:00 0:00:00.471555 352422 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-12T14:11:56.707987+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-12T13:00:00+00:00 EmrJobFlowSensor 2023-03-12T14:01:47.129409+00:00 2023-03-12T14:11:48.889030+00:00 0:10:01.759621 352415 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-12T14:01:44.842946+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-12T13:00:00+00:00 EmrCreateJobFlowOperator 2023-03-12T14:01:27.061940+00:00 2023-03-12T14:01:27.924628+00:00 0:00:00.862688 352413 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-12T14:01:24.821536+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-12T13:00:00+00:00 PythonOperator 2023-03-12T14:01:05.721128+00:00 2023-03-12T14:01:09.024528+00:00 0:00:03.303400 352411 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-12T14:01:02.808953+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-12T12:00:00+00:00 TriggerDagRunOperator 2023-03-12T13:11:11.794280+00:00 2023-03-12T13:11:12.286296+00:00 0:00:00.492016 352401 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-12T13:11:09.501954+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-12T12:00:00+00:00 TriggerDagRunOperator 2023-03-12T13:11:11.798221+00:00 2023-03-12T13:11:12.286373+00:00 0:00:00.488152 352400 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-12T13:11:09.501983+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-12T12:00:00+00:00 EmrJobFlowSensor 2023-03-12T13:01:02.781372+00:00 2023-03-12T13:11:04.687849+00:00 0:10:01.906477 352394 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-12T13:00:59.396056+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-12T12:00:00+00:00 EmrCreateJobFlowOperator 2023-03-12T13:00:41.835404+00:00 2023-03-12T13:00:43.342171+00:00 0:00:01.506767 352392 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-12T13:00:37.297000+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-12T12:00:00+00:00 PythonOperator 2023-03-12T13:00:17.631419+00:00 2023-03-12T13:00:20.708767+00:00 0:00:03.077348 352390 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-12T13:00:15.201574+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-12T11:00:00+00:00 TriggerDagRunOperator 2023-03-12T12:11:16.914872+00:00 2023-03-12T12:11:17.417763+00:00 0:00:00.502891 352382 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-12T12:11:13.924701+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-12T11:00:00+00:00 TriggerDagRunOperator 2023-03-12T12:11:16.850995+00:00 2023-03-12T12:11:17.323434+00:00 0:00:00.472439 352381 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-12T12:11:13.924743+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-12T11:00:00+00:00 EmrJobFlowSensor 2023-03-12T12:01:05.277341+00:00 2023-03-12T12:11:07.163957+00:00 0:10:01.886616 352375 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-12T12:01:03.058479+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-12T11:00:00+00:00 EmrCreateJobFlowOperator 2023-03-12T12:00:43.533258+00:00 2023-03-12T12:00:44.570151+00:00 0:00:01.036893 352373 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-12T12:00:41.052994+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-12T11:00:00+00:00 PythonOperator 2023-03-12T12:00:23.318083+00:00 2023-03-12T12:00:27.285286+00:00 0:00:03.967203 352371 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-12T12:00:20.973648+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-12T10:00:00+00:00 TriggerDagRunOperator 2023-03-12T11:11:22.829207+00:00 2023-03-12T11:11:23.310891+00:00 0:00:00.481684 352362 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-12T11:11:20.568911+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-12T10:00:00+00:00 TriggerDagRunOperator 2023-03-12T11:11:22.750655+00:00 2023-03-12T11:11:23.195688+00:00 0:00:00.445033 352361 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-12T11:11:20.568941+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-12T10:00:00+00:00 EmrJobFlowSensor 2023-03-12T11:01:09.113926+00:00 2023-03-12T11:11:11.010181+00:00 0:10:01.896255 352355 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-12T11:01:06.163462+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-12T10:00:00+00:00 EmrCreateJobFlowOperator 2023-03-12T11:00:46.581398+00:00 2023-03-12T11:00:47.450020+00:00 0:00:00.868622 352353 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-12T11:00:44.178802+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-12T10:00:00+00:00 PythonOperator 2023-03-12T11:00:24.827092+00:00 2023-03-12T11:00:28.082575+00:00 0:00:03.255483 352351 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-12T11:00:22.096298+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-12T09:00:00+00:00 TriggerDagRunOperator 2023-03-12T10:18:31.799110+00:00 2023-03-12T10:18:32.273002+00:00 0:00:00.473892 352341 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-12T10:18:28.787706+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-12T09:00:00+00:00 TriggerDagRunOperator 2023-03-12T10:18:31.570019+00:00 2023-03-12T10:18:32.053666+00:00 0:00:00.483647 352340 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-12T10:18:28.787661+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-12T09:00:00+00:00 EmrJobFlowSensor 2023-03-12T10:08:23.579573+00:00 2023-03-12T10:18:25.410407+00:00 0:10:01.830834 352335 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-12T10:08:21.003118+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-12T09:00:00+00:00 EmrCreateJobFlowOperator 2023-03-12T10:08:02.495954+00:00 2023-03-12T10:08:03.719794+00:00 0:00:01.223840 352333 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-12T10:07:58.969906+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-12T09:00:00+00:00 PythonOperator 2023-03-12T10:00:19.380394+00:00 2023-03-12T10:00:22.518029+00:00 0:00:03.137635 352328 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-12T10:00:16.963648+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-12T08:00:00+00:00 TriggerDagRunOperator 2023-03-12T09:23:06.719428+00:00 2023-03-12T09:23:07.210608+00:00 0:00:00.491180 352321 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-12T09:23:04.189622+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-12T08:00:00+00:00 TriggerDagRunOperator 2023-03-12T09:23:06.736348+00:00 2023-03-12T09:23:07.238747+00:00 0:00:00.502399 352320 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-12T09:23:04.189650+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-12T08:00:00+00:00 EmrJobFlowSensor 2023-03-12T09:12:59.826785+00:00 2023-03-12T09:23:01.689067+00:00 0:10:01.862282 352315 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-12T09:12:56.200797+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-12T08:00:00+00:00 EmrCreateJobFlowOperator 2023-03-12T09:12:36.339722+00:00 2023-03-12T09:12:37.211821+00:00 0:00:00.872099 352312 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-12T09:12:34.141960+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-12T08:00:00+00:00 PythonOperator 2023-03-12T09:12:17.125391+00:00 2023-03-12T09:12:20.492950+00:00 0:00:03.367559 352309 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-12T09:12:14.129216+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-12T07:00:00+00:00 TriggerDagRunOperator 2023-03-12T08:17:11.986034+00:00 2023-03-12T08:17:12.453354+00:00 0:00:00.467320 352299 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-12T08:17:09.167913+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-12T07:00:00+00:00 TriggerDagRunOperator 2023-03-12T08:17:11.800467+00:00 2023-03-12T08:17:12.288686+00:00 0:00:00.488219 352298 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-12T08:17:09.167883+00:00 2 default_pool