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-06T09:00:00+00:00 PythonOperator 2021-04-06T10:00:22.128996+00:00 2021-04-06T10:00:24.975565+00:00 0:00:02.846569 14162 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-06T10:00:19.702303+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-06T08:00:00+00:00 TriggerDagRunOperator 2021-04-06T09:11:29.133206+00:00 2021-04-06T09:11:29.661735+00:00 0:00:00.528529 14154 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T09:11:26.611608+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-06T08:00:00+00:00 TriggerDagRunOperator 2021-04-06T09:11:28.951356+00:00 2021-04-06T09:11:29.353544+00:00 0:00:00.402188 14153 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T09:11:26.611640+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-06T08:00:00+00:00 EmrJobFlowSensor 2021-04-06T09:01:02.152687+00:00 2021-04-06T09:11:05.047568+00:00 0:10:02.894881 14149 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T09:00:59.669830+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-06T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T09:00:39.718753+00:00 2021-04-06T09:00:41.383931+00:00 0:00:01.665178 14148 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-06T09:00:37.525096+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-06T08:00:00+00:00 PythonOperator 2021-04-06T09:00:19.919745+00:00 2021-04-06T09:00:22.653021+00:00 0:00:02.733276 14147 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-06T09:00:17.519468+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-06T07:00:00+00:00 TriggerDagRunOperator 2021-04-06T08:14:07.426252+00:00 2021-04-06T08:14:07.865979+00:00 0:00:00.439727 14140 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T08:14:04.478028+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-06T07:00:00+00:00 TriggerDagRunOperator 2021-04-06T08:14:07.415076+00:00 2021-04-06T08:14:08.023331+00:00 0:00:00.608255 14139 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T08:14:04.478059+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-06T07:00:00+00:00 EmrJobFlowSensor 2021-04-06T08:01:01.221326+00:00 2021-04-06T08:10:04.075077+00:00 0:09:02.853751 14134 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T08:00:58.562558+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-06T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T08:00:38.827690+00:00 2021-04-06T08:00:40.518117+00:00 0:00:01.690427 14133 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-06T08:00:36.478358+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-06T07:00:00+00:00 PythonOperator 2021-04-06T08:00:18.623042+00:00 2021-04-06T08:00:21.397385+00:00 0:00:02.774343 14132 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-06T08:00:16.384557+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-06T06:00:00+00:00 TriggerDagRunOperator 2021-04-06T07:11:14.028229+00:00 2021-04-06T07:11:14.590339+00:00 0:00:00.562110 14122 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T07:11:11.389479+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-06T06:00:00+00:00 TriggerDagRunOperator 2021-04-06T07:11:13.914082+00:00 2021-04-06T07:11:14.360403+00:00 0:00:00.446321 14121 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T07:11:11.389450+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-06T06:00:00+00:00 EmrJobFlowSensor 2021-04-06T07:01:05.694292+00:00 2021-04-06T07:11:08.377350+00:00 0:10:02.683058 14116 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T07:01:03.354177+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-06T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T07:00:43.651895+00:00 2021-04-06T07:00:45.349538+00:00 0:00:01.697643 14115 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-06T07:00:41.258329+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-06T06:00:00+00:00 PythonOperator 2021-04-06T07:00:23.427189+00:00 2021-04-06T07:00:26.416101+00:00 0:00:02.988912 14114 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-06T07:00:21.241621+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-06T05:00:00+00:00 TriggerDagRunOperator 2021-04-06T06:10:14.480968+00:00 2021-04-06T06:10:14.913886+00:00 0:00:00.432918 14107 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T06:10:11.903065+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-06T05:00:00+00:00 TriggerDagRunOperator 2021-04-06T06:10:14.484765+00:00 2021-04-06T06:10:15.038243+00:00 0:00:00.553478 14106 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T06:10:11.903039+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-06T05:00:00+00:00 EmrJobFlowSensor 2021-04-06T06:01:03.910774+00:00 2021-04-06T06:10:06.717021+00:00 0:09:02.806247 14101 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T06:01:01.685900+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-06T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T06:00:41.808968+00:00 2021-04-06T06:00:43.530205+00:00 0:00:01.721237 14100 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-06T06:00:39.644665+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-06T05:00:00+00:00 PythonOperator 2021-04-06T06:00:21.826256+00:00 2021-04-06T06:00:24.542992+00:00 0:00:02.716736 14099 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-06T06:00:19.622545+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-06T04:00:00+00:00 TriggerDagRunOperator 2021-04-06T05:11:05.356995+00:00 2021-04-06T05:11:05.872251+00:00 0:00:00.515256 14092 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T05:11:02.567336+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-06T04:00:00+00:00 TriggerDagRunOperator 2021-04-06T05:11:04.987948+00:00 2021-04-06T05:11:05.396040+00:00 0:00:00.408092 14091 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T05:11:02.567289+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-06T04:00:00+00:00 EmrJobFlowSensor 2021-04-06T05:00:54.710096+00:00 2021-04-06T05:10:57.682394+00:00 0:10:02.972298 14086 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T05:00:52.140509+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-06T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T05:00:32.614004+00:00 2021-04-06T05:00:34.298636+00:00 0:00:01.684632 14085 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-06T05:00:30.153071+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-06T04:00:00+00:00 PythonOperator 2021-04-06T05:00:10.524677+00:00 2021-04-06T05:00:13.269362+00:00 0:00:02.744685 14084 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-06T05:00:08.072536+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-06T03:00:00+00:00 TriggerDagRunOperator 2021-04-06T04:13:21.812544+00:00 2021-04-06T04:13:22.361319+00:00 0:00:00.548775 14077 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T04:13:19.503442+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-06T03:00:00+00:00 TriggerDagRunOperator 2021-04-06T04:13:21.714307+00:00 2021-04-06T04:13:22.143018+00:00 0:00:00.428711 14076 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T04:13:19.503398+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-06T03:00:00+00:00 EmrJobFlowSensor 2021-04-06T04:03:04.835692+00:00 2021-04-06T04:13:07.690181+00:00 0:10:02.854489 14072 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T04:03:02.352995+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-06T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T04:02:42.517269+00:00 2021-04-06T04:02:44.255885+00:00 0:00:01.738616 14071 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-06T04:02:40.256084+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-06T03:00:00+00:00 PythonOperator 2021-04-06T04:02:10.667191+00:00 2021-04-06T04:02:13.531373+00:00 0:00:02.864182 14070 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-06T04:02:08.220983+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-06T02:00:00+00:00 TriggerDagRunOperator 2021-04-06T03:10:08.445170+00:00 2021-04-06T03:10:08.970061+00:00 0:00:00.524891 14062 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T03:10:05.993137+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-06T02:00:00+00:00 TriggerDagRunOperator 2021-04-06T03:10:08.369477+00:00 2021-04-06T03:10:08.774885+00:00 0:00:00.405408 14061 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T03:10:05.993105+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-06T02:00:00+00:00 EmrJobFlowSensor 2021-04-06T03:01:01.456558+00:00 2021-04-06T03:10:04.205312+00:00 0:09:02.748754 14057 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T03:00:59.236723+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-06T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T03:00:39.433074+00:00 2021-04-06T03:00:41.194465+00:00 0:00:01.761391 14056 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-06T03:00:37.217355+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-06T02:00:00+00:00 PythonOperator 2021-04-06T03:00:19.516355+00:00 2021-04-06T03:00:22.217478+00:00 0:00:02.701123 14055 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-06T03:00:17.198714+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-06T01:00:00+00:00 TriggerDagRunOperator 2021-04-06T02:09:23.335478+00:00 2021-04-06T02:09:24.084464+00:00 0:00:00.748986 14047 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T02:09:20.646637+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-06T01:00:00+00:00 TriggerDagRunOperator 2021-04-06T02:09:23.024154+00:00 2021-04-06T02:09:23.672697+00:00 0:00:00.648543 14046 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T02:09:20.646605+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-06T01:00:00+00:00 EmrJobFlowSensor 2021-04-06T02:01:10.418709+00:00 2021-04-06T02:09:13.082308+00:00 0:08:02.663599 14042 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T02:01:07.866326+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-06T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T02:00:38.049337+00:00 2021-04-06T02:00:39.883368+00:00 0:00:01.834031 14041 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-06T02:00:35.792378+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-06T01:00:00+00:00 PythonOperator 2021-04-06T02:00:14.120896+00:00 2021-04-06T02:00:16.986289+00:00 0:00:02.865393 14040 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-06T02:00:11.737190+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-06T00:00:00+00:00 TriggerDagRunOperator 2021-04-06T01:10:59.220141+00:00 2021-04-06T01:10:59.783810+00:00 0:00:00.563669 14032 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T01:10:56.655232+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-06T00:00:00+00:00 TriggerDagRunOperator 2021-04-06T01:10:59.200403+00:00 2021-04-06T01:10:59.614693+00:00 0:00:00.414290 14031 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T01:10:56.655196+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-06T00:00:00+00:00 EmrJobFlowSensor 2021-04-06T01:00:50.124547+00:00 2021-04-06T01:10:52.729938+00:00 0:10:02.605391 14027 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T01:00:47.764012+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-06T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T01:00:30.081444+00:00 2021-04-06T01:00:31.772009+00:00 0:00:01.690565 14026 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-06T01:00:27.747044+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-06T00:00:00+00:00 PythonOperator 2021-04-06T01:00:08.054677+00:00 2021-04-06T01:00:10.759299+00:00 0:00:02.704622 14025 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-06T01:00:05.660682+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-05T23:00:00+00:00 TriggerDagRunOperator 2021-04-06T00:10:03.913065+00:00 2021-04-06T00:10:04.364079+00:00 0:00:00.451014 14017 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T00:10:01.350584+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-05T23:00:00+00:00 TriggerDagRunOperator 2021-04-06T00:10:03.853089+00:00 2021-04-06T00:10:04.451012+00:00 0:00:00.597923 14016 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T00:10:01.350554+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-05T23:00:00+00:00 EmrJobFlowSensor 2021-04-06T00:00:48.870508+00:00 2021-04-06T00:09:51.603278+00:00 0:09:02.732770 14012 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T00:00:46.499067+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-05T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T00:00:28.636567+00:00 2021-04-06T00:00:30.358823+00:00 0:00:01.722256 14011 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-06T00:00:26.446844+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-05T23:00:00+00:00 PythonOperator 2021-04-06T00:00:06.957092+00:00 2021-04-06T00:00:09.746504+00:00 0:00:02.789412 14010 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-06T00:00:04.477292+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-05T22:00:00+00:00 TriggerDagRunOperator 2021-04-05T23:11:08.535717+00:00 2021-04-05T23:11:09.094062+00:00 0:00:00.558345 14002 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T23:11:06.043829+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-05T22:00:00+00:00 TriggerDagRunOperator 2021-04-05T23:11:08.174725+00:00 2021-04-05T23:11:08.601651+00:00 0:00:00.426926 14001 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T23:11:06.043794+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-05T22:00:00+00:00 EmrJobFlowSensor 2021-04-05T23:00:59.551816+00:00 2021-04-05T23:11:02.527576+00:00 0:10:02.975760 13997 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T23:00:57.234619+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-05T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T23:00:37.548732+00:00 2021-04-05T23:00:39.310008+00:00 0:00:01.761276 13996 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-05T23:00:35.216566+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-05T22:00:00+00:00 PythonOperator 2021-04-05T23:00:18.037238+00:00 2021-04-05T23:00:20.824444+00:00 0:00:02.787206 13995 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-05T23:00:15.198746+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-05T21:00:00+00:00 TriggerDagRunOperator 2021-04-05T22:11:04.287584+00:00 2021-04-05T22:11:04.701435+00:00 0:00:00.413851 13987 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T22:11:01.789365+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-05T21:00:00+00:00 TriggerDagRunOperator 2021-04-05T22:11:04.260148+00:00 2021-04-05T22:11:04.827419+00:00 0:00:00.567271 13986 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T22:11:01.789397+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-05T21:00:00+00:00 EmrJobFlowSensor 2021-04-05T22:00:46.852529+00:00 2021-04-05T22:10:49.727257+00:00 0:10:02.874728 13982 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T22:00:44.589928+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-05T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T22:00:26.715661+00:00 2021-04-05T22:00:28.465412+00:00 0:00:01.749751 13981 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-05T22:00:24.566237+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-05T21:00:00+00:00 PythonOperator 2021-04-05T22:00:05.096757+00:00 2021-04-05T22:00:07.976803+00:00 0:00:02.880046 13980 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-05T22:00:02.549373+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-05T20:00:00+00:00 TriggerDagRunOperator 2021-04-05T21:11:18.233904+00:00 2021-04-05T21:11:18.776973+00:00 0:00:00.543069 13972 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T21:11:15.598674+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-05T20:00:00+00:00 TriggerDagRunOperator 2021-04-05T21:11:17.907121+00:00 2021-04-05T21:11:18.336125+00:00 0:00:00.429004 13971 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T21:11:15.598721+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-05T20:00:00+00:00 EmrJobFlowSensor 2021-04-05T21:01:07.135290+00:00 2021-04-05T21:11:10.043234+00:00 0:10:02.907944 13967 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T21:01:04.740837+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-05T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T21:00:44.987431+00:00 2021-04-05T21:00:46.761780+00:00 0:00:01.774349 13966 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-05T21:00:42.655616+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-05T20:00:00+00:00 PythonOperator 2021-04-05T21:00:24.927404+00:00 2021-04-05T21:00:27.694804+00:00 0:00:02.767400 13965 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-05T21:00:22.549956+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-05T19:00:00+00:00 TriggerDagRunOperator 2021-04-05T20:10:57.349531+00:00 2021-04-05T20:10:57.900544+00:00 0:00:00.551013 13957 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T20:10:55.040026+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-05T19:00:00+00:00 TriggerDagRunOperator 2021-04-05T20:10:57.289060+00:00 2021-04-05T20:10:57.686340+00:00 0:00:00.397280 13956 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T20:10:55.040063+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-05T19:00:00+00:00 EmrJobFlowSensor 2021-04-05T20:00:50.258773+00:00 2021-04-05T20:10:53.033973+00:00 0:10:02.775200 13952 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T20:00:48.002910+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-05T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T20:00:28.509566+00:00 2021-04-05T20:00:30.202239+00:00 0:00:01.692673 13951 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-05T20:00:26.055817+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-05T19:00:00+00:00 PythonOperator 2021-04-05T20:00:08.785981+00:00 2021-04-05T20:00:11.548716+00:00 0:00:02.762735 13950 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-05T20:00:05.957785+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-05T18:00:00+00:00 TriggerDagRunOperator 2021-04-05T19:10:17.415191+00:00 2021-04-05T19:10:17.966860+00:00 0:00:00.551669 13942 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T19:10:14.860299+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-05T18:00:00+00:00 TriggerDagRunOperator 2021-04-05T19:10:17.258713+00:00 2021-04-05T19:10:17.688555+00:00 0:00:00.429842 13941 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T19:10:14.860348+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-05T18:00:00+00:00 EmrJobFlowSensor 2021-04-05T19:01:00.549092+00:00 2021-04-05T19:10:03.156210+00:00 0:09:02.607118 13937 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T19:00:58.045632+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-05T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T19:00:38.257507+00:00 2021-04-05T19:00:40.050675+00:00 0:00:01.793168 13936 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-05T19:00:35.840074+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-05T18:00:00+00:00 PythonOperator 2021-04-05T19:00:14.614765+00:00 2021-04-05T19:00:17.494714+00:00 0:00:02.879949 13935 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-05T19:00:11.818210+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-05T17:00:00+00:00 TriggerDagRunOperator 2021-04-05T18:13:14.243251+00:00 2021-04-05T18:13:14.783111+00:00 0:00:00.539860 13927 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T18:13:11.789895+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-05T17:00:00+00:00 TriggerDagRunOperator 2021-04-05T18:13:14.089797+00:00 2021-04-05T18:13:14.509916+00:00 0:00:00.420119 13926 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T18:13:11.789926+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-05T17:00:00+00:00 EmrJobFlowSensor 2021-04-05T18:00:54.760231+00:00 2021-04-05T18:12:57.632677+00:00 0:12:02.872446 13922 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T18:00:52.352189+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-05T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T18:00:34.567320+00:00 2021-04-05T18:00:36.280121+00:00 0:00:01.712801 13921 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-05T18:00:32.210231+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-05T17:00:00+00:00 PythonOperator 2021-04-05T18:00:12.606964+00:00 2021-04-05T18:00:15.440019+00:00 0:00:02.833055 13920 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-05T18:00:10.191741+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-05T16:00:00+00:00 TriggerDagRunOperator 2021-04-05T17:10:28.098317+00:00 2021-04-05T17:10:28.633232+00:00 0:00:00.534915 13912 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T17:10:25.760495+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-05T16:00:00+00:00 TriggerDagRunOperator 2021-04-05T17:10:27.989254+00:00 2021-04-05T17:10:28.389420+00:00 0:00:00.400166 13911 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T17:10:25.760534+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-05T16:00:00+00:00 EmrJobFlowSensor 2021-04-05T17:00:59.039661+00:00 2021-04-05T17:10:01.848426+00:00 0:09:02.808765 13907 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T17:00:56.844450+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-05T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T17:00:37.095106+00:00 2021-04-05T17:00:38.909042+00:00 0:00:01.813936 13906 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-05T17:00:34.814141+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-05T16:00:00+00:00 PythonOperator 2021-04-05T17:00:15.740370+00:00 2021-04-05T17:00:18.599201+00:00 0:00:02.858831 13905 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-05T17:00:12.871667+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-05T15:00:00+00:00 TriggerDagRunOperator 2021-04-05T16:10:03.595780+00:00 2021-04-05T16:10:04.044801+00:00 0:00:00.449021 13897 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T16:10:01.189277+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-05T15:00:00+00:00 TriggerDagRunOperator 2021-04-05T16:10:03.545695+00:00 2021-04-05T16:10:04.106206+00:00 0:00:00.560511 13896 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T16:10:01.189248+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-05T15:00:00+00:00 EmrJobFlowSensor 2021-04-05T16:00:48.132391+00:00 2021-04-05T16:09:50.838588+00:00 0:09:02.706197 13892 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T16:00:45.924116+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-05T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T16:00:26.317564+00:00 2021-04-05T16:00:28.146521+00:00 0:00:01.828957 13891 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-05T16:00:23.973632+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-05T15:00:00+00:00 PythonOperator 2021-04-05T16:00:04.833064+00:00 2021-04-05T16:00:07.731371+00:00 0:00:02.898307 13890 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-05T16:00:01.890059+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-05T14:00:00+00:00 TriggerDagRunOperator 2021-04-05T15:10:13.201655+00:00 2021-04-05T15:10:13.626276+00:00 0:00:00.424621 13882 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T15:10:10.890015+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-05T14:00:00+00:00 TriggerDagRunOperator 2021-04-05T15:10:13.195437+00:00 2021-04-05T15:10:13.739094+00:00 0:00:00.543657 13881 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T15:10:10.889983+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-05T14:00:00+00:00 EmrJobFlowSensor 2021-04-05T15:00:50.250376+00:00 2021-04-05T15:09:52.832932+00:00 0:09:02.582556 13877 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T15:00:48.002720+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-05T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T15:00:30.446139+00:00 2021-04-05T15:00:32.267417+00:00 0:00:01.821278 13876 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-05T15:00:27.987492+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-05T14:00:00+00:00 PythonOperator 2021-04-05T15:00:08.422357+00:00 2021-04-05T15:00:11.162553+00:00 0:00:02.740196 13875 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-05T15:00:05.943971+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-05T13:00:00+00:00 TriggerDagRunOperator 2021-04-05T14:09:04.309449+00:00 2021-04-05T14:09:04.723699+00:00 0:00:00.414250 13867 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T14:09:01.586181+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-05T13:00:00+00:00 TriggerDagRunOperator 2021-04-05T14:09:04.031276+00:00 2021-04-05T14:09:04.572017+00:00 0:00:00.540741 13866 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T14:09:01.586214+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-05T13:00:00+00:00 EmrJobFlowSensor 2021-04-05T14:00:49.663382+00:00 2021-04-05T14:08:52.142995+00:00 0:08:02.479613 13862 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T14:00:46.960339+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-05T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T14:00:29.056197+00:00 2021-04-05T14:00:30.739244+00:00 0:00:01.683047 13861 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-05T14:00:26.807561+00:00 2 default_pool