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-08T01:00:00+00:00 PythonOperator 2021-04-08T02:00:08.606018+00:00 2021-04-08T02:00:11.385849+00:00 0:00:02.779831 14762 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-08T02:00:05.947615+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-08T00:00:00+00:00 TriggerDagRunOperator 2021-04-08T01:10:26.554216+00:00 2021-04-08T01:10:27.104732+00:00 0:00:00.550516 14754 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T01:10:24.263267+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-08T00:00:00+00:00 TriggerDagRunOperator 2021-04-08T01:10:26.464903+00:00 2021-04-08T01:10:26.889276+00:00 0:00:00.424373 14753 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T01:10:24.263316+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-08T00:00:00+00:00 EmrJobFlowSensor 2021-04-08T01:01:01.747149+00:00 2021-04-08T01:10:04.475623+00:00 0:09:02.728474 14749 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T01:00:59.473659+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-08T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T01:00:37.693638+00:00 2021-04-08T01:00:39.377031+00:00 0:00:01.683393 14748 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-08T01:00:35.404663+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-08T00:00:00+00:00 PythonOperator 2021-04-08T01:00:16.020460+00:00 2021-04-08T01:00:18.752730+00:00 0:00:02.732270 14747 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-08T01:00:13.340732+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-07T23:00:00+00:00 TriggerDagRunOperator 2021-04-08T00:10:17.710542+00:00 2021-04-08T00:10:18.245700+00:00 0:00:00.535158 14739 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T00:10:15.072196+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-07T23:00:00+00:00 TriggerDagRunOperator 2021-04-08T00:10:17.539391+00:00 2021-04-08T00:10:17.944407+00:00 0:00:00.405016 14738 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T00:10:15.072235+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-07T23:00:00+00:00 EmrJobFlowSensor 2021-04-08T00:00:54.576508+00:00 2021-04-08T00:09:57.415698+00:00 0:09:02.839190 14734 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T00:00:52.099732+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-07T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T00:00:32.299414+00:00 2021-04-08T00:00:34.046353+00:00 0:00:01.746939 14733 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-08T00:00:30.082625+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-07T23:00:00+00:00 PythonOperator 2021-04-08T00:00:04.714600+00:00 2021-04-08T00:00:07.455527+00:00 0:00:02.740927 14732 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-08T00:00:02.077902+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-07T22:00:00+00:00 TriggerDagRunOperator 2021-04-07T23:10:34.630654+00:00 2021-04-07T23:10:35.091523+00:00 0:00:00.460869 14724 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T23:10:32.368493+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-07T22:00:00+00:00 TriggerDagRunOperator 2021-04-07T23:10:34.627738+00:00 2021-04-07T23:10:35.191776+00:00 0:00:00.564038 14723 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T23:10:32.368531+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-07T22:00:00+00:00 EmrJobFlowSensor 2021-04-07T23:01:07.522893+00:00 2021-04-07T23:10:10.353374+00:00 0:09:02.830481 14719 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T23:01:05.210021+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-07T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T23:00:45.417531+00:00 2021-04-07T23:00:47.145592+00:00 0:00:01.728061 14718 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-07T23:00:43.192369+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-07T22:00:00+00:00 PythonOperator 2021-04-07T23:00:25.401283+00:00 2021-04-07T23:00:28.202873+00:00 0:00:02.801590 14717 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-07T23:00:23.085870+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-07T21:00:00+00:00 TriggerDagRunOperator 2021-04-07T22:09:11.643471+00:00 2021-04-07T22:09:12.193643+00:00 0:00:00.550172 14709 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T22:09:09.192921+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-07T21:00:00+00:00 TriggerDagRunOperator 2021-04-07T22:09:11.593429+00:00 2021-04-07T22:09:12.006216+00:00 0:00:00.412787 14708 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T22:09:09.192985+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-07T21:00:00+00:00 EmrJobFlowSensor 2021-04-07T22:01:01.041002+00:00 2021-04-07T22:09:03.843829+00:00 0:08:02.802827 14704 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T22:00:58.578737+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-07T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T22:00:38.979827+00:00 2021-04-07T22:00:40.686889+00:00 0:00:01.707062 14703 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-07T22:00:36.440828+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-07T21:00:00+00:00 PythonOperator 2021-04-07T22:00:19.137978+00:00 2021-04-07T22:00:21.913055+00:00 0:00:02.775077 14702 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-07T22:00:16.369494+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-07T20:00:00+00:00 TriggerDagRunOperator 2021-04-07T21:11:00.853827+00:00 2021-04-07T21:11:01.311484+00:00 0:00:00.457657 14694 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T21:10:58.072125+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-07T20:00:00+00:00 TriggerDagRunOperator 2021-04-07T21:11:00.714154+00:00 2021-04-07T21:11:01.264214+00:00 0:00:00.550060 14693 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T21:10:58.072091+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-07T20:00:00+00:00 EmrJobFlowSensor 2021-04-07T21:01:51.323155+00:00 2021-04-07T21:10:54.000808+00:00 0:09:02.677653 14689 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T21:01:49.112667+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-07T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T21:01:29.780138+00:00 2021-04-07T21:01:31.549016+00:00 0:00:01.768878 14688 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-07T21:01:27.159823+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-07T20:00:00+00:00 PythonOperator 2021-04-07T21:01:09.653983+00:00 2021-04-07T21:01:12.545536+00:00 0:00:02.891553 14687 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-07T21:01:07.084024+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-07T19:00:00+00:00 TriggerDagRunOperator 2021-04-07T20:10:16.677943+00:00 2021-04-07T20:10:17.257546+00:00 0:00:00.579603 14679 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T20:10:14.061865+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-07T19:00:00+00:00 TriggerDagRunOperator 2021-04-07T20:10:16.476226+00:00 2021-04-07T20:10:16.903857+00:00 0:00:00.427631 14678 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T20:10:14.061813+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-07T19:00:00+00:00 EmrJobFlowSensor 2021-04-07T20:00:59.515432+00:00 2021-04-07T20:10:02.155427+00:00 0:09:02.639995 14674 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T20:00:57.186833+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-07T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T20:00:39.655001+00:00 2021-04-07T20:00:41.466646+00:00 0:00:01.811645 14673 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-07T20:00:37.164904+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-07T19:00:00+00:00 PythonOperator 2021-04-07T20:00:15.552077+00:00 2021-04-07T20:00:18.300577+00:00 0:00:02.748500 14672 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-07T20:00:13.143100+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-07T18:00:00+00:00 TriggerDagRunOperator 2021-04-07T19:09:35.579268+00:00 2021-04-07T19:09:36.094768+00:00 0:00:00.515500 14664 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T19:09:33.144106+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-07T18:00:00+00:00 TriggerDagRunOperator 2021-04-07T19:09:35.412941+00:00 2021-04-07T19:09:35.859532+00:00 0:00:00.446591 14663 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T19:09:33.144076+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-07T18:00:00+00:00 EmrJobFlowSensor 2021-04-07T19:01:10.311730+00:00 2021-04-07T19:09:12.844726+00:00 0:08:02.532996 14659 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T19:01:08.159847+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-07T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T19:00:44.564817+00:00 2021-04-07T19:00:46.372692+00:00 0:00:01.807875 14658 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-07T19:00:42.133849+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-07T18:00:00+00:00 PythonOperator 2021-04-07T19:00:14.495989+00:00 2021-04-07T19:00:17.246514+00:00 0:00:02.750525 14657 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-07T19:00:12.109685+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-07T17:00:00+00:00 TriggerDagRunOperator 2021-04-07T18:10:08.255226+00:00 2021-04-07T18:10:08.819947+00:00 0:00:00.564721 14649 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T18:10:05.583622+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-07T17:00:00+00:00 TriggerDagRunOperator 2021-04-07T18:10:08.017473+00:00 2021-04-07T18:10:08.432552+00:00 0:00:00.415079 14648 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T18:10:05.583593+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-07T17:00:00+00:00 EmrJobFlowSensor 2021-04-07T18:00:55.225364+00:00 2021-04-07T18:09:58.156020+00:00 0:09:02.930656 14644 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T18:00:52.846194+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-07T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T18:00:35.159892+00:00 2021-04-07T18:00:36.882731+00:00 0:00:01.722839 14643 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-07T18:00:32.760426+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-07T17:00:00+00:00 PythonOperator 2021-04-07T18:00:12.964119+00:00 2021-04-07T18:00:15.830327+00:00 0:00:02.866208 14642 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-07T18:00:10.689911+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-07T16:00:00+00:00 TriggerDagRunOperator 2021-04-07T17:15:42.611632+00:00 2021-04-07T17:15:43.152671+00:00 0:00:00.541039 14635 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T17:15:40.099725+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-07T16:00:00+00:00 TriggerDagRunOperator 2021-04-07T17:15:42.530451+00:00 2021-04-07T17:15:42.957005+00:00 0:00:00.426554 14634 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T17:15:40.099696+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-07T16:00:00+00:00 EmrJobFlowSensor 2021-04-07T17:01:15.387521+00:00 2021-04-07T17:10:18.195064+00:00 0:09:02.807543 14629 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T17:01:13.129107+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-07T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T17:00:53.311450+00:00 2021-04-07T17:00:54.998270+00:00 0:00:01.686820 14628 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-07T17:00:51.086805+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-07T16:00:00+00:00 PythonOperator 2021-04-07T17:00:33.236605+00:00 2021-04-07T17:00:35.989833+00:00 0:00:02.753228 14627 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-07T17:00:31.006505+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-07T15:00:00+00:00 TriggerDagRunOperator 2021-04-07T16:32:48.881489+00:00 2021-04-07T16:32:49.412674+00:00 0:00:00.531185 14620 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T16:32:46.499940+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-07T15:00:00+00:00 TriggerDagRunOperator 2021-04-07T16:32:48.798089+00:00 2021-04-07T16:32:49.222243+00:00 0:00:00.424154 14619 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T16:32:46.499912+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-07T15:00:00+00:00 EmrJobFlowSensor 2021-04-07T16:11:10.696897+00:00 2021-04-07T16:32:14.954094+00:00 0:21:04.257197 14618 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T16:11:08.457687+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-07T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T16:10:48.796587+00:00 2021-04-07T16:10:50.611899+00:00 0:00:01.815312 14616 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-07T16:10:46.435981+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-07T15:00:00+00:00 PythonOperator 2021-04-07T16:10:24.621203+00:00 2021-04-07T16:10:27.318326+00:00 0:00:02.697123 14614 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-07T16:10:22.423724+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-07T14:00:00+00:00 TriggerDagRunOperator 2021-04-07T15:11:06.199579+00:00 2021-04-07T15:11:06.636861+00:00 0:00:00.437282 14605 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T15:11:03.656827+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-07T14:00:00+00:00 TriggerDagRunOperator 2021-04-07T15:11:06.227702+00:00 2021-04-07T15:11:06.791951+00:00 0:00:00.564249 14604 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T15:11:03.656874+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-07T14:00:00+00:00 EmrJobFlowSensor 2021-04-07T15:00:48.933780+00:00 2021-04-07T15:10:51.770513+00:00 0:10:02.836733 14600 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T15:00:46.736687+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-07T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T15:00:29.132317+00:00 2021-04-07T15:00:30.953273+00:00 0:00:01.820956 14599 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-07T15:00:26.717955+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-07T14:00:00+00:00 PythonOperator 2021-04-07T15:00:07.380463+00:00 2021-04-07T15:00:10.147688+00:00 0:00:02.767225 14598 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-07T15:00:04.618281+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-07T13:00:00+00:00 TriggerDagRunOperator 2021-04-07T14:09:12.591259+00:00 2021-04-07T14:09:13.111053+00:00 0:00:00.519794 14590 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T14:09:10.097047+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-07T13:00:00+00:00 TriggerDagRunOperator 2021-04-07T14:09:12.216785+00:00 2021-04-07T14:09:12.641799+00:00 0:00:00.425014 14589 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T14:09:10.097083+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-07T13:00:00+00:00 EmrJobFlowSensor 2021-04-07T14:01:01.659823+00:00 2021-04-07T14:09:04.324513+00:00 0:08:02.664690 14585 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T14:00:59.306114+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-07T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T14:00:39.467495+00:00 2021-04-07T14:00:41.144900+00:00 0:00:01.677405 14584 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-07T14:00:37.285103+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-07T13:00:00+00:00 PythonOperator 2021-04-07T14:00:20.214802+00:00 2021-04-07T14:00:22.994548+00:00 0:00:02.779746 14583 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-07T14:00:17.269005+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-07T12:00:00+00:00 TriggerDagRunOperator 2021-04-07T13:10:30.579222+00:00 2021-04-07T13:10:31.119525+00:00 0:00:00.540303 14575 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T13:10:27.842349+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-07T12:00:00+00:00 TriggerDagRunOperator 2021-04-07T13:10:30.451690+00:00 2021-04-07T13:10:30.881303+00:00 0:00:00.429613 14574 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T13:10:27.842401+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-07T12:00:00+00:00 EmrJobFlowSensor 2021-04-07T13:01:06.721244+00:00 2021-04-07T13:10:09.461024+00:00 0:09:02.739780 14570 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T13:01:04.360126+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-07T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T13:00:46.559979+00:00 2021-04-07T13:00:48.236713+00:00 0:00:01.676734 14569 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-07T13:00:44.294945+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-07T12:00:00+00:00 PythonOperator 2021-04-07T13:00:24.641491+00:00 2021-04-07T13:00:27.526956+00:00 0:00:02.885465 14568 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-07T13:00:22.233030+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-07T11:00:00+00:00 TriggerDagRunOperator 2021-04-07T12:11:20.350434+00:00 2021-04-07T12:11:20.879230+00:00 0:00:00.528796 14560 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T12:11:17.681929+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-07T11:00:00+00:00 TriggerDagRunOperator 2021-04-07T12:11:20.193644+00:00 2021-04-07T12:11:20.620359+00:00 0:00:00.426715 14559 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T12:11:17.681963+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-07T11:00:00+00:00 EmrJobFlowSensor 2021-04-07T12:01:03.140080+00:00 2021-04-07T12:11:05.984918+00:00 0:10:02.844838 14555 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T12:01:00.760605+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-07T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T12:00:40.997337+00:00 2021-04-07T12:00:42.800283+00:00 0:00:01.802946 14554 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-07T12:00:38.752297+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-07T11:00:00+00:00 PythonOperator 2021-04-07T12:00:21.022448+00:00 2021-04-07T12:00:23.938129+00:00 0:00:02.915681 14553 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-07T12:00:18.655083+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-07T10:00:00+00:00 TriggerDagRunOperator 2021-04-07T11:10:16.790766+00:00 2021-04-07T11:10:17.237405+00:00 0:00:00.446639 14545 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T11:10:14.019938+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-07T10:00:00+00:00 TriggerDagRunOperator 2021-04-07T11:10:16.349241+00:00 2021-04-07T11:10:16.944517+00:00 0:00:00.595276 14544 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T11:10:14.019980+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-07T10:00:00+00:00 EmrJobFlowSensor 2021-04-07T11:01:01.534633+00:00 2021-04-07T11:10:04.157757+00:00 0:09:02.623124 14540 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T11:00:58.870347+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-07T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T11:00:39.208831+00:00 2021-04-07T11:00:41.036319+00:00 0:00:01.827488 14539 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-07T11:00:36.759173+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-07T10:00:00+00:00 PythonOperator 2021-04-07T11:00:19.485326+00:00 2021-04-07T11:00:22.199323+00:00 0:00:02.713997 14538 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-07T11:00:16.658706+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-07T09:00:00+00:00 TriggerDagRunOperator 2021-04-07T10:10:33.450085+00:00 2021-04-07T10:10:33.985974+00:00 0:00:00.535889 14530 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T10:10:31.013003+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-07T09:00:00+00:00 TriggerDagRunOperator 2021-04-07T10:10:33.277697+00:00 2021-04-07T10:10:33.715910+00:00 0:00:00.438213 14529 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T10:10:31.013041+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-07T09:00:00+00:00 EmrJobFlowSensor 2021-04-07T10:01:06.139782+00:00 2021-04-07T10:10:08.856840+00:00 0:09:02.717058 14525 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T10:01:03.834476+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-07T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T10:00:44.083411+00:00 2021-04-07T10:00:45.766369+00:00 0:00:01.682958 14524 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-07T10:00:41.817968+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-07T09:00:00+00:00 PythonOperator 2021-04-07T10:00:22.105460+00:00 2021-04-07T10:00:24.850437+00:00 0:00:02.744977 14523 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-07T10:00:19.799146+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-07T08:00:00+00:00 TriggerDagRunOperator 2021-04-07T09:10:57.074067+00:00 2021-04-07T09:10:57.635311+00:00 0:00:00.561244 14515 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T09:10:54.719643+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-07T08:00:00+00:00 TriggerDagRunOperator 2021-04-07T09:10:57.035387+00:00 2021-04-07T09:10:57.437564+00:00 0:00:00.402177 14514 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T09:10:54.719608+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-07T08:00:00+00:00 EmrJobFlowSensor 2021-04-07T09:00:50.035268+00:00 2021-04-07T09:10:52.729833+00:00 0:10:02.694565 14510 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T09:00:47.733630+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-07T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T09:00:30.267206+00:00 2021-04-07T09:00:31.996537+00:00 0:00:01.729331 14509 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-07T09:00:27.764323+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-07T08:00:00+00:00 PythonOperator 2021-04-07T09:00:08.166449+00:00 2021-04-07T09:00:11.100132+00:00 0:00:02.933683 14508 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-07T09:00:05.693709+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-07T07:00:00+00:00 TriggerDagRunOperator 2021-04-07T08:10:08.195609+00:00 2021-04-07T08:10:08.625845+00:00 0:00:00.430236 14500 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T08:10:05.507896+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-07T07:00:00+00:00 TriggerDagRunOperator 2021-04-07T08:10:08.093626+00:00 2021-04-07T08:10:08.701149+00:00 0:00:00.607523 14499 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T08:10:05.507934+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-07T07:00:00+00:00 EmrJobFlowSensor 2021-04-07T08:00:54.825760+00:00 2021-04-07T08:09:57.496014+00:00 0:09:02.670254 14495 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T08:00:52.512250+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-07T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T08:00:28.745915+00:00 2021-04-07T08:00:30.394034+00:00 0:00:01.648119 14494 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-07T08:00:26.430877+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-07T07:00:00+00:00 PythonOperator 2021-04-07T08:00:06.727492+00:00 2021-04-07T08:00:09.580941+00:00 0:00:02.853449 14493 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-07T08:00:04.413277+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-07T06:00:00+00:00 TriggerDagRunOperator 2021-04-07T07:10:19.421021+00:00 2021-04-07T07:10:19.954052+00:00 0:00:00.533031 14485 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T07:10:16.981565+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-07T06:00:00+00:00 TriggerDagRunOperator 2021-04-07T07:10:19.274388+00:00 2021-04-07T07:10:19.746768+00:00 0:00:00.472380 14484 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T07:10:16.981533+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-07T06:00:00+00:00 EmrJobFlowSensor 2021-04-07T07:00:54.673548+00:00 2021-04-07T07:09:57.507966+00:00 0:09:02.834418 14480 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T07:00:52.130010+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-07T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T07:00:34.315744+00:00 2021-04-07T07:00:36.003966+00:00 0:00:01.688222 14479 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-07T07:00:32.112543+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-07T06:00:00+00:00 PythonOperator 2021-04-07T07:00:06.292336+00:00 2021-04-07T07:00:09.024982+00:00 0:00:02.732646 14478 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-07T07:00:04.086747+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-07T05:00:00+00:00 TriggerDagRunOperator 2021-04-07T06:13:39.931218+00:00 2021-04-07T06:13:40.459814+00:00 0:00:00.528596 14471 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T06:13:37.090180+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-07T05:00:00+00:00 TriggerDagRunOperator 2021-04-07T06:13:39.788061+00:00 2021-04-07T06:13:40.210419+00:00 0:00:00.422358 14470 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T06:13:37.090153+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-07T05:00:00+00:00 EmrJobFlowSensor 2021-04-07T06:01:12.360461+00:00 2021-04-07T06:10:15.153125+00:00 0:09:02.792664 14465 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T06:01:10.022996+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-07T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T06:00:44.479813+00:00 2021-04-07T06:00:46.289402+00:00 0:00:01.809589 14464 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-07T06:00:41.995372+00:00 2 default_pool