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-05-08T01:00:00+00:00 PythonOperator 2021-05-08T02:00:18.652601+00:00 2021-05-08T02:00:21.762314+00:00 0:00:03.109713 25661 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-08T02:00:16.176518+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-08T00:00:00+00:00 TriggerDagRunOperator 2021-05-08T01:11:30.733809+00:00 2021-05-08T01:11:31.281901+00:00 0:00:00.548092 25653 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T01:11:28.062217+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-08T00:00:00+00:00 TriggerDagRunOperator 2021-05-08T01:11:30.487345+00:00 2021-05-08T01:11:30.897368+00:00 0:00:00.410023 25652 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T01:11:28.062171+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-08T00:00:00+00:00 EmrJobFlowSensor 2021-05-08T01:01:05.039464+00:00 2021-05-08T01:11:07.887448+00:00 0:10:02.847984 25648 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T01:01:02.785312+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-08T00:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T01:00:43.018156+00:00 2021-05-08T01:00:44.700258+00:00 0:00:01.682102 25647 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-08T01:00:40.701959+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-08T00:00:00+00:00 PythonOperator 2021-05-08T01:00:21.041053+00:00 2021-05-08T01:00:24.262074+00:00 0:00:03.221021 25646 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-08T01:00:18.687095+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-07T23:00:00+00:00 TriggerDagRunOperator 2021-05-08T00:11:10.097042+00:00 2021-05-08T00:11:10.648730+00:00 0:00:00.551688 25638 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T00:11:07.751502+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-07T23:00:00+00:00 TriggerDagRunOperator 2021-05-08T00:11:09.972877+00:00 2021-05-08T00:11:10.418702+00:00 0:00:00.445825 25637 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T00:11:07.751464+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-07T23:00:00+00:00 EmrJobFlowSensor 2021-05-08T00:00:48.910406+00:00 2021-05-08T00:10:51.830231+00:00 0:10:02.919825 25633 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T00:00:46.611673+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-07T23:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T00:00:27.014763+00:00 2021-05-08T00:00:28.812688+00:00 0:00:01.797925 25632 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-08T00:00:24.593694+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-07T23:00:00+00:00 PythonOperator 2021-05-08T00:00:05.050684+00:00 2021-05-08T00:00:08.150916+00:00 0:00:03.100232 25631 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-08T00:00:02.543077+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-07T22:00:00+00:00 TriggerDagRunOperator 2021-05-07T23:11:17.713935+00:00 2021-05-07T23:11:18.261386+00:00 0:00:00.547451 25623 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T23:11:15.252010+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-07T22:00:00+00:00 TriggerDagRunOperator 2021-05-07T23:11:17.566325+00:00 2021-05-07T23:11:17.968575+00:00 0:00:00.402250 25622 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T23:11:15.251976+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-07T22:00:00+00:00 EmrJobFlowSensor 2021-05-07T23:00:58.368676+00:00 2021-05-07T23:11:01.259487+00:00 0:10:02.890811 25618 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T23:00:55.928693+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-07T22:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T23:00:36.345026+00:00 2021-05-07T23:00:38.147766+00:00 0:00:01.802740 25616 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-07T23:00:33.960124+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-07T22:00:00+00:00 PythonOperator 2021-05-07T23:00:14.622847+00:00 2021-05-07T23:00:17.709289+00:00 0:00:03.086442 25614 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-07T23:00:11.941082+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-07T21:00:00+00:00 TriggerDagRunOperator 2021-05-07T22:10:21.616787+00:00 2021-05-07T22:10:22.151061+00:00 0:00:00.534274 25605 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T22:10:19.319113+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-07T21:00:00+00:00 TriggerDagRunOperator 2021-05-07T22:10:21.487594+00:00 2021-05-07T22:10:21.900538+00:00 0:00:00.412944 25604 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T22:10:19.319144+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-07T21:00:00+00:00 EmrJobFlowSensor 2021-05-07T22:01:02.535642+00:00 2021-05-07T22:10:05.292164+00:00 0:09:02.756522 25600 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T22:01:00.318009+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-07T21:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T22:00:40.648925+00:00 2021-05-07T22:00:42.444411+00:00 0:00:01.795486 25599 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-07T22:00:38.285176+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-07T21:00:00+00:00 PythonOperator 2021-05-07T22:00:18.904850+00:00 2021-05-07T22:00:21.990623+00:00 0:00:03.085773 25598 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-07T22:00:16.204637+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-07T20:00:00+00:00 TriggerDagRunOperator 2021-05-07T21:11:18.360756+00:00 2021-05-07T21:11:18.973235+00:00 0:00:00.612479 25590 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T21:11:16.024703+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-07T20:00:00+00:00 TriggerDagRunOperator 2021-05-07T21:11:18.174746+00:00 2021-05-07T21:11:18.625774+00:00 0:00:00.451028 25589 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T21:11:16.024673+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-07T20:00:00+00:00 EmrJobFlowSensor 2021-05-07T21:00:56.701887+00:00 2021-05-07T21:10:59.491738+00:00 0:10:02.789851 25585 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T21:00:54.508725+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-07T20:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T21:00:36.791536+00:00 2021-05-07T21:00:38.463184+00:00 0:00:01.671648 25584 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-07T21:00:34.490737+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-07T20:00:00+00:00 PythonOperator 2021-05-07T21:00:15.457898+00:00 2021-05-07T21:00:18.537665+00:00 0:00:03.079767 25583 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-07T21:00:12.227129+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-07T19:00:00+00:00 TriggerDagRunOperator 2021-05-07T20:09:29.937677+00:00 2021-05-07T20:09:30.477566+00:00 0:00:00.539889 25575 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T20:09:27.337441+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-07T19:00:00+00:00 TriggerDagRunOperator 2021-05-07T20:09:29.763613+00:00 2021-05-07T20:09:30.184662+00:00 0:00:00.421049 25574 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T20:09:27.337473+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-07T19:00:00+00:00 EmrJobFlowSensor 2021-05-07T20:00:56.792676+00:00 2021-05-07T20:08:59.251543+00:00 0:08:02.458867 25570 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T20:00:54.557673+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-07T19:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T20:00:36.847468+00:00 2021-05-07T20:00:38.716755+00:00 0:00:01.869287 25569 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-07T20:00:34.547158+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-07T19:00:00+00:00 PythonOperator 2021-05-07T20:00:15.110025+00:00 2021-05-07T20:00:18.185757+00:00 0:00:03.075732 25568 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-07T20:00:12.430152+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-07T18:00:00+00:00 TriggerDagRunOperator 2021-05-07T19:11:21.362233+00:00 2021-05-07T19:11:21.764489+00:00 0:00:00.402256 25560 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T19:11:18.928607+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-07T18:00:00+00:00 TriggerDagRunOperator 2021-05-07T19:11:21.193863+00:00 2021-05-07T19:11:21.796430+00:00 0:00:00.602567 25559 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T19:11:18.928577+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-07T18:00:00+00:00 EmrJobFlowSensor 2021-05-07T19:01:11.984733+00:00 2021-05-07T19:11:14.826334+00:00 0:10:02.841601 25555 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T19:01:09.896699+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-07T18:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T19:00:52.046491+00:00 2021-05-07T19:00:53.732164+00:00 0:00:01.685673 25554 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-07T19:00:49.832651+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-07T18:00:00+00:00 PythonOperator 2021-05-07T19:00:30.320919+00:00 2021-05-07T19:00:33.369743+00:00 0:00:03.048824 25553 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-07T19:00:27.344850+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-07T17:00:00+00:00 TriggerDagRunOperator 2021-05-07T18:11:15.608491+00:00 2021-05-07T18:11:16.113756+00:00 0:00:00.505265 25545 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T18:11:13.089656+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-07T17:00:00+00:00 TriggerDagRunOperator 2021-05-07T18:11:15.294147+00:00 2021-05-07T18:11:15.710694+00:00 0:00:00.416547 25544 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T18:11:13.089618+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-07T17:00:00+00:00 EmrJobFlowSensor 2021-05-07T18:00:50.229135+00:00 2021-05-07T18:10:53.127448+00:00 0:10:02.898313 25540 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T18:00:47.733545+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-07T17:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T18:00:27.798791+00:00 2021-05-07T18:00:29.472956+00:00 0:00:01.674165 25539 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-07T18:00:25.717302+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-07T17:00:00+00:00 PythonOperator 2021-05-07T18:00:06.285561+00:00 2021-05-07T18:00:09.412197+00:00 0:00:03.126636 25538 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-07T18:00:03.763350+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-07T16:00:00+00:00 TriggerDagRunOperator 2021-05-07T17:11:12.302752+00:00 2021-05-07T17:11:12.861135+00:00 0:00:00.558383 25530 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T17:11:09.994261+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-07T16:00:00+00:00 TriggerDagRunOperator 2021-05-07T17:11:12.206688+00:00 2021-05-07T17:11:12.624059+00:00 0:00:00.417371 25529 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T17:11:09.994293+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-07T16:00:00+00:00 EmrJobFlowSensor 2021-05-07T17:01:05.480802+00:00 2021-05-07T17:11:08.261112+00:00 0:10:02.780310 25525 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T17:01:03.149694+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-07T16:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T17:00:43.183189+00:00 2021-05-07T17:00:44.936102+00:00 0:00:01.752913 25524 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-07T17:00:41.087024+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-07T16:00:00+00:00 PythonOperator 2021-05-07T17:00:21.312641+00:00 2021-05-07T17:00:24.373792+00:00 0:00:03.061151 25523 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-07T17:00:19.074849+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-07T15:00:00+00:00 TriggerDagRunOperator 2021-05-07T16:11:17.075270+00:00 2021-05-07T16:11:17.511559+00:00 0:00:00.436289 25515 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T16:11:14.521879+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-07T15:00:00+00:00 TriggerDagRunOperator 2021-05-07T16:11:16.809940+00:00 2021-05-07T16:11:17.407380+00:00 0:00:00.597440 25514 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T16:11:14.521909+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-07T15:00:00+00:00 EmrJobFlowSensor 2021-05-07T16:01:05.513358+00:00 2021-05-07T16:11:08.230993+00:00 0:10:02.717635 25510 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T16:01:03.190579+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-07T15:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T16:00:43.388064+00:00 2021-05-07T16:00:45.108903+00:00 0:00:01.720839 25509 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-07T16:00:41.110640+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-07T15:00:00+00:00 PythonOperator 2021-05-07T16:00:21.437088+00:00 2021-05-07T16:00:24.518393+00:00 0:00:03.081305 25508 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-07T16:00:19.094566+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-07T14:00:00+00:00 TriggerDagRunOperator 2021-05-07T15:10:12.621454+00:00 2021-05-07T15:10:13.155938+00:00 0:00:00.534484 25500 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T15:10:10.412863+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-07T14:00:00+00:00 TriggerDagRunOperator 2021-05-07T15:10:12.546836+00:00 2021-05-07T15:10:12.930409+00:00 0:00:00.383573 25499 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T15:10:10.412898+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-07T14:00:00+00:00 EmrJobFlowSensor 2021-05-07T15:00:55.356176+00:00 2021-05-07T15:09:58.077101+00:00 0:09:02.720925 25495 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T15:00:53.079249+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-07T14:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T15:00:33.274488+00:00 2021-05-07T15:00:35.007276+00:00 0:00:01.732788 25494 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-07T15:00:31.065356+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-07T14:00:00+00:00 PythonOperator 2021-05-07T15:00:11.226985+00:00 2021-05-07T15:00:14.328318+00:00 0:00:03.101333 25493 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-07T15:00:08.989514+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-07T13:00:00+00:00 TriggerDagRunOperator 2021-05-07T14:11:16.520535+00:00 2021-05-07T14:11:17.058794+00:00 0:00:00.538259 25485 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T14:11:14.198592+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-07T13:00:00+00:00 TriggerDagRunOperator 2021-05-07T14:11:16.287212+00:00 2021-05-07T14:11:16.729514+00:00 0:00:00.442302 25484 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T14:11:14.198561+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-07T13:00:00+00:00 EmrJobFlowSensor 2021-05-07T14:00:59.106288+00:00 2021-05-07T14:11:01.951578+00:00 0:10:02.845290 25480 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T14:00:56.924564+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-07T13:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T14:00:39.512249+00:00 2021-05-07T14:00:41.306511+00:00 0:00:01.794262 25479 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-07T14:00:36.947588+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-07T13:00:00+00:00 PythonOperator 2021-05-07T14:00:17.057836+00:00 2021-05-07T14:00:20.095120+00:00 0:00:03.037284 25478 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-07T14:00:14.835557+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-07T12:00:00+00:00 TriggerDagRunOperator 2021-05-07T13:16:05.682449+00:00 2021-05-07T13:16:06.226402+00:00 0:00:00.543953 25471 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T13:16:03.114488+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-07T12:00:00+00:00 TriggerDagRunOperator 2021-05-07T13:16:05.592985+00:00 2021-05-07T13:16:05.977326+00:00 0:00:00.384341 25470 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T13:16:03.114517+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-07T12:00:00+00:00 EmrJobFlowSensor 2021-05-07T13:01:07.112993+00:00 2021-05-07T13:10:09.801292+00:00 0:09:02.688299 25465 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T13:01:04.992653+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-07T12:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T13:00:45.244109+00:00 2021-05-07T13:00:46.920713+00:00 0:00:01.676604 25464 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-07T13:00:42.960704+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-07T12:00:00+00:00 PythonOperator 2021-05-07T13:00:25.182062+00:00 2021-05-07T13:00:28.348693+00:00 0:00:03.166631 25463 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-07T13:00:22.838512+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-07T11:00:00+00:00 TriggerDagRunOperator 2021-05-07T12:10:01.697476+00:00 2021-05-07T12:10:02.393593+00:00 0:00:00.696117 25454 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T12:09:58.549067+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-07T11:00:00+00:00 TriggerDagRunOperator 2021-05-07T12:10:01.293524+00:00 2021-05-07T12:10:01.835471+00:00 0:00:00.541947 25453 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T12:09:58.549096+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-07T11:00:00+00:00 EmrJobFlowSensor 2021-05-07T12:00:48.922272+00:00 2021-05-07T12:09:51.694613+00:00 0:09:02.772341 25450 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T12:00:46.441169+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-07T11:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T12:00:26.704991+00:00 2021-05-07T12:00:28.415323+00:00 0:00:01.710332 25449 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-07T12:00:24.367081+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-07T11:00:00+00:00 PythonOperator 2021-05-07T12:00:06.494595+00:00 2021-05-07T12:00:09.536376+00:00 0:00:03.041781 25448 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-07T12:00:04.269880+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-07T10:00:00+00:00 TriggerDagRunOperator 2021-05-07T11:10:28.644095+00:00 2021-05-07T11:10:29.162504+00:00 0:00:00.518409 25441 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T11:10:25.983099+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-07T10:00:00+00:00 TriggerDagRunOperator 2021-05-07T11:10:28.517944+00:00 2021-05-07T11:10:28.947245+00:00 0:00:00.429301 25440 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T11:10:25.983054+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-07T10:00:00+00:00 EmrJobFlowSensor 2021-05-07T11:01:00.919214+00:00 2021-05-07T11:10:03.557596+00:00 0:09:02.638382 25435 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T11:00:58.672152+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-07T10:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T11:00:38.936129+00:00 2021-05-07T11:00:40.745582+00:00 0:00:01.809453 25434 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-07T11:00:36.426939+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-07T10:00:00+00:00 PythonOperator 2021-05-07T11:00:17.246162+00:00 2021-05-07T11:00:20.341540+00:00 0:00:03.095378 25433 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-07T11:00:14.454274+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-07T09:00:00+00:00 TriggerDagRunOperator 2021-05-07T10:14:52.773873+00:00 2021-05-07T10:14:53.398401+00:00 0:00:00.624528 25426 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T10:14:50.124639+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-07T09:00:00+00:00 TriggerDagRunOperator 2021-05-07T10:14:52.474637+00:00 2021-05-07T10:14:52.911466+00:00 0:00:00.436829 25425 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T10:14:50.124680+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-07T09:00:00+00:00 EmrJobFlowSensor 2021-05-07T10:04:31.334293+00:00 2021-05-07T10:14:34.159057+00:00 0:10:02.824764 25421 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T10:04:29.215066+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-07T09:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T10:04:09.612964+00:00 2021-05-07T10:04:11.330793+00:00 0:00:01.717829 25420 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-07T10:04:07.217380+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-07T09:00:00+00:00 PythonOperator 2021-05-07T10:00:19.338415+00:00 2021-05-07T10:00:22.382858+00:00 0:00:03.044443 25418 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-07T10:00:17.047320+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-07T08:00:00+00:00 TriggerDagRunOperator 2021-05-07T09:10:33.422382+00:00 2021-05-07T09:10:33.953384+00:00 0:00:00.531002 25411 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T09:10:30.706445+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-07T08:00:00+00:00 TriggerDagRunOperator 2021-05-07T09:10:33.165323+00:00 2021-05-07T09:10:33.598268+00:00 0:00:00.432945 25410 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T09:10:30.706399+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-07T08:00:00+00:00 EmrJobFlowSensor 2021-05-07T09:01:16.027149+00:00 2021-05-07T09:10:18.775389+00:00 0:09:02.748240 25406 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T09:01:13.679405+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-07T08:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T09:00:53.863479+00:00 2021-05-07T09:00:55.582387+00:00 0:00:01.718908 25405 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-07T09:00:51.588588+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-07T08:00:00+00:00 PythonOperator 2021-05-07T09:00:34.289691+00:00 2021-05-07T09:00:37.391899+00:00 0:00:03.102208 25404 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-07T09:00:31.571000+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-07T07:00:00+00:00 TriggerDagRunOperator 2021-05-07T08:11:02.433763+00:00 2021-05-07T08:11:02.947156+00:00 0:00:00.513393 25396 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T08:10:59.657931+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-07T07:00:00+00:00 TriggerDagRunOperator 2021-05-07T08:11:02.088719+00:00 2021-05-07T08:11:02.484423+00:00 0:00:00.395704 25395 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T08:10:59.657879+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-07T07:00:00+00:00 EmrJobFlowSensor 2021-05-07T08:00:46.442689+00:00 2021-05-07T08:10:49.471396+00:00 0:10:03.028707 25391 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T08:00:44.143292+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-07T07:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T08:00:26.656598+00:00 2021-05-07T08:00:28.522026+00:00 0:00:01.865428 25390 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-07T08:00:24.180432+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-07T07:00:00+00:00 PythonOperator 2021-05-07T08:00:04.493408+00:00 2021-05-07T08:00:07.565589+00:00 0:00:03.072181 25389 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-07T08:00:02.090033+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-07T06:00:00+00:00 TriggerDagRunOperator 2021-05-07T07:10:25.315842+00:00 2021-05-07T07:10:25.824651+00:00 0:00:00.508809 25381 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T07:10:22.808117+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-07T06:00:00+00:00 TriggerDagRunOperator 2021-05-07T07:10:25.006759+00:00 2021-05-07T07:10:25.441742+00:00 0:00:00.434983 25380 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T07:10:22.808151+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-07T06:00:00+00:00 EmrJobFlowSensor 2021-05-07T07:00:57.688425+00:00 2021-05-07T07:10:00.309939+00:00 0:09:02.621514 25376 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T07:00:55.560381+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-07T06:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T07:00:33.839200+00:00 2021-05-07T07:00:35.594256+00:00 0:00:01.755056 25375 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-07T07:00:31.585904+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-07T06:00:00+00:00 PythonOperator 2021-05-07T07:00:11.898842+00:00 2021-05-07T07:00:15.073346+00:00 0:00:03.174504 25374 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-07T07:00:09.485481+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-07T05:00:00+00:00 TriggerDagRunOperator 2021-05-07T06:09:59.210699+00:00 2021-05-07T06:09:59.724251+00:00 0:00:00.513552 25366 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T06:09:56.165160+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-07T05:00:00+00:00 TriggerDagRunOperator 2021-05-07T06:09:58.589006+00:00 2021-05-07T06:09:59.002864+00:00 0:00:00.413858 25365 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T06:09:56.165203+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-07T05:00:00+00:00 EmrJobFlowSensor 2021-05-07T06:00:46.933166+00:00 2021-05-07T06:09:49.750901+00:00 0:09:02.817735 25361 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T06:00:44.692807+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-07T05:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T06:00:25.077608+00:00 2021-05-07T06:00:26.904323+00:00 0:00:01.826715 25360 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-07T06:00:22.621857+00:00 2 default_pool