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-26T09:00:00+00:00 PythonOperator 2021-04-26T10:00:05.451642+00:00 2021-04-26T10:00:08.509747+00:00 0:00:03.058105 21425 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-26T10:00:03.128294+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-26T08:00:00+00:00 TriggerDagRunOperator 2021-04-26T09:11:20.355441+00:00 2021-04-26T09:11:20.920500+00:00 0:00:00.565059 21417 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T09:11:18.015369+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-26T08:00:00+00:00 TriggerDagRunOperator 2021-04-26T09:11:20.294243+00:00 2021-04-26T09:11:20.727906+00:00 0:00:00.433663 21416 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T09:11:18.015403+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-26T08:00:00+00:00 EmrJobFlowSensor 2021-04-26T09:00:59.420138+00:00 2021-04-26T09:11:02.255597+00:00 0:10:02.835459 21412 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T09:00:56.985375+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-26T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-26T09:00:37.231981+00:00 2021-04-26T09:00:38.932173+00:00 0:00:01.700192 21411 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-26T09:00:34.961010+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-26T08:00:00+00:00 PythonOperator 2021-04-26T09:00:17.206911+00:00 2021-04-26T09:00:20.251784+00:00 0:00:03.044873 21410 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-26T09:00:14.887941+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-26T07:00:00+00:00 TriggerDagRunOperator 2021-04-26T08:10:05.510584+00:00 2021-04-26T08:10:05.953833+00:00 0:00:00.443249 21402 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T08:10:03.035094+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-26T07:00:00+00:00 TriggerDagRunOperator 2021-04-26T08:10:05.420960+00:00 2021-04-26T08:10:05.983119+00:00 0:00:00.562159 21401 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T08:10:03.035130+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-26T07:00:00+00:00 EmrJobFlowSensor 2021-04-26T08:00:56.347161+00:00 2021-04-26T08:09:58.945645+00:00 0:09:02.598484 21397 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T08:00:54.008215+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-26T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-26T08:00:34.397102+00:00 2021-04-26T08:00:36.113675+00:00 0:00:01.716573 21396 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-26T08:00:32.052208+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-26T07:00:00+00:00 PythonOperator 2021-04-26T08:00:14.486793+00:00 2021-04-26T08:00:17.480194+00:00 0:00:02.993401 21395 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-26T08:00:11.966358+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-26T06:00:00+00:00 TriggerDagRunOperator 2021-04-26T07:11:14.254829+00:00 2021-04-26T07:11:14.772733+00:00 0:00:00.517904 21384 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T07:11:11.572831+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-26T06:00:00+00:00 TriggerDagRunOperator 2021-04-26T07:11:14.060509+00:00 2021-04-26T07:11:14.508789+00:00 0:00:00.448280 21383 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T07:11:11.572782+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-26T06:00:00+00:00 EmrJobFlowSensor 2021-04-26T07:00:52.969815+00:00 2021-04-26T07:10:55.875769+00:00 0:10:02.905954 21379 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T07:00:50.595002+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-26T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-26T07:00:30.858144+00:00 2021-04-26T07:00:32.730959+00:00 0:00:01.872815 21378 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-26T07:00:28.562624+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-26T06:00:00+00:00 PythonOperator 2021-04-26T07:00:10.815341+00:00 2021-04-26T07:00:13.881458+00:00 0:00:03.066117 21377 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-26T07:00:08.528621+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-26T05:00:00+00:00 TriggerDagRunOperator 2021-04-26T06:10:42.068512+00:00 2021-04-26T06:10:42.571706+00:00 0:00:00.503194 21369 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T06:10:39.472277+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-26T05:00:00+00:00 TriggerDagRunOperator 2021-04-26T06:10:41.922618+00:00 2021-04-26T06:10:42.349626+00:00 0:00:00.427008 21368 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T06:10:39.472326+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-26T05:00:00+00:00 EmrJobFlowSensor 2021-04-26T06:01:14.870922+00:00 2021-04-26T06:10:17.483395+00:00 0:09:02.612473 21364 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T06:01:12.385762+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-26T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-26T06:00:48.731981+00:00 2021-04-26T06:00:50.404471+00:00 0:00:01.672490 21363 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-26T06:00:46.336487+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-26T05:00:00+00:00 PythonOperator 2021-04-26T06:00:20.649530+00:00 2021-04-26T06:00:23.668748+00:00 0:00:03.019218 21362 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-26T06:00:18.309627+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-26T04:00:00+00:00 TriggerDagRunOperator 2021-04-26T05:10:20.719168+00:00 2021-04-26T05:10:21.247891+00:00 0:00:00.528723 21354 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T05:10:18.304689+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-26T04:00:00+00:00 TriggerDagRunOperator 2021-04-26T05:10:20.537693+00:00 2021-04-26T05:10:20.959131+00:00 0:00:00.421438 21353 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T05:10:18.304652+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-26T04:00:00+00:00 EmrJobFlowSensor 2021-04-26T05:00:56.127931+00:00 2021-04-26T05:09:58.892156+00:00 0:09:02.764225 21349 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T05:00:53.487874+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-26T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-26T05:00:33.908199+00:00 2021-04-26T05:00:35.688634+00:00 0:00:01.780435 21348 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-26T05:00:31.424211+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-26T04:00:00+00:00 PythonOperator 2021-04-26T05:00:12.180664+00:00 2021-04-26T05:00:15.187550+00:00 0:00:03.006886 21347 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-26T05:00:09.465851+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-26T03:00:00+00:00 TriggerDagRunOperator 2021-04-26T04:09:10.430945+00:00 2021-04-26T04:09:10.933329+00:00 0:00:00.502384 21339 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T04:09:07.814063+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-26T03:00:00+00:00 TriggerDagRunOperator 2021-04-26T04:09:10.274179+00:00 2021-04-26T04:09:10.716044+00:00 0:00:00.441865 21338 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T04:09:07.814032+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-26T03:00:00+00:00 EmrJobFlowSensor 2021-04-26T04:01:01.555462+00:00 2021-04-26T04:09:04.169448+00:00 0:08:02.613986 21334 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T04:00:59.252076+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-26T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-26T04:00:39.723228+00:00 2021-04-26T04:00:41.408549+00:00 0:00:01.685321 21333 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-26T04:00:37.280281+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-26T03:00:00+00:00 PythonOperator 2021-04-26T04:00:17.513597+00:00 2021-04-26T04:00:20.555846+00:00 0:00:03.042249 21332 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-26T04:00:15.196805+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-26T02:00:00+00:00 TriggerDagRunOperator 2021-04-26T03:09:29.822085+00:00 2021-04-26T03:09:30.340705+00:00 0:00:00.518620 21324 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T03:09:27.250727+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-26T02:00:00+00:00 TriggerDagRunOperator 2021-04-26T03:09:29.544131+00:00 2021-04-26T03:09:29.966304+00:00 0:00:00.422173 21323 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T03:09:27.250776+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-26T02:00:00+00:00 EmrJobFlowSensor 2021-04-26T03:01:02.578817+00:00 2021-04-26T03:09:05.191082+00:00 0:08:02.612265 21319 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T03:01:00.394727+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-26T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-26T03:00:42.686210+00:00 2021-04-26T03:00:44.498823+00:00 0:00:01.812613 21318 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-26T03:00:40.451005+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-26T02:00:00+00:00 PythonOperator 2021-04-26T03:00:20.642305+00:00 2021-04-26T03:00:23.675178+00:00 0:00:03.032873 21317 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-26T03:00:18.304884+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-26T01:00:00+00:00 TriggerDagRunOperator 2021-04-26T02:09:06.509632+00:00 2021-04-26T02:09:06.941682+00:00 0:00:00.432050 21309 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T02:09:03.851669+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-26T01:00:00+00:00 TriggerDagRunOperator 2021-04-26T02:09:06.093945+00:00 2021-04-26T02:09:06.653239+00:00 0:00:00.559294 21308 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T02:09:03.851703+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-26T01:00:00+00:00 EmrJobFlowSensor 2021-04-26T02:00:55.335264+00:00 2021-04-26T02:08:57.879643+00:00 0:08:02.544379 21304 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T02:00:53.105567+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-26T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-26T02:00:33.314675+00:00 2021-04-26T02:00:35.345365+00:00 0:00:02.030690 21303 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-26T02:00:31.086373+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-26T01:00:00+00:00 PythonOperator 2021-04-26T02:00:11.401338+00:00 2021-04-26T02:00:14.495115+00:00 0:00:03.093777 21302 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-26T02:00:09.031972+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-26T00:00:00+00:00 TriggerDagRunOperator 2021-04-26T01:10:17.318191+00:00 2021-04-26T01:10:17.781059+00:00 0:00:00.462868 21294 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T01:10:14.963514+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-26T00:00:00+00:00 TriggerDagRunOperator 2021-04-26T01:10:17.313064+00:00 2021-04-26T01:10:17.866870+00:00 0:00:00.553806 21293 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T01:10:14.963477+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-26T00:00:00+00:00 EmrJobFlowSensor 2021-04-26T01:01:00.530544+00:00 2021-04-26T01:10:03.235253+00:00 0:09:02.704709 21289 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T01:00:57.964976+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-26T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-26T01:00:38.126992+00:00 2021-04-26T01:00:39.850573+00:00 0:00:01.723581 21288 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-26T01:00:35.879389+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-26T00:00:00+00:00 PythonOperator 2021-04-26T01:00:18.520096+00:00 2021-04-26T01:00:21.620379+00:00 0:00:03.100283 21287 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-26T01:00:15.798572+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-25T23:00:00+00:00 TriggerDagRunOperator 2021-04-26T00:10:16.332574+00:00 2021-04-26T00:10:16.884093+00:00 0:00:00.551519 21279 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T00:10:13.467537+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-25T23:00:00+00:00 TriggerDagRunOperator 2021-04-26T00:10:16.292654+00:00 2021-04-26T00:10:16.727447+00:00 0:00:00.434793 21278 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T00:10:13.467588+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-25T23:00:00+00:00 EmrJobFlowSensor 2021-04-26T00:01:03.002854+00:00 2021-04-26T00:10:05.753807+00:00 0:09:02.750953 21274 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T00:01:00.658809+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-25T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-26T00:00:40.846082+00:00 2021-04-26T00:00:42.639178+00:00 0:00:01.793096 21273 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-26T00:00:38.592763+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-25T23:00:00+00:00 PythonOperator 2021-04-26T00:00:19.294134+00:00 2021-04-26T00:00:22.296116+00:00 0:00:03.001982 21272 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-26T00:00:16.564541+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-25T22:00:00+00:00 TriggerDagRunOperator 2021-04-25T23:11:10.674635+00:00 2021-04-25T23:11:11.222606+00:00 0:00:00.547971 21264 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T23:11:08.316845+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-25T22:00:00+00:00 TriggerDagRunOperator 2021-04-25T23:11:10.625927+00:00 2021-04-25T23:11:11.092757+00:00 0:00:00.466830 21263 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T23:11:08.316895+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-25T22:00:00+00:00 EmrJobFlowSensor 2021-04-25T23:00:51.707421+00:00 2021-04-25T23:10:54.433251+00:00 0:10:02.725830 21259 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T23:00:48.711865+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-25T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T23:00:29.172913+00:00 2021-04-25T23:00:30.934357+00:00 0:00:01.761444 21256 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-25T23:00:26.657555+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-25T22:00:00+00:00 PythonOperator 2021-04-25T23:00:08.879114+00:00 2021-04-25T23:00:11.837523+00:00 0:00:02.958409 21255 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-25T23:00:06.615745+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-25T21:00:00+00:00 TriggerDagRunOperator 2021-04-25T22:08:57.097678+00:00 2021-04-25T22:08:57.611644+00:00 0:00:00.513966 21246 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T22:08:54.448035+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-25T21:00:00+00:00 TriggerDagRunOperator 2021-04-25T22:08:56.992740+00:00 2021-04-25T22:08:57.635749+00:00 0:00:00.643009 21245 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T22:08:54.447903+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-25T21:00:00+00:00 EmrJobFlowSensor 2021-04-25T22:00:47.408605+00:00 2021-04-25T22:08:49.928419+00:00 0:08:02.519814 21241 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T22:00:45.294568+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-25T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T22:00:25.629699+00:00 2021-04-25T22:00:27.464078+00:00 0:00:01.834379 21240 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-25T22:00:23.263420+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-25T21:00:00+00:00 PythonOperator 2021-04-25T22:00:05.806409+00:00 2021-04-25T22:00:08.831794+00:00 0:00:03.025385 21239 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-25T22:00:03.208638+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-25T20:00:00+00:00 TriggerDagRunOperator 2021-04-25T21:10:57.970238+00:00 2021-04-25T21:10:58.515520+00:00 0:00:00.545282 21231 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T21:10:55.668702+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-25T20:00:00+00:00 TriggerDagRunOperator 2021-04-25T21:10:57.883673+00:00 2021-04-25T21:10:58.292389+00:00 0:00:00.408716 21230 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T21:10:55.668737+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-25T20:00:00+00:00 EmrJobFlowSensor 2021-04-25T21:00:48.965521+00:00 2021-04-25T21:10:51.749409+00:00 0:10:02.783888 21226 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T21:00:46.278863+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-25T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T21:00:26.637048+00:00 2021-04-25T21:00:28.380228+00:00 0:00:01.743180 21225 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-25T21:00:24.245579+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-25T20:00:00+00:00 PythonOperator 2021-04-25T21:00:06.901836+00:00 2021-04-25T21:00:09.902512+00:00 0:00:03.000676 21224 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-25T21:00:04.161908+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-25T19:00:00+00:00 TriggerDagRunOperator 2021-04-25T20:09:58.178675+00:00 2021-04-25T20:09:58.693732+00:00 0:00:00.515057 21216 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T20:09:55.415977+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-25T19:00:00+00:00 TriggerDagRunOperator 2021-04-25T20:09:57.648596+00:00 2021-04-25T20:09:58.038689+00:00 0:00:00.390093 21215 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T20:09:55.415934+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-25T19:00:00+00:00 EmrJobFlowSensor 2021-04-25T20:00:50.475593+00:00 2021-04-25T20:09:53.177650+00:00 0:09:02.702057 21211 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T20:00:48.147252+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-25T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T20:00:30.437145+00:00 2021-04-25T20:00:32.118309+00:00 0:00:01.681164 21210 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-25T20:00:28.144884+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-25T19:00:00+00:00 PythonOperator 2021-04-25T20:00:08.391692+00:00 2021-04-25T20:00:11.416076+00:00 0:00:03.024384 21209 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-25T20:00:06.088935+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-25T18:00:00+00:00 TriggerDagRunOperator 2021-04-25T19:10:23.241063+00:00 2021-04-25T19:10:23.652161+00:00 0:00:00.411098 21201 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T19:10:20.712925+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-25T18:00:00+00:00 TriggerDagRunOperator 2021-04-25T19:10:22.945803+00:00 2021-04-25T19:10:23.449733+00:00 0:00:00.503930 21200 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T19:10:20.712880+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-25T18:00:00+00:00 EmrJobFlowSensor 2021-04-25T19:00:56.276169+00:00 2021-04-25T19:09:58.950643+00:00 0:09:02.674474 21196 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T19:00:53.920457+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-25T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T19:00:26.156306+00:00 2021-04-25T19:00:27.825682+00:00 0:00:01.669376 21195 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-25T19:00:23.894213+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-25T18:00:00+00:00 PythonOperator 2021-04-25T19:00:04.724311+00:00 2021-04-25T19:00:07.872835+00:00 0:00:03.148524 21194 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-25T19:00:01.811926+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-25T17:00:00+00:00 TriggerDagRunOperator 2021-04-25T18:10:17.527443+00:00 2021-04-25T18:10:17.955929+00:00 0:00:00.428486 21186 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T18:10:15.248948+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-25T17:00:00+00:00 TriggerDagRunOperator 2021-04-25T18:10:17.511393+00:00 2021-04-25T18:10:18.076751+00:00 0:00:00.565358 21185 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T18:10:15.249002+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-25T17:00:00+00:00 EmrJobFlowSensor 2021-04-25T18:00:52.149069+00:00 2021-04-25T18:09:54.885680+00:00 0:09:02.736611 21181 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T18:00:50.001569+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-25T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T18:00:30.229921+00:00 2021-04-25T18:00:32.919047+00:00 0:00:02.689126 21180 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-25T18:00:27.962127+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-25T17:00:00+00:00 PythonOperator 2021-04-25T18:00:08.435463+00:00 2021-04-25T18:00:11.440920+00:00 0:00:03.005457 21179 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-25T18:00:05.924131+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-25T16:00:00+00:00 TriggerDagRunOperator 2021-04-25T17:10:01.835206+00:00 2021-04-25T17:10:02.414576+00:00 0:00:00.579370 21171 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T17:09:59.387323+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-25T16:00:00+00:00 TriggerDagRunOperator 2021-04-25T17:10:01.759803+00:00 2021-04-25T17:10:02.265464+00:00 0:00:00.505661 21170 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T17:09:59.387358+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-25T16:00:00+00:00 EmrJobFlowSensor 2021-04-25T17:00:54.673956+00:00 2021-04-25T17:09:57.318652+00:00 0:09:02.644696 21166 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T17:00:52.341609+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-25T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T17:00:32.648750+00:00 2021-04-25T17:00:34.470951+00:00 0:00:01.822201 21165 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-25T17:00:30.155272+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-25T16:00:00+00:00 PythonOperator 2021-04-25T17:00:10.417526+00:00 2021-04-25T17:00:13.387932+00:00 0:00:02.970406 21164 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-25T17:00:08.054140+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-25T15:00:00+00:00 TriggerDagRunOperator 2021-04-25T16:10:17.273514+00:00 2021-04-25T16:10:17.784815+00:00 0:00:00.511301 21156 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T16:10:14.663716+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-25T15:00:00+00:00 TriggerDagRunOperator 2021-04-25T16:10:17.124161+00:00 2021-04-25T16:10:17.540800+00:00 0:00:00.416639 21155 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T16:10:14.663678+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-25T15:00:00+00:00 EmrJobFlowSensor 2021-04-25T16:01:03.718770+00:00 2021-04-25T16:10:06.538827+00:00 0:09:02.820057 21151 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T16:01:01.404272+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-25T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T16:00:39.718187+00:00 2021-04-25T16:00:41.444589+00:00 0:00:01.726402 21150 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-25T16:00:37.376704+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-25T15:00:00+00:00 PythonOperator 2021-04-25T16:00:19.741747+00:00 2021-04-25T16:00:22.792784+00:00 0:00:03.051037 21149 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-25T16:00:17.370791+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-25T14:00:00+00:00 TriggerDagRunOperator 2021-04-25T15:30:40.006562+00:00 2021-04-25T15:30:40.515826+00:00 0:00:00.509264 21142 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T15:30:37.476627+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-25T14:00:00+00:00 TriggerDagRunOperator 2021-04-25T15:30:39.883653+00:00 2021-04-25T15:30:40.288465+00:00 0:00:00.404812 21141 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T15:30:37.476669+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-25T14:00:00+00:00 EmrJobFlowSensor 2021-04-25T15:20:14.435287+00:00 2021-04-25T15:30:17.253795+00:00 0:10:02.818508 21140 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T15:20:12.074472+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-25T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T15:19:54.394656+00:00 2021-04-25T15:19:56.200471+00:00 0:00:01.805815 21138 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-25T15:19:51.996141+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-25T14:00:00+00:00 PythonOperator 2021-04-25T15:19:32.738222+00:00 2021-04-25T15:19:35.687951+00:00 0:00:02.949729 21136 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-25T15:19:29.934464+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-25T13:00:00+00:00 TriggerDagRunOperator 2021-04-25T14:11:21.930097+00:00 2021-04-25T14:11:22.449248+00:00 0:00:00.519151 21127 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T14:11:19.627158+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-25T13:00:00+00:00 TriggerDagRunOperator 2021-04-25T14:11:21.820386+00:00 2021-04-25T14:11:22.213919+00:00 0:00:00.393533 21126 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-25T14:11:19.627185+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-25T13:00:00+00:00 EmrJobFlowSensor 2021-04-25T14:00:54.505089+00:00 2021-04-25T14:10:57.365295+00:00 0:10:02.860206 21122 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-25T14:00:52.287864+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-25T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-25T14:00:33.061494+00:00 2021-04-25T14:00:34.865298+00:00 0:00:01.803804 21121 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-25T14:00:30.444529+00:00 2 default_pool