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-14T17:00:00+00:00 PythonOperator 2021-04-14T18:00:17.626346+00:00 2021-04-14T18:00:20.498299+00:00 0:00:02.871953 17176 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-14T18:00:15.419984+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-14T16:00:00+00:00 TriggerDagRunOperator 2021-04-14T17:11:25.120219+00:00 2021-04-14T17:11:25.554041+00:00 0:00:00.433822 17169 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T17:11:22.114376+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-14T16:00:00+00:00 TriggerDagRunOperator 2021-04-14T17:11:25.118552+00:00 2021-04-14T17:11:25.671480+00:00 0:00:00.552928 17168 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T17:11:22.114411+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-14T16:00:00+00:00 EmrJobFlowSensor 2021-04-14T17:01:05.411099+00:00 2021-04-14T17:09:07.883837+00:00 0:08:02.472738 17163 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T17:01:03.104351+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-14T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T17:00:39.584591+00:00 2021-04-14T17:00:41.605177+00:00 0:00:02.020586 17162 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-14T17:00:37.082810+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-14T16:00:00+00:00 PythonOperator 2021-04-14T17:00:11.241907+00:00 2021-04-14T17:00:14.211992+00:00 0:00:02.970085 17161 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-14T17:00:08.997882+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-14T15:00:00+00:00 TriggerDagRunOperator 2021-04-14T16:17:32.836595+00:00 2021-04-14T16:17:33.235576+00:00 0:00:00.398981 17154 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T16:17:30.473164+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-14T15:00:00+00:00 TriggerDagRunOperator 2021-04-14T16:17:32.831432+00:00 2021-04-14T16:17:33.369905+00:00 0:00:00.538473 17153 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T16:17:30.473138+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-14T15:00:00+00:00 EmrJobFlowSensor 2021-04-14T16:08:26.000458+00:00 2021-04-14T16:17:28.661151+00:00 0:09:02.660693 17152 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T16:08:23.557752+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-14T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T16:08:04.223606+00:00 2021-04-14T16:08:06.095109+00:00 0:00:01.871503 17150 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-14T16:08:01.487281+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-14T15:00:00+00:00 PythonOperator 2021-04-14T16:07:43.692033+00:00 2021-04-14T16:07:46.570259+00:00 0:00:02.878226 17148 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-14T16:07:41.469951+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-14T14:00:00+00:00 TriggerDagRunOperator 2021-04-14T15:10:55.780602+00:00 2021-04-14T15:10:56.827159+00:00 0:00:01.046557 17139 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T15:10:53.365626+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-14T14:00:00+00:00 TriggerDagRunOperator 2021-04-14T15:10:55.709460+00:00 2021-04-14T15:10:56.269655+00:00 0:00:00.560195 17138 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T15:10:53.365657+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-14T14:00:00+00:00 EmrJobFlowSensor 2021-04-14T15:00:48.951056+00:00 2021-04-14T15:10:51.829950+00:00 0:10:02.878894 17134 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T15:00:46.557542+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-14T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T15:00:29.052899+00:00 2021-04-14T15:00:31.091224+00:00 0:00:02.038325 17133 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-14T15:00:26.462842+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-14T14:00:00+00:00 PythonOperator 2021-04-14T15:00:06.588940+00:00 2021-04-14T15:00:09.514557+00:00 0:00:02.925617 17132 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-14T15:00:04.389112+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-14T13:00:00+00:00 TriggerDagRunOperator 2021-04-14T14:14:26.289048+00:00 2021-04-14T14:14:26.752243+00:00 0:00:00.463195 17123 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T14:14:23.665588+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-14T13:00:00+00:00 TriggerDagRunOperator 2021-04-14T14:14:26.319446+00:00 2021-04-14T14:14:26.887547+00:00 0:00:00.568101 17122 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T14:14:23.665554+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-14T13:00:00+00:00 EmrJobFlowSensor 2021-04-14T14:01:14.703121+00:00 2021-04-14T14:10:17.439504+00:00 0:09:02.736383 17117 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T14:01:12.394269+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-14T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T14:00:42.590723+00:00 2021-04-14T14:00:44.321868+00:00 0:00:01.731145 17116 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-14T14:00:40.343885+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-14T13:00:00+00:00 PythonOperator 2021-04-14T14:00:14.674168+00:00 2021-04-14T14:00:17.597375+00:00 0:00:02.923207 17115 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-14T14:00:12.322854+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-14T12:00:00+00:00 TriggerDagRunOperator 2021-04-14T13:10:59.310646+00:00 2021-04-14T13:10:59.743423+00:00 0:00:00.432777 17108 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T13:10:56.858116+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-14T12:00:00+00:00 TriggerDagRunOperator 2021-04-14T13:10:59.298818+00:00 2021-04-14T13:10:59.850448+00:00 0:00:00.551630 17107 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T13:10:56.858165+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-14T12:00:00+00:00 EmrJobFlowSensor 2021-04-14T13:00:49.304715+00:00 2021-04-14T13:10:52.113074+00:00 0:10:02.808359 17102 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T13:00:47.126272+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-14T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T13:00:27.399579+00:00 2021-04-14T13:00:29.122222+00:00 0:00:01.722643 17101 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-14T13:00:25.106062+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-14T12:00:00+00:00 PythonOperator 2021-04-14T13:00:05.500686+00:00 2021-04-14T13:00:08.383325+00:00 0:00:02.882639 17100 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-14T13:00:03.148311+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-14T11:00:00+00:00 TriggerDagRunOperator 2021-04-14T12:13:56.882581+00:00 2021-04-14T12:13:57.392253+00:00 0:00:00.509672 17093 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T12:13:54.504259+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-14T11:00:00+00:00 TriggerDagRunOperator 2021-04-14T12:13:56.765815+00:00 2021-04-14T12:13:57.161815+00:00 0:00:00.396000 17092 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T12:13:54.504231+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-14T11:00:00+00:00 EmrJobFlowSensor 2021-04-14T12:05:48.104502+00:00 2021-04-14T12:13:50.649654+00:00 0:08:02.545152 17091 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T12:05:45.719076+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-14T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T12:05:26.009231+00:00 2021-04-14T12:05:27.704241+00:00 0:00:01.695010 17088 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-14T12:05:23.705004+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-14T11:00:00+00:00 PythonOperator 2021-04-14T12:05:06.355265+00:00 2021-04-14T12:05:09.295712+00:00 0:00:02.940447 17087 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-14T12:05:03.466157+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-14T10:00:00+00:00 TriggerDagRunOperator 2021-04-14T11:09:16.779128+00:00 2021-04-14T11:09:17.271825+00:00 0:00:00.492697 17076 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T11:09:14.171591+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-14T10:00:00+00:00 TriggerDagRunOperator 2021-04-14T11:09:16.577985+00:00 2021-04-14T11:09:17.014668+00:00 0:00:00.436683 17075 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T11:09:14.171643+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-14T10:00:00+00:00 EmrJobFlowSensor 2021-04-14T11:00:47.658531+00:00 2021-04-14T11:08:50.188954+00:00 0:08:02.530423 17071 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T11:00:45.352466+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-14T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T11:00:26.065798+00:00 2021-04-14T11:00:27.932750+00:00 0:00:01.866952 17070 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-14T11:00:23.245641+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-14T10:00:00+00:00 PythonOperator 2021-04-14T11:00:05.904000+00:00 2021-04-14T11:00:08.851296+00:00 0:00:02.947296 17069 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-14T11:00:03.252883+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-14T09:00:00+00:00 TriggerDagRunOperator 2021-04-14T10:10:17.043921+00:00 2021-04-14T10:10:17.459757+00:00 0:00:00.415836 17061 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T10:10:14.747172+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-14T09:00:00+00:00 TriggerDagRunOperator 2021-04-14T10:10:17.045052+00:00 2021-04-14T10:10:17.576085+00:00 0:00:00.531033 17060 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T10:10:14.747204+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-14T09:00:00+00:00 EmrJobFlowSensor 2021-04-14T10:01:04.727137+00:00 2021-04-14T10:10:07.489182+00:00 0:09:02.762045 17056 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T10:01:02.162825+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-14T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T10:00:42.406216+00:00 2021-04-14T10:00:44.129674+00:00 0:00:01.723458 17055 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-14T10:00:40.159372+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-14T09:00:00+00:00 PythonOperator 2021-04-14T10:00:22.401709+00:00 2021-04-14T10:00:25.450583+00:00 0:00:03.048874 17054 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-14T10:00:20.076066+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-14T08:00:00+00:00 TriggerDagRunOperator 2021-04-14T09:10:20.223711+00:00 2021-04-14T09:10:20.741104+00:00 0:00:00.517393 17046 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T09:10:17.688280+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-14T08:00:00+00:00 TriggerDagRunOperator 2021-04-14T09:10:20.137682+00:00 2021-04-14T09:10:20.535664+00:00 0:00:00.397982 17045 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T09:10:17.688315+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-14T08:00:00+00:00 EmrJobFlowSensor 2021-04-14T09:01:04.915466+00:00 2021-04-14T09:10:07.797851+00:00 0:09:02.882385 17041 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T09:01:02.393928+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-14T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T09:00:36.600208+00:00 2021-04-14T09:00:38.313475+00:00 0:00:01.713267 17040 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-14T09:00:34.363361+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-14T08:00:00+00:00 PythonOperator 2021-04-14T09:00:12.598324+00:00 2021-04-14T09:00:15.571225+00:00 0:00:02.972901 17039 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-14T09:00:10.321533+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-14T07:00:00+00:00 TriggerDagRunOperator 2021-04-14T08:11:25.133895+00:00 2021-04-14T08:11:25.666803+00:00 0:00:00.532908 17031 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T08:11:22.569795+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-14T07:00:00+00:00 TriggerDagRunOperator 2021-04-14T08:11:25.086223+00:00 2021-04-14T08:11:25.478367+00:00 0:00:00.392144 17030 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T08:11:22.569750+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-14T07:00:00+00:00 EmrJobFlowSensor 2021-04-14T08:00:58.447874+00:00 2021-04-14T08:11:01.332732+00:00 0:10:02.884858 17026 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T08:00:55.766884+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-14T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T08:00:37.947190+00:00 2021-04-14T08:00:39.606648+00:00 0:00:01.659458 17025 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-14T08:00:35.699292+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-14T07:00:00+00:00 PythonOperator 2021-04-14T08:00:16.485455+00:00 2021-04-14T08:00:19.488721+00:00 0:00:03.003266 17024 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-14T08:00:13.614318+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-14T06:00:00+00:00 TriggerDagRunOperator 2021-04-14T07:10:13.167881+00:00 2021-04-14T07:10:13.572774+00:00 0:00:00.404893 17016 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T07:10:10.692585+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-14T06:00:00+00:00 TriggerDagRunOperator 2021-04-14T07:10:13.208919+00:00 2021-04-14T07:10:13.754706+00:00 0:00:00.545787 17015 airflow-worker-2.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T07:10:10.692620+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-14T06:00:00+00:00 EmrJobFlowSensor 2021-04-14T07:01:02.326426+00:00 2021-04-14T07:10:05.090732+00:00 0:09:02.764306 17011 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T07:00:59.944349+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-14T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T07:00:40.098775+00:00 2021-04-14T07:00:41.912783+00:00 0:00:01.814008 17010 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-14T07:00:37.829734+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-14T06:00:00+00:00 PythonOperator 2021-04-14T07:00:20.586821+00:00 2021-04-14T07:00:23.446956+00:00 0:00:02.860135 17009 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-14T07:00:17.813187+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-14T05:00:00+00:00 TriggerDagRunOperator 2021-04-14T06:11:25.151159+00:00 2021-04-14T06:11:25.559668+00:00 0:00:00.408509 17001 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T06:11:22.776370+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-14T05:00:00+00:00 TriggerDagRunOperator 2021-04-14T06:11:25.118866+00:00 2021-04-14T06:11:25.677406+00:00 0:00:00.558540 17000 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T06:11:22.776403+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-14T05:00:00+00:00 EmrJobFlowSensor 2021-04-14T06:01:04.435622+00:00 2021-04-14T06:11:07.498167+00:00 0:10:03.062545 16996 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T06:01:02.006839+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-14T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T06:00:40.240479+00:00 2021-04-14T06:00:41.965756+00:00 0:00:01.725277 16995 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-14T06:00:38.044397+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-14T05:00:00+00:00 PythonOperator 2021-04-14T06:00:20.460677+00:00 2021-04-14T06:00:23.373024+00:00 0:00:02.912347 16994 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-14T06:00:17.930326+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-14T04:00:00+00:00 TriggerDagRunOperator 2021-04-14T05:11:04.186794+00:00 2021-04-14T05:11:04.832715+00:00 0:00:00.645921 16986 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T05:11:01.596446+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-14T04:00:00+00:00 TriggerDagRunOperator 2021-04-14T05:11:04.032087+00:00 2021-04-14T05:11:04.776484+00:00 0:00:00.744397 16985 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T05:11:01.596413+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-14T04:00:00+00:00 EmrJobFlowSensor 2021-04-14T05:00:55.155211+00:00 2021-04-14T05:10:57.827618+00:00 0:10:02.672407 16981 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T05:00:52.375940+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-14T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T05:00:34.715218+00:00 2021-04-14T05:00:36.485115+00:00 0:00:01.769897 16980 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-14T05:00:32.359514+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-14T04:00:00+00:00 PythonOperator 2021-04-14T05:00:11.146946+00:00 2021-04-14T05:00:14.113584+00:00 0:00:02.966638 16979 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-14T05:00:08.351122+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-14T03:00:00+00:00 TriggerDagRunOperator 2021-04-14T04:09:07.075434+00:00 2021-04-14T04:09:07.588575+00:00 0:00:00.513141 16971 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T04:09:04.740145+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-14T03:00:00+00:00 TriggerDagRunOperator 2021-04-14T04:09:06.989093+00:00 2021-04-14T04:09:07.397107+00:00 0:00:00.408014 16970 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T04:09:04.740177+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-14T03:00:00+00:00 EmrJobFlowSensor 2021-04-14T04:00:56.048588+00:00 2021-04-14T04:08:58.656540+00:00 0:08:02.607952 16966 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T04:00:53.653016+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-14T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T04:00:33.952338+00:00 2021-04-14T04:00:35.813962+00:00 0:00:01.861624 16965 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-14T04:00:31.583898+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-14T03:00:00+00:00 PythonOperator 2021-04-14T04:00:11.845225+00:00 2021-04-14T04:00:14.692892+00:00 0:00:02.847667 16964 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-14T04:00:09.526290+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-14T02:00:00+00:00 TriggerDagRunOperator 2021-04-14T03:10:04.856757+00:00 2021-04-14T03:10:05.426984+00:00 0:00:00.570227 16956 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T03:10:01.937553+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-14T02:00:00+00:00 TriggerDagRunOperator 2021-04-14T03:10:04.217827+00:00 2021-04-14T03:10:04.749965+00:00 0:00:00.532138 16955 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T03:10:01.937514+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-14T02:00:00+00:00 EmrJobFlowSensor 2021-04-14T03:00:49.725244+00:00 2021-04-14T03:09:52.602496+00:00 0:09:02.877252 16951 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T03:00:47.221521+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-14T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T03:00:27.438044+00:00 2021-04-14T03:00:29.135733+00:00 0:00:01.697689 16950 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-14T03:00:25.202658+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-14T02:00:00+00:00 PythonOperator 2021-04-14T03:00:06.079865+00:00 2021-04-14T03:00:09.831797+00:00 0:00:03.751932 16949 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-14T03:00:03.244137+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-14T01:00:00+00:00 TriggerDagRunOperator 2021-04-14T02:11:27.852940+00:00 2021-04-14T02:11:28.266475+00:00 0:00:00.413535 16941 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T02:11:25.448457+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-14T01:00:00+00:00 TriggerDagRunOperator 2021-04-14T02:11:27.876739+00:00 2021-04-14T02:11:28.447568+00:00 0:00:00.570829 16940 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T02:11:25.448493+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-14T01:00:00+00:00 EmrJobFlowSensor 2021-04-14T02:01:02.753519+00:00 2021-04-14T02:11:05.469823+00:00 0:10:02.716304 16936 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T02:01:00.287224+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-14T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T02:00:40.501979+00:00 2021-04-14T02:00:42.170076+00:00 0:00:01.668097 16935 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-14T02:00:38.272169+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-14T01:00:00+00:00 PythonOperator 2021-04-14T02:00:19.034455+00:00 2021-04-14T02:00:21.952745+00:00 0:00:02.918290 16934 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-14T02:00:16.056202+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-14T00:00:00+00:00 TriggerDagRunOperator 2021-04-14T01:10:12.238755+00:00 2021-04-14T01:10:12.693998+00:00 0:00:00.455243 16926 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T01:10:09.977438+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-14T00:00:00+00:00 TriggerDagRunOperator 2021-04-14T01:10:12.246265+00:00 2021-04-14T01:10:12.838764+00:00 0:00:00.592499 16925 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T01:10:09.977475+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-14T00:00:00+00:00 EmrJobFlowSensor 2021-04-14T01:00:57.092640+00:00 2021-04-14T01:09:59.744687+00:00 0:09:02.652047 16921 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T01:00:54.831344+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-14T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T01:00:35.330981+00:00 2021-04-14T01:00:37.057220+00:00 0:00:01.726239 16920 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-14T01:00:32.817151+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-14T00:00:00+00:00 PythonOperator 2021-04-14T01:00:13.210663+00:00 2021-04-14T01:00:16.081806+00:00 0:00:02.871143 16919 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-14T01:00:10.799090+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-13T23:00:00+00:00 TriggerDagRunOperator 2021-04-14T00:10:01.262776+00:00 2021-04-14T00:10:01.753726+00:00 0:00:00.490950 16911 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T00:09:58.872898+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-13T23:00:00+00:00 TriggerDagRunOperator 2021-04-14T00:10:01.275422+00:00 2021-04-14T00:10:01.851106+00:00 0:00:00.575684 16910 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T00:09:58.872942+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-13T23:00:00+00:00 EmrJobFlowSensor 2021-04-14T00:00:54.294215+00:00 2021-04-14T00:09:56.944592+00:00 0:09:02.650377 16906 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T00:00:52.027064+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-13T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T00:00:32.464013+00:00 2021-04-14T00:00:34.166690+00:00 0:00:01.702677 16905 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-14T00:00:30.052747+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-13T23:00:00+00:00 PythonOperator 2021-04-14T00:00:10.609626+00:00 2021-04-14T00:00:13.631506+00:00 0:00:03.021880 16904 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-14T00:00:08.056104+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-13T22:00:00+00:00 TriggerDagRunOperator 2021-04-13T23:10:26.515952+00:00 2021-04-13T23:10:27.053542+00:00 0:00:00.537590 16896 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T23:10:24.235919+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-13T22:00:00+00:00 TriggerDagRunOperator 2021-04-13T23:10:26.395595+00:00 2021-04-13T23:10:26.886533+00:00 0:00:00.490938 16895 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T23:10:24.235955+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-13T22:00:00+00:00 EmrJobFlowSensor 2021-04-13T23:01:07.846014+00:00 2021-04-13T23:10:10.610914+00:00 0:09:02.764900 16891 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T23:01:05.451019+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-13T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T23:00:45.825380+00:00 2021-04-13T23:00:47.505018+00:00 0:00:01.679638 16890 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-13T23:00:43.351327+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-13T22:00:00+00:00 PythonOperator 2021-04-13T23:00:25.490130+00:00 2021-04-13T23:00:28.338726+00:00 0:00:02.848596 16889 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-13T23:00:23.260151+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-13T21:00:00+00:00 TriggerDagRunOperator 2021-04-13T22:11:15.086856+00:00 2021-04-13T22:11:15.602203+00:00 0:00:00.515347 16881 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T22:11:12.562325+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-13T21:00:00+00:00 TriggerDagRunOperator 2021-04-13T22:11:14.995843+00:00 2021-04-13T22:11:15.432096+00:00 0:00:00.436253 16880 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T22:11:12.562369+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-13T21:00:00+00:00 EmrJobFlowSensor 2021-04-13T22:00:59.992377+00:00 2021-04-13T22:11:02.983021+00:00 0:10:02.990644 16876 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T22:00:57.449848+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-13T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T22:00:39.865513+00:00 2021-04-13T22:00:41.651732+00:00 0:00:01.786219 16875 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-13T22:00:37.387530+00:00 2 default_pool