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-15T13:00:00+00:00 PythonOperator 2021-05-15T14:00:08.417805+00:00 2021-05-15T14:00:11.562661+00:00 0:00:03.144856 28378 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-15T14:00:05.547106+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-15T12:00:00+00:00 TriggerDagRunOperator 2021-05-15T13:10:32.447535+00:00 2021-05-15T13:10:32.953460+00:00 0:00:00.505925 28370 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T13:10:29.864142+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-15T12:00:00+00:00 TriggerDagRunOperator 2021-05-15T13:10:32.163984+00:00 2021-05-15T13:10:32.636295+00:00 0:00:00.472311 28369 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T13:10:29.864094+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-15T12:00:00+00:00 EmrJobFlowSensor 2021-05-15T13:01:06.830439+00:00 2021-05-15T13:10:09.553631+00:00 0:09:02.723192 28365 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T13:01:04.744456+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-15T12:00:00+00:00 EmrCreateJobFlowOperator 2021-05-15T13:00:30.994131+00:00 2021-05-15T13:00:32.718235+00:00 0:00:01.724104 28364 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-15T13:00:28.722725+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-15T12:00:00+00:00 PythonOperator 2021-05-15T13:00:09.195458+00:00 2021-05-15T13:00:12.309882+00:00 0:00:03.114424 28363 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-15T13:00:06.743647+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-15T11:00:00+00:00 TriggerDagRunOperator 2021-05-15T12:10:05.296135+00:00 2021-05-15T12:10:05.720034+00:00 0:00:00.423899 28355 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T12:10:02.699594+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-15T11:00:00+00:00 TriggerDagRunOperator 2021-05-15T12:10:05.280065+00:00 2021-05-15T12:10:05.819900+00:00 0:00:00.539835 28354 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T12:10:02.699642+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-15T11:00:00+00:00 EmrJobFlowSensor 2021-05-15T12:00:53.790398+00:00 2021-05-15T12:09:56.560458+00:00 0:09:02.770060 28350 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T12:00:51.661525+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-15T11:00:00+00:00 EmrCreateJobFlowOperator 2021-05-15T12:00:25.787361+00:00 2021-05-15T12:00:27.490370+00:00 0:00:01.703009 28349 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-15T12:00:23.636302+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-15T11:00:00+00:00 PythonOperator 2021-05-15T12:00:04.345701+00:00 2021-05-15T12:00:07.515763+00:00 0:00:03.170062 28348 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-15T12:00:01.748584+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-15T10:00:00+00:00 TriggerDagRunOperator 2021-05-15T11:09:12.059534+00:00 2021-05-15T11:09:12.630171+00:00 0:00:00.570637 28340 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T11:09:09.784446+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-15T10:00:00+00:00 TriggerDagRunOperator 2021-05-15T11:09:11.916411+00:00 2021-05-15T11:09:12.345578+00:00 0:00:00.429167 28339 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T11:09:09.784480+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-15T10:00:00+00:00 EmrJobFlowSensor 2021-05-15T11:00:49.232894+00:00 2021-05-15T11:08:51.739985+00:00 0:08:02.507091 28335 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T11:00:46.956735+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-15T10:00:00+00:00 EmrCreateJobFlowOperator 2021-05-15T11:00:27.012460+00:00 2021-05-15T11:00:28.926505+00:00 0:00:01.914045 28334 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-15T11:00:24.789377+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-15T10:00:00+00:00 PythonOperator 2021-05-15T11:00:07.142463+00:00 2021-05-15T11:00:10.285900+00:00 0:00:03.143437 28333 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-15T11:00:04.744565+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-15T09:00:00+00:00 TriggerDagRunOperator 2021-05-15T10:11:09.745200+00:00 2021-05-15T10:11:10.302038+00:00 0:00:00.556838 28325 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T10:11:07.154941+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-15T09:00:00+00:00 TriggerDagRunOperator 2021-05-15T10:11:09.572847+00:00 2021-05-15T10:11:09.975185+00:00 0:00:00.402338 28324 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T10:11:07.154972+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-15T09:00:00+00:00 EmrJobFlowSensor 2021-05-15T10:00:56.606695+00:00 2021-05-15T10:10:59.660589+00:00 0:10:03.053894 28320 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T10:00:54.165688+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-15T09:00:00+00:00 EmrCreateJobFlowOperator 2021-05-15T10:00:36.441355+00:00 2021-05-15T10:00:38.262070+00:00 0:00:01.820715 28319 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-15T10:00:34.093033+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-15T09:00:00+00:00 PythonOperator 2021-05-15T10:00:12.550518+00:00 2021-05-15T10:00:15.667961+00:00 0:00:03.117443 28318 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-15T10:00:10.029214+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-15T08:00:00+00:00 TriggerDagRunOperator 2021-05-15T09:10:03.933693+00:00 2021-05-15T09:10:04.449840+00:00 0:00:00.516147 28310 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T09:10:01.424702+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-15T08:00:00+00:00 TriggerDagRunOperator 2021-05-15T09:10:03.678530+00:00 2021-05-15T09:10:04.139598+00:00 0:00:00.461068 28309 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T09:10:01.424734+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-15T08:00:00+00:00 EmrJobFlowSensor 2021-05-15T09:00:48.493541+00:00 2021-05-15T09:09:51.197116+00:00 0:09:02.703575 28305 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T09:00:46.398342+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-15T08:00:00+00:00 EmrCreateJobFlowOperator 2021-05-15T09:00:28.487035+00:00 2021-05-15T09:00:30.256567+00:00 0:00:01.769532 28304 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-15T09:00:26.367903+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-15T08:00:00+00:00 PythonOperator 2021-05-15T09:00:06.580854+00:00 2021-05-15T09:00:09.738217+00:00 0:00:03.157363 28303 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-15T09:00:04.335467+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-15T07:00:00+00:00 TriggerDagRunOperator 2021-05-15T08:11:28.275202+00:00 2021-05-15T08:11:28.729622+00:00 0:00:00.454420 28295 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T08:11:25.719415+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-15T07:00:00+00:00 TriggerDagRunOperator 2021-05-15T08:11:28.054340+00:00 2021-05-15T08:11:28.621692+00:00 0:00:00.567352 28294 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T08:11:25.719380+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-15T07:00:00+00:00 EmrJobFlowSensor 2021-05-15T08:01:06.610458+00:00 2021-05-15T08:11:09.428882+00:00 0:10:02.818424 28290 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T08:01:04.513869+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-15T07:00:00+00:00 EmrCreateJobFlowOperator 2021-05-15T08:00:46.778819+00:00 2021-05-15T08:00:48.644685+00:00 0:00:01.865866 28289 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-15T08:00:44.496941+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-15T07:00:00+00:00 PythonOperator 2021-05-15T08:00:24.872455+00:00 2021-05-15T08:00:27.998110+00:00 0:00:03.125655 28288 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-15T08:00:22.459394+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-15T06:00:00+00:00 TriggerDagRunOperator 2021-05-15T07:10:18.949117+00:00 2021-05-15T07:10:19.487318+00:00 0:00:00.538201 28280 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T07:10:16.524087+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-15T06:00:00+00:00 TriggerDagRunOperator 2021-05-15T07:10:18.760117+00:00 2021-05-15T07:10:19.171574+00:00 0:00:00.411457 28279 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T07:10:16.524053+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-15T06:00:00+00:00 EmrJobFlowSensor 2021-05-15T07:01:01.964097+00:00 2021-05-15T07:10:04.861724+00:00 0:09:02.897627 28275 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T07:00:59.742108+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-15T06:00:00+00:00 EmrCreateJobFlowOperator 2021-05-15T07:00:39.777082+00:00 2021-05-15T07:00:41.533169+00:00 0:00:01.756087 28274 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-15T07:00:37.662142+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-15T06:00:00+00:00 PythonOperator 2021-05-15T07:00:20.444068+00:00 2021-05-15T07:00:23.540583+00:00 0:00:03.096515 28273 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-15T07:00:17.620762+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-15T05:00:00+00:00 TriggerDagRunOperator 2021-05-15T06:11:08.411759+00:00 2021-05-15T06:11:09.005170+00:00 0:00:00.593411 28265 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T06:11:06.028855+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-15T05:00:00+00:00 TriggerDagRunOperator 2021-05-15T06:11:08.338986+00:00 2021-05-15T06:11:08.797656+00:00 0:00:00.458670 28264 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T06:11:06.028821+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-15T05:00:00+00:00 EmrJobFlowSensor 2021-05-15T06:00:49.812415+00:00 2021-05-15T06:10:52.775783+00:00 0:10:02.963368 28260 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T06:00:47.278399+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-15T05:00:00+00:00 EmrCreateJobFlowOperator 2021-05-15T06:00:29.597968+00:00 2021-05-15T06:00:31.433218+00:00 0:00:01.835250 28259 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-15T06:00:27.203196+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-15T05:00:00+00:00 PythonOperator 2021-05-15T06:00:07.607191+00:00 2021-05-15T06:00:10.712574+00:00 0:00:03.105383 28258 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-15T06:00:05.181716+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-15T04:00:00+00:00 TriggerDagRunOperator 2021-05-15T05:11:07.404589+00:00 2021-05-15T05:11:07.916329+00:00 0:00:00.511740 28250 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T05:11:05.087098+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-15T04:00:00+00:00 TriggerDagRunOperator 2021-05-15T05:11:07.245533+00:00 2021-05-15T05:11:07.650719+00:00 0:00:00.405186 28249 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T05:11:05.087068+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-15T04:00:00+00:00 EmrJobFlowSensor 2021-05-15T05:00:54.114525+00:00 2021-05-15T05:10:56.885581+00:00 0:10:02.771056 28245 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T05:00:51.911619+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-15T04:00:00+00:00 EmrCreateJobFlowOperator 2021-05-15T05:00:32.352917+00:00 2021-05-15T05:00:34.060881+00:00 0:00:01.707964 28244 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-15T05:00:30.041121+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-15T04:00:00+00:00 PythonOperator 2021-05-15T05:00:10.537021+00:00 2021-05-15T05:00:13.641514+00:00 0:00:03.104493 28243 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-15T05:00:07.872738+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-15T03:00:00+00:00 TriggerDagRunOperator 2021-05-15T04:11:25.967240+00:00 2021-05-15T04:11:26.703357+00:00 0:00:00.736117 28235 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T04:11:23.499923+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-15T03:00:00+00:00 TriggerDagRunOperator 2021-05-15T04:11:25.867638+00:00 2021-05-15T04:11:26.350485+00:00 0:00:00.482847 28234 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T04:11:23.499957+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-15T03:00:00+00:00 EmrJobFlowSensor 2021-05-15T04:00:57.701080+00:00 2021-05-15T04:11:00.476573+00:00 0:10:02.775493 28230 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T04:00:55.540831+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-15T03:00:00+00:00 EmrCreateJobFlowOperator 2021-05-15T04:00:37.731428+00:00 2021-05-15T04:00:39.415312+00:00 0:00:01.683884 28229 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-15T04:00:35.391328+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-15T03:00:00+00:00 PythonOperator 2021-05-15T04:00:15.598140+00:00 2021-05-15T04:00:18.733251+00:00 0:00:03.135111 28228 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-15T04:00:13.318941+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-15T02:00:00+00:00 TriggerDagRunOperator 2021-05-15T03:09:19.159636+00:00 2021-05-15T03:09:19.687325+00:00 0:00:00.527689 28220 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T03:09:16.676300+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-15T02:00:00+00:00 TriggerDagRunOperator 2021-05-15T03:09:18.874882+00:00 2021-05-15T03:09:19.318049+00:00 0:00:00.443167 28219 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T03:09:16.676266+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-15T02:00:00+00:00 EmrJobFlowSensor 2021-05-15T03:01:05.941635+00:00 2021-05-15T03:09:08.648543+00:00 0:08:02.706908 28215 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T03:01:03.584395+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-15T02:00:00+00:00 EmrCreateJobFlowOperator 2021-05-15T03:00:44.523221+00:00 2021-05-15T03:00:46.342927+00:00 0:00:01.819706 28214 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-15T03:00:41.565349+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-15T02:00:00+00:00 PythonOperator 2021-05-15T03:00:21.566916+00:00 2021-05-15T03:00:24.745419+00:00 0:00:03.178503 28213 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-15T03:00:19.385396+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-15T01:00:00+00:00 TriggerDagRunOperator 2021-05-15T02:11:04.142064+00:00 2021-05-15T02:11:04.686369+00:00 0:00:00.544305 28205 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T02:11:01.538321+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-15T01:00:00+00:00 TriggerDagRunOperator 2021-05-15T02:11:04.115698+00:00 2021-05-15T02:11:04.533184+00:00 0:00:00.417486 28204 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T02:11:01.538353+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-15T01:00:00+00:00 EmrJobFlowSensor 2021-05-15T02:00:46.070979+00:00 2021-05-15T02:10:48.929614+00:00 0:10:02.858635 28200 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T02:00:44.001779+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-15T01:00:00+00:00 EmrCreateJobFlowOperator 2021-05-15T02:00:26.141005+00:00 2021-05-15T02:00:27.926658+00:00 0:00:01.785653 28199 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-15T02:00:23.990776+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-15T01:00:00+00:00 PythonOperator 2021-05-15T02:00:04.353126+00:00 2021-05-15T02:00:07.458248+00:00 0:00:03.105122 28198 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-15T02:00:01.962759+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-15T00:00:00+00:00 TriggerDagRunOperator 2021-05-15T01:11:04.437041+00:00 2021-05-15T01:11:04.960666+00:00 0:00:00.523625 28190 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T01:11:01.996735+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-15T00:00:00+00:00 TriggerDagRunOperator 2021-05-15T01:11:04.215153+00:00 2021-05-15T01:11:04.636468+00:00 0:00:00.421315 28189 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T01:11:01.996704+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-15T00:00:00+00:00 EmrJobFlowSensor 2021-05-15T01:00:55.021106+00:00 2021-05-15T01:10:58.055565+00:00 0:10:03.034459 28185 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T01:00:52.717634+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-15T00:00:00+00:00 EmrCreateJobFlowOperator 2021-05-15T01:00:35.058557+00:00 2021-05-15T01:00:36.861619+00:00 0:00:01.803062 28184 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-15T01:00:32.704112+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-15T00:00:00+00:00 PythonOperator 2021-05-15T01:00:11.075619+00:00 2021-05-15T01:00:14.398425+00:00 0:00:03.322806 28183 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-15T01:00:08.766673+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-14T23:00:00+00:00 TriggerDagRunOperator 2021-05-15T00:12:38.800075+00:00 2021-05-15T00:12:39.327213+00:00 0:00:00.527138 28176 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T00:12:35.697643+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-14T23:00:00+00:00 TriggerDagRunOperator 2021-05-15T00:12:38.642157+00:00 2021-05-15T00:12:39.066308+00:00 0:00:00.424151 28175 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T00:12:35.697698+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-14T23:00:00+00:00 EmrJobFlowSensor 2021-05-15T00:01:06.921922+00:00 2021-05-15T00:11:09.791869+00:00 0:10:02.869947 28170 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T00:01:04.556490+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-14T23:00:00+00:00 EmrCreateJobFlowOperator 2021-05-15T00:00:46.644702+00:00 2021-05-15T00:00:48.491729+00:00 0:00:01.847027 28169 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-15T00:00:44.425428+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-14T23:00:00+00:00 PythonOperator 2021-05-15T00:00:25.123729+00:00 2021-05-15T00:00:28.337424+00:00 0:00:03.213695 28168 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-15T00:00:22.468773+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-14T22:00:00+00:00 TriggerDagRunOperator 2021-05-14T23:10:34.611720+00:00 2021-05-14T23:10:35.121278+00:00 0:00:00.509558 28161 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T23:10:32.144497+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-14T22:00:00+00:00 TriggerDagRunOperator 2021-05-14T23:10:34.429891+00:00 2021-05-14T23:10:34.842439+00:00 0:00:00.412548 28160 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T23:10:32.144447+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-14T22:00:00+00:00 EmrJobFlowSensor 2021-05-14T23:01:07.327010+00:00 2021-05-14T23:10:10.179507+00:00 0:09:02.852497 28155 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T23:01:05.040229+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-14T22:00:00+00:00 EmrCreateJobFlowOperator 2021-05-14T23:00:43.015678+00:00 2021-05-14T23:00:44.712813+00:00 0:00:01.697135 28153 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-14T23:00:40.890620+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-14T22:00:00+00:00 PythonOperator 2021-05-14T23:00:20.968349+00:00 2021-05-14T23:00:24.179719+00:00 0:00:03.211370 28151 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-14T23:00:18.817277+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-14T21:00:00+00:00 TriggerDagRunOperator 2021-05-14T22:11:19.715145+00:00 2021-05-14T22:11:20.250787+00:00 0:00:00.535642 28143 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T22:11:16.953711+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-14T21:00:00+00:00 TriggerDagRunOperator 2021-05-14T22:11:19.436354+00:00 2021-05-14T22:11:19.829377+00:00 0:00:00.393023 28142 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T22:11:16.953740+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-14T21:00:00+00:00 EmrJobFlowSensor 2021-05-14T22:01:06.751381+00:00 2021-05-14T22:11:09.672499+00:00 0:10:02.921118 28137 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T22:01:04.522216+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-14T21:00:00+00:00 EmrCreateJobFlowOperator 2021-05-14T22:00:46.773100+00:00 2021-05-14T22:00:48.563571+00:00 0:00:01.790471 28136 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-14T22:00:44.502398+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-14T21:00:00+00:00 PythonOperator 2021-05-14T22:00:24.825826+00:00 2021-05-14T22:00:27.918442+00:00 0:00:03.092616 28135 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-14T22:00:22.456907+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-14T20:00:00+00:00 TriggerDagRunOperator 2021-05-14T21:09:10.445825+00:00 2021-05-14T21:09:10.974554+00:00 0:00:00.528729 28128 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T21:09:07.763341+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-14T20:00:00+00:00 TriggerDagRunOperator 2021-05-14T21:09:10.099044+00:00 2021-05-14T21:09:10.524107+00:00 0:00:00.425063 28127 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T21:09:07.763370+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-14T20:00:00+00:00 EmrJobFlowSensor 2021-05-14T21:00:47.415865+00:00 2021-05-14T21:08:49.963941+00:00 0:08:02.548076 28122 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T21:00:45.164466+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-14T20:00:00+00:00 EmrCreateJobFlowOperator 2021-05-14T21:00:25.308360+00:00 2021-05-14T21:00:27.135456+00:00 0:00:01.827096 28121 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-14T21:00:23.007541+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-14T20:00:00+00:00 PythonOperator 2021-05-14T21:00:05.238437+00:00 2021-05-14T21:00:08.423182+00:00 0:00:03.184745 28120 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-14T21:00:02.986024+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-14T19:00:00+00:00 TriggerDagRunOperator 2021-05-14T20:10:16.151736+00:00 2021-05-14T20:10:16.693315+00:00 0:00:00.541579 28113 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T20:10:13.830072+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-14T19:00:00+00:00 TriggerDagRunOperator 2021-05-14T20:10:15.981459+00:00 2021-05-14T20:10:16.418276+00:00 0:00:00.436817 28112 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T20:10:13.830043+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-14T19:00:00+00:00 EmrJobFlowSensor 2021-05-14T20:00:53.493029+00:00 2021-05-14T20:09:56.141176+00:00 0:09:02.648147 28107 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T20:00:51.312483+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-14T19:00:00+00:00 EmrCreateJobFlowOperator 2021-05-14T20:00:33.413851+00:00 2021-05-14T20:00:35.141867+00:00 0:00:01.728016 28106 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-14T20:00:31.291167+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-14T19:00:00+00:00 PythonOperator 2021-05-14T20:00:11.445306+00:00 2021-05-14T20:00:14.588772+00:00 0:00:03.143466 28105 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-14T20:00:09.188780+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-14T18:00:00+00:00 TriggerDagRunOperator 2021-05-14T19:09:23.173208+00:00 2021-05-14T19:09:23.741237+00:00 0:00:00.568029 28098 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T19:09:20.444454+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-14T18:00:00+00:00 TriggerDagRunOperator 2021-05-14T19:09:22.985055+00:00 2021-05-14T19:09:23.415499+00:00 0:00:00.430444 28097 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T19:09:20.444501+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-14T18:00:00+00:00 EmrJobFlowSensor 2021-05-14T19:01:07.527492+00:00 2021-05-14T19:09:10.076182+00:00 0:08:02.548690 28092 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T19:01:05.145263+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-14T18:00:00+00:00 EmrCreateJobFlowOperator 2021-05-14T19:00:45.385726+00:00 2021-05-14T19:00:47.076125+00:00 0:00:01.690399 28091 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-14T19:00:43.056186+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-14T18:00:00+00:00 PythonOperator 2021-05-14T19:00:25.184496+00:00 2021-05-14T19:00:28.398694+00:00 0:00:03.214198 28090 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-14T19:00:22.926962+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-14T17:00:00+00:00 TriggerDagRunOperator 2021-05-14T18:11:59.419101+00:00 2021-05-14T18:11:59.954398+00:00 0:00:00.535297 28083 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T18:11:56.694255+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-14T17:00:00+00:00 TriggerDagRunOperator 2021-05-14T18:11:59.103788+00:00 2021-05-14T18:11:59.523726+00:00 0:00:00.419938 28082 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T18:11:56.694212+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-14T17:00:00+00:00 EmrJobFlowSensor 2021-05-14T18:02:32.378506+00:00 2021-05-14T18:11:35.056190+00:00 0:09:02.677684 28078 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T18:02:29.857848+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-14T17:00:00+00:00 EmrCreateJobFlowOperator 2021-05-14T18:02:10.068191+00:00 2021-05-14T18:02:11.774055+00:00 0:00:01.705864 28077 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-14T18:02:07.762975+00:00 2 default_pool