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_emr_steps 2021-04-27T05:00:00+00:00 PythonOperator 2021-04-27T06:00:06.794681+00:00 2021-04-27T06:00:09.766825+00:00 0:00:02.972144 21727 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-27T06:00:04.526572+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-27T04:00:00+00:00 TriggerDagRunOperator 2021-04-27T05:11:25.717794+00:00 2021-04-27T05:11:26.234077+00:00 0:00:00.516283 21719 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T05:11:23.291681+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-27T04:00:00+00:00 TriggerDagRunOperator 2021-04-27T05:11:25.483883+00:00 2021-04-27T05:11:25.892490+00:00 0:00:00.408607 21718 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T05:11:23.291728+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-27T04:00:00+00:00 EmrJobFlowSensor 2021-04-27T05:01:04.188164+00:00 2021-04-27T05:11:07.291345+00:00 0:10:03.103181 21714 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T05:01:01.762293+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-27T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T05:00:42.106610+00:00 2021-04-27T05:00:44.085587+00:00 0:00:01.978977 21713 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-27T05:00:39.643703+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-27T04:00:00+00:00 PythonOperator 2021-04-27T05:00:21.839425+00:00 2021-04-27T05:00:24.828681+00:00 0:00:02.989256 21712 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-27T05:00:19.518572+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-27T03:00:00+00:00 TriggerDagRunOperator 2021-04-27T04:10:05.527268+00:00 2021-04-27T04:10:05.957998+00:00 0:00:00.430730 21704 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T04:10:03.012459+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-27T03:00:00+00:00 TriggerDagRunOperator 2021-04-27T04:10:05.373148+00:00 2021-04-27T04:10:05.920770+00:00 0:00:00.547622 21703 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T04:10:03.012495+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-27T03:00:00+00:00 EmrJobFlowSensor 2021-04-27T04:00:56.100484+00:00 2021-04-27T04:09:58.700904+00:00 0:09:02.600420 21699 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T04:00:53.890504+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-27T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T04:00:34.175292+00:00 2021-04-27T04:00:35.886119+00:00 0:00:01.710827 21698 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-27T04:00:31.831335+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-27T03:00:00+00:00 PythonOperator 2021-04-27T04:00:12.112067+00:00 2021-04-27T04:00:15.208796+00:00 0:00:03.096729 21697 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-27T04:00:09.798279+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-27T02:00:00+00:00 TriggerDagRunOperator 2021-04-27T03:11:01.332011+00:00 2021-04-27T03:11:01.792449+00:00 0:00:00.460438 21689 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T03:10:58.984332+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-27T02:00:00+00:00 TriggerDagRunOperator 2021-04-27T03:11:01.238229+00:00 2021-04-27T03:11:01.809099+00:00 0:00:00.570870 21688 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T03:10:58.984359+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-27T02:00:00+00:00 EmrJobFlowSensor 2021-04-27T03:00:51.641190+00:00 2021-04-27T03:10:54.433745+00:00 0:10:02.792555 21684 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T03:00:49.499235+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-27T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T03:00:29.798025+00:00 2021-04-27T03:00:31.503120+00:00 0:00:01.705095 21683 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-27T03:00:27.467775+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-27T02:00:00+00:00 PythonOperator 2021-04-27T03:00:10.037850+00:00 2021-04-27T03:00:13.065154+00:00 0:00:03.027304 21682 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-27T03:00:07.415898+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-27T01:00:00+00:00 TriggerDagRunOperator 2021-04-27T02:10:12.313710+00:00 2021-04-27T02:10:12.915033+00:00 0:00:00.601323 21674 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T02:10:10.052063+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-27T01:00:00+00:00 TriggerDagRunOperator 2021-04-27T02:10:12.293089+00:00 2021-04-27T02:10:12.780063+00:00 0:00:00.486974 21673 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T02:10:10.052104+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-27T01:00:00+00:00 EmrJobFlowSensor 2021-04-27T02:00:54.743076+00:00 2021-04-27T02:09:57.427686+00:00 0:09:02.684610 21669 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T02:00:52.521890+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-27T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T02:00:34.715369+00:00 2021-04-27T02:00:36.463704+00:00 0:00:01.748335 21668 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-27T02:00:32.509162+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-27T01:00:00+00:00 PythonOperator 2021-04-27T02:00:11.282088+00:00 2021-04-27T02:00:14.302253+00:00 0:00:03.020165 21667 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-27T02:00:08.558806+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-27T00:00:00+00:00 TriggerDagRunOperator 2021-04-27T01:09:45.683030+00:00 2021-04-27T01:09:46.235070+00:00 0:00:00.552040 21659 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T01:09:43.299301+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-27T00:00:00+00:00 TriggerDagRunOperator 2021-04-27T01:09:45.657441+00:00 2021-04-27T01:09:46.165673+00:00 0:00:00.508232 21658 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T01:09:43.299333+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-27T00:00:00+00:00 EmrJobFlowSensor 2021-04-27T01:01:18.489150+00:00 2021-04-27T01:09:21.105637+00:00 0:08:02.616487 21654 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T01:01:16.244620+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-27T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T01:00:58.671863+00:00 2021-04-27T01:01:00.525658+00:00 0:00:01.853795 21653 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-27T01:00:56.211000+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-27T00:00:00+00:00 PythonOperator 2021-04-27T01:00:36.573206+00:00 2021-04-27T01:00:39.653564+00:00 0:00:03.080358 21652 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-27T01:00:34.190729+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-26T23:00:00+00:00 TriggerDagRunOperator 2021-04-27T00:09:23.654259+00:00 2021-04-27T00:09:24.170660+00:00 0:00:00.516401 21644 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T00:09:21.293384+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-26T23:00:00+00:00 TriggerDagRunOperator 2021-04-27T00:09:23.498922+00:00 2021-04-27T00:09:23.916646+00:00 0:00:00.417724 21643 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T00:09:21.293420+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-26T23:00:00+00:00 EmrJobFlowSensor 2021-04-27T00:00:58.561781+00:00 2021-04-27T00:09:01.091139+00:00 0:08:02.529358 21639 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T00:00:56.316726+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-26T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T00:00:36.845349+00:00 2021-04-27T00:00:38.528301+00:00 0:00:01.682952 21638 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-27T00:00:34.354933+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-26T23:00:00+00:00 PythonOperator 2021-04-27T00:00:16.500452+00:00 2021-04-27T00:00:19.630402+00:00 0:00:03.129950 21637 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-27T00:00:14.200335+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-26T22:00:00+00:00 TriggerDagRunOperator 2021-04-26T23:10:11.963076+00:00 2021-04-26T23:10:12.480632+00:00 0:00:00.517556 21629 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T23:10:09.044608+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-26T22:00:00+00:00 TriggerDagRunOperator 2021-04-26T23:10:11.393981+00:00 2021-04-26T23:10:11.847088+00:00 0:00:00.453107 21628 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T23:10:09.044562+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-26T22:00:00+00:00 EmrJobFlowSensor 2021-04-26T23:00:56.306012+00:00 2021-04-26T23:09:59.086085+00:00 0:09:02.780073 21623 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T23:00:54.101085+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-26T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-26T23:00:34.618348+00:00 2021-04-26T23:00:36.502438+00:00 0:00:01.884090 21621 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-26T23:00:32.157728+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-26T22:00:00+00:00 PythonOperator 2021-04-26T23:00:12.751008+00:00 2021-04-26T23:00:15.771198+00:00 0:00:03.020190 21619 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-26T23:00:10.064110+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-26T21:00:00+00:00 TriggerDagRunOperator 2021-04-26T22:11:17.732050+00:00 2021-04-26T22:11:18.138559+00:00 0:00:00.406509 21611 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T22:11:15.010332+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-26T21:00:00+00:00 TriggerDagRunOperator 2021-04-26T22:11:17.284802+00:00 2021-04-26T22:11:17.840917+00:00 0:00:00.556115 21610 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T22:11:15.010364+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-26T21:00:00+00:00 EmrJobFlowSensor 2021-04-26T22:01:06.315305+00:00 2021-04-26T22:11:09.290245+00:00 0:10:02.974940 21606 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T22:01:04.055152+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-26T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-26T22:00:46.322245+00:00 2021-04-26T22:00:48.149918+00:00 0:00:01.827673 21605 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-26T22:00:43.991006+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-26T21:00:00+00:00 PythonOperator 2021-04-26T22:00:24.195375+00:00 2021-04-26T22:00:27.196959+00:00 0:00:03.001584 21604 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-26T22:00:21.915304+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-26T20:00:00+00:00 TriggerDagRunOperator 2021-04-26T21:09:05.963924+00:00 2021-04-26T21:09:06.345680+00:00 0:00:00.381756 21596 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T21:09:02.752990+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-26T20:00:00+00:00 TriggerDagRunOperator 2021-04-26T21:09:05.395274+00:00 2021-04-26T21:09:05.931344+00:00 0:00:00.536070 21595 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T21:09:02.753021+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-26T20:00:00+00:00 EmrJobFlowSensor 2021-04-26T21:00:54.585945+00:00 2021-04-26T21:08:57.196180+00:00 0:08:02.610235 21591 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T21:00:52.102305+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-26T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-26T21:00:32.687592+00:00 2021-04-26T21:00:34.358621+00:00 0:00:01.671029 21590 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-26T21:00:30.154507+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-26T20:00:00+00:00 PythonOperator 2021-04-26T21:00:12.280081+00:00 2021-04-26T21:00:15.302333+00:00 0:00:03.022252 21589 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-26T21:00:10.024229+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-26T19:00:00+00:00 TriggerDagRunOperator 2021-04-26T20:10:10.829368+00:00 2021-04-26T20:10:11.398015+00:00 0:00:00.568647 21581 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T20:10:08.540051+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-26T19:00:00+00:00 TriggerDagRunOperator 2021-04-26T20:10:10.805811+00:00 2021-04-26T20:10:11.252821+00:00 0:00:00.447010 21580 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T20:10:08.540014+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-26T19:00:00+00:00 EmrJobFlowSensor 2021-04-26T20:00:50.037554+00:00 2021-04-26T20:09:52.797523+00:00 0:09:02.759969 21576 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T20:00:47.571977+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-26T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-26T20:00:27.870512+00:00 2021-04-26T20:00:29.538083+00:00 0:00:01.667571 21575 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-26T20:00:25.552615+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-26T19:00:00+00:00 PythonOperator 2021-04-26T20:00:07.866491+00:00 2021-04-26T20:00:10.891108+00:00 0:00:03.024617 21574 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-26T20:00:05.445062+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-26T18:00:00+00:00 TriggerDagRunOperator 2021-04-26T19:09:12.549587+00:00 2021-04-26T19:09:12.993182+00:00 0:00:00.443595 21566 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T19:09:09.851180+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-26T18:00:00+00:00 TriggerDagRunOperator 2021-04-26T19:09:12.197379+00:00 2021-04-26T19:09:12.809352+00:00 0:00:00.611973 21565 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T19:09:09.851211+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-26T18:00:00+00:00 EmrJobFlowSensor 2021-04-26T19:01:01.310910+00:00 2021-04-26T19:09:03.877255+00:00 0:08:02.566345 21561 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T19:00:59.140263+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-26T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-26T19:00:35.477523+00:00 2021-04-26T19:00:37.127865+00:00 0:00:01.650342 21560 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-26T19:00:33.118210+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-26T18:00:00+00:00 PythonOperator 2021-04-26T19:00:13.879185+00:00 2021-04-26T19:00:16.896449+00:00 0:00:03.017264 21559 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-26T19:00:11.162455+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-26T17:00:00+00:00 TriggerDagRunOperator 2021-04-26T18:11:21.306387+00:00 2021-04-26T18:11:21.878797+00:00 0:00:00.572410 21551 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T18:11:19.019893+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-26T17:00:00+00:00 TriggerDagRunOperator 2021-04-26T18:11:21.203189+00:00 2021-04-26T18:11:21.642946+00:00 0:00:00.439757 21550 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T18:11:19.019921+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-26T17:00:00+00:00 EmrJobFlowSensor 2021-04-26T18:00:56.200139+00:00 2021-04-26T18:10:58.932592+00:00 0:10:02.732453 21546 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T18:00:53.965997+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-26T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-26T18:00:36.209222+00:00 2021-04-26T18:00:37.872749+00:00 0:00:01.663527 21545 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-26T18:00:33.953326+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-26T17:00:00+00:00 PythonOperator 2021-04-26T18:00:14.311151+00:00 2021-04-26T18:00:17.393650+00:00 0:00:03.082499 21544 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-26T18:00:11.849162+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-26T16:00:00+00:00 TriggerDagRunOperator 2021-04-26T17:11:19.979802+00:00 2021-04-26T17:11:20.524677+00:00 0:00:00.544875 21536 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T17:11:17.366469+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-26T16:00:00+00:00 TriggerDagRunOperator 2021-04-26T17:11:19.939809+00:00 2021-04-26T17:11:20.370296+00:00 0:00:00.430487 21535 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T17:11:17.366434+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-26T16:00:00+00:00 EmrJobFlowSensor 2021-04-26T17:01:00.509989+00:00 2021-04-26T17:11:03.422234+00:00 0:10:02.912245 21531 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T17:00:58.285378+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-26T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-26T17:00:38.683682+00:00 2021-04-26T17:00:40.385483+00:00 0:00:01.701801 21530 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-26T17:00:36.285986+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-26T16:00:00+00:00 PythonOperator 2021-04-26T17:00:18.620323+00:00 2021-04-26T17:00:21.683630+00:00 0:00:03.063307 21529 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-26T17:00:16.244512+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-26T15:00:00+00:00 TriggerDagRunOperator 2021-04-26T16:10:20.831431+00:00 2021-04-26T16:10:21.346212+00:00 0:00:00.514781 21521 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T16:10:18.440902+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-26T15:00:00+00:00 TriggerDagRunOperator 2021-04-26T16:10:20.706410+00:00 2021-04-26T16:10:21.135501+00:00 0:00:00.429091 21520 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T16:10:18.440856+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-26T15:00:00+00:00 EmrJobFlowSensor 2021-04-26T16:01:04.011898+00:00 2021-04-26T16:10:06.744246+00:00 0:09:02.732348 21516 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T16:01:01.649666+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-26T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-26T16:00:41.932008+00:00 2021-04-26T16:00:43.775985+00:00 0:00:01.843977 21515 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-26T16:00:39.588337+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-26T15:00:00+00:00 PythonOperator 2021-04-26T16:00:21.797000+00:00 2021-04-26T16:00:24.846267+00:00 0:00:03.049267 21514 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-26T16:00:19.486694+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-26T14:00:00+00:00 TriggerDagRunOperator 2021-04-26T15:11:25.277249+00:00 2021-04-26T15:11:25.799998+00:00 0:00:00.522749 21506 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T15:11:22.541688+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-26T14:00:00+00:00 TriggerDagRunOperator 2021-04-26T15:11:25.121528+00:00 2021-04-26T15:11:25.642149+00:00 0:00:00.520621 21505 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T15:11:22.541643+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-26T14:00:00+00:00 EmrJobFlowSensor 2021-04-26T15:01:01.745563+00:00 2021-04-26T15:11:04.740108+00:00 0:10:02.994545 21501 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T15:00:59.371785+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-26T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-26T15:00:39.580841+00:00 2021-04-26T15:00:41.318703+00:00 0:00:01.737862 21500 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-26T15:00:37.311180+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-26T14:00:00+00:00 PythonOperator 2021-04-26T15:00:19.581896+00:00 2021-04-26T15:00:22.687548+00:00 0:00:03.105652 21499 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-26T15:00:17.294779+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-26T13:00:00+00:00 TriggerDagRunOperator 2021-04-26T14:10:15.521567+00:00 2021-04-26T14:10:16.048160+00:00 0:00:00.526593 21491 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T14:10:13.294486+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-26T13:00:00+00:00 TriggerDagRunOperator 2021-04-26T14:10:15.488762+00:00 2021-04-26T14:10:15.894198+00:00 0:00:00.405436 21490 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T14:10:13.294520+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-26T13:00:00+00:00 EmrJobFlowSensor 2021-04-26T14:00:50.785159+00:00 2021-04-26T14:09:53.465784+00:00 0:09:02.680625 21486 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T14:00:48.450372+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-26T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-26T14:00:28.653164+00:00 2021-04-26T14:00:30.403271+00:00 0:00:01.750107 21485 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-26T14:00:26.349697+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-26T13:00:00+00:00 PythonOperator 2021-04-26T14:00:08.605592+00:00 2021-04-26T14:00:11.644910+00:00 0:00:03.039318 21484 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-26T14:00:06.329570+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-26T12:00:00+00:00 TriggerDagRunOperator 2021-04-26T13:16:34.803665+00:00 2021-04-26T13:16:35.562791+00:00 0:00:00.759126 21475 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T13:16:32.326476+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-26T12:00:00+00:00 TriggerDagRunOperator 2021-04-26T13:16:34.688193+00:00 2021-04-26T13:16:35.396782+00:00 0:00:00.708589 21474 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T13:16:32.326505+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-26T12:00:00+00:00 EmrJobFlowSensor 2021-04-26T13:16:15.192709+00:00 2021-04-26T13:16:16.778066+00:00 0:00:01.585357 21472 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T13:16:12.308786+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-26T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-26T13:00:30.626574+00:00 2021-04-26T13:00:32.343192+00:00 0:00:01.716618 21470 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-26T13:00:28.263205+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-26T12:00:00+00:00 PythonOperator 2021-04-26T13:00:10.593256+00:00 2021-04-26T13:00:13.681004+00:00 0:00:03.087748 21469 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-26T13:00:08.187427+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-26T11:00:00+00:00 TriggerDagRunOperator 2021-04-26T12:12:05.678357+00:00 2021-04-26T12:12:06.285527+00:00 0:00:00.607170 21462 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T12:12:03.088035+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-26T11:00:00+00:00 TriggerDagRunOperator 2021-04-26T12:12:05.363478+00:00 2021-04-26T12:12:05.790365+00:00 0:00:00.426887 21461 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T12:12:03.087986+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-26T11:00:00+00:00 EmrJobFlowSensor 2021-04-26T12:01:40.386400+00:00 2021-04-26T12:11:43.215686+00:00 0:10:02.829286 21457 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T12:01:38.114663+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-26T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-26T12:01:18.306423+00:00 2021-04-26T12:01:20.129026+00:00 0:00:01.822603 21456 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-26T12:01:16.088278+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-26T11:00:00+00:00 PythonOperator 2021-04-26T12:00:58.851873+00:00 2021-04-26T12:01:01.850561+00:00 0:00:02.998688 21455 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-26T12:00:56.127518+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-26T10:00:00+00:00 TriggerDagRunOperator 2021-04-26T11:10:40.042008+00:00 2021-04-26T11:10:40.559113+00:00 0:00:00.517105 21447 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T11:10:37.741767+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-26T10:00:00+00:00 TriggerDagRunOperator 2021-04-26T11:10:39.993820+00:00 2021-04-26T11:10:40.402245+00:00 0:00:00.408425 21446 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T11:10:37.741801+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-26T10:00:00+00:00 EmrJobFlowSensor 2021-04-26T11:01:09.704411+00:00 2021-04-26T11:10:12.471931+00:00 0:09:02.767520 21442 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T11:01:07.051193+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-26T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-26T11:00:47.149595+00:00 2021-04-26T11:00:48.872112+00:00 0:00:01.722517 21441 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-26T11:00:44.952067+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-26T10:00:00+00:00 PythonOperator 2021-04-26T11:00:27.321163+00:00 2021-04-26T11:00:30.361302+00:00 0:00:03.040139 21440 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-26T11:00:24.936681+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-26T09:00:00+00:00 TriggerDagRunOperator 2021-04-26T10:11:10.313709+00:00 2021-04-26T10:11:10.904929+00:00 0:00:00.591220 21432 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T10:11:07.942618+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-26T09:00:00+00:00 TriggerDagRunOperator 2021-04-26T10:11:10.264468+00:00 2021-04-26T10:11:10.732307+00:00 0:00:00.467839 21431 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T10:11:07.942646+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-26T09:00:00+00:00 EmrJobFlowSensor 2021-04-26T10:00:57.669853+00:00 2021-04-26T10:11:00.409871+00:00 0:10:02.740018 21427 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T10:00:55.260754+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-26T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-26T10:00:37.768016+00:00 2021-04-26T10:00:39.477811+00:00 0:00:01.709795 21426 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-26T10:00:35.159627+00:00 2 default_pool