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-20T13:00:00+00:00 PythonOperator 2021-04-20T14:00:13.120206+00:00 2021-04-20T14:00:16.323833+00:00 0:00:03.203627 19285 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-20T14:00:10.718962+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-20T12:00:00+00:00 TriggerDagRunOperator 2021-04-20T13:10:16.050340+00:00 2021-04-20T13:10:16.482308+00:00 0:00:00.431968 19277 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T13:10:13.459523+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-20T12:00:00+00:00 TriggerDagRunOperator 2021-04-20T13:10:15.910842+00:00 2021-04-20T13:10:16.465023+00:00 0:00:00.554181 19276 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T13:10:13.459554+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-20T12:00:00+00:00 EmrJobFlowSensor 2021-04-20T13:00:50.688350+00:00 2021-04-20T13:09:53.306200+00:00 0:09:02.617850 19272 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T13:00:48.497567+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-20T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-20T13:00:30.917379+00:00 2021-04-20T13:00:32.663717+00:00 0:00:01.746338 19271 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-20T13:00:28.564889+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-20T12:00:00+00:00 PythonOperator 2021-04-20T13:00:08.810985+00:00 2021-04-20T13:00:12.447149+00:00 0:00:03.636164 19270 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-20T13:00:06.413854+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-20T11:00:00+00:00 TriggerDagRunOperator 2021-04-20T12:10:17.124257+00:00 2021-04-20T12:10:17.644594+00:00 0:00:00.520337 19262 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T12:10:14.901587+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-20T11:00:00+00:00 TriggerDagRunOperator 2021-04-20T12:10:17.061348+00:00 2021-04-20T12:10:17.464157+00:00 0:00:00.402809 19261 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T12:10:14.901553+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-20T11:00:00+00:00 EmrJobFlowSensor 2021-04-20T12:00:57.941695+00:00 2021-04-20T12:10:01.274380+00:00 0:09:03.332685 19257 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T12:00:55.806470+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-20T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-20T12:00:38.014774+00:00 2021-04-20T12:00:39.734795+00:00 0:00:01.720021 19256 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-20T12:00:35.785343+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-20T11:00:00+00:00 PythonOperator 2021-04-20T12:00:11.877219+00:00 2021-04-20T12:00:14.874865+00:00 0:00:02.997646 19255 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-20T12:00:09.637773+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-20T10:00:00+00:00 TriggerDagRunOperator 2021-04-20T11:10:45.304884+00:00 2021-04-20T11:10:45.821588+00:00 0:00:00.516704 19248 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T11:10:42.654560+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-20T10:00:00+00:00 TriggerDagRunOperator 2021-04-20T11:10:44.990034+00:00 2021-04-20T11:10:45.489325+00:00 0:00:00.499291 19247 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T11:10:42.654588+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-20T10:00:00+00:00 EmrJobFlowSensor 2021-04-20T11:00:50.016849+00:00 2021-04-20T11:09:52.810638+00:00 0:09:02.793789 19242 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T11:00:47.664538+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-20T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-20T11:00:28.329769+00:00 2021-04-20T11:00:30.072801+00:00 0:00:01.743032 19241 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-20T11:00:25.673723+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-20T10:00:00+00:00 PythonOperator 2021-04-20T11:00:05.910875+00:00 2021-04-20T11:00:08.949720+00:00 0:00:03.038845 19240 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-20T11:00:03.605533+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-20T09:00:00+00:00 TriggerDagRunOperator 2021-04-20T10:10:09.118398+00:00 2021-04-20T10:10:09.618985+00:00 0:00:00.500587 19233 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T10:10:06.236631+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-20T09:00:00+00:00 TriggerDagRunOperator 2021-04-20T10:10:08.541496+00:00 2021-04-20T10:10:09.184870+00:00 0:00:00.643374 19232 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T10:10:06.236661+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-20T09:00:00+00:00 EmrJobFlowSensor 2021-04-20T10:00:58.601467+00:00 2021-04-20T10:10:01.352218+00:00 0:09:02.750751 19227 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T10:00:56.265858+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-20T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-20T10:00:39.016786+00:00 2021-04-20T10:00:40.742414+00:00 0:00:01.725628 19226 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-20T10:00:36.255954+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-20T09:00:00+00:00 PythonOperator 2021-04-20T10:00:16.317462+00:00 2021-04-20T10:00:19.678296+00:00 0:00:03.360834 19225 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-20T10:00:14.121750+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-20T08:00:00+00:00 TriggerDagRunOperator 2021-04-20T09:15:51.503409+00:00 2021-04-20T09:15:52.044884+00:00 0:00:00.541475 19218 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T09:15:49.297484+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-20T08:00:00+00:00 TriggerDagRunOperator 2021-04-20T09:15:51.453448+00:00 2021-04-20T09:15:51.861874+00:00 0:00:00.408426 19217 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T09:15:49.297452+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-20T08:00:00+00:00 EmrJobFlowSensor 2021-04-20T09:05:38.427932+00:00 2021-04-20T09:15:41.322384+00:00 0:10:02.894452 19214 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T09:05:36.088400+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-20T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-20T09:05:18.324525+00:00 2021-04-20T09:05:20.133303+00:00 0:00:01.808778 19212 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-20T09:05:16.043424+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-20T08:00:00+00:00 PythonOperator 2021-04-20T09:04:56.802401+00:00 2021-04-20T09:04:59.712232+00:00 0:00:02.909831 19211 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-20T09:04:53.834814+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-20T07:00:00+00:00 TriggerDagRunOperator 2021-04-20T08:10:29.742699+00:00 2021-04-20T08:10:30.210857+00:00 0:00:00.468158 19203 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T08:10:27.302873+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-20T07:00:00+00:00 TriggerDagRunOperator 2021-04-20T08:10:29.738503+00:00 2021-04-20T08:10:30.314389+00:00 0:00:00.575886 19202 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T08:10:27.302905+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-20T07:00:00+00:00 EmrJobFlowSensor 2021-04-20T08:01:14.453264+00:00 2021-04-20T08:10:17.284788+00:00 0:09:02.831524 19198 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T08:01:12.042021+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-20T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-20T08:00:50.419054+00:00 2021-04-20T08:00:52.154469+00:00 0:00:01.735415 19197 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-20T08:00:48.044472+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-20T07:00:00+00:00 PythonOperator 2021-04-20T08:00:20.369022+00:00 2021-04-20T08:00:23.381308+00:00 0:00:03.012286 19196 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-20T08:00:18.000337+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-20T06:00:00+00:00 TriggerDagRunOperator 2021-04-20T07:11:32.346290+00:00 2021-04-20T07:11:32.914577+00:00 0:00:00.568287 19186 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T07:11:29.934526+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-20T06:00:00+00:00 TriggerDagRunOperator 2021-04-20T07:11:32.209290+00:00 2021-04-20T07:11:32.686570+00:00 0:00:00.477280 19185 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T07:11:29.934562+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-20T06:00:00+00:00 EmrJobFlowSensor 2021-04-20T07:01:05.337452+00:00 2021-04-20T07:11:08.441682+00:00 0:10:03.104230 19181 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T07:01:03.023348+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-20T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-20T07:00:43.496588+00:00 2021-04-20T07:00:45.596729+00:00 0:00:02.100141 19180 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-20T07:00:41.060648+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-20T06:00:00+00:00 PythonOperator 2021-04-20T07:00:15.281780+00:00 2021-04-20T07:00:18.370234+00:00 0:00:03.088454 19179 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-20T07:00:12.977592+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-20T05:00:00+00:00 TriggerDagRunOperator 2021-04-20T06:10:34.350077+00:00 2021-04-20T06:10:34.795090+00:00 0:00:00.445013 19171 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T06:10:31.797441+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-20T05:00:00+00:00 TriggerDagRunOperator 2021-04-20T06:10:34.071123+00:00 2021-04-20T06:10:34.621303+00:00 0:00:00.550180 19170 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T06:10:31.797404+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-20T05:00:00+00:00 EmrJobFlowSensor 2021-04-20T06:01:07.071895+00:00 2021-04-20T06:10:09.779305+00:00 0:09:02.707410 19166 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T06:01:04.883650+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-20T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-20T06:00:46.976543+00:00 2021-04-20T06:00:48.783263+00:00 0:00:01.806720 19165 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-20T06:00:44.804614+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-20T05:00:00+00:00 PythonOperator 2021-04-20T06:00:25.562093+00:00 2021-04-20T06:00:28.886112+00:00 0:00:03.324019 19164 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-20T06:00:22.856485+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-20T04:00:00+00:00 TriggerDagRunOperator 2021-04-20T05:10:59.354149+00:00 2021-04-20T05:10:59.903186+00:00 0:00:00.549037 19156 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T05:10:56.434893+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-20T04:00:00+00:00 TriggerDagRunOperator 2021-04-20T05:10:58.790677+00:00 2021-04-20T05:10:59.548336+00:00 0:00:00.757659 19155 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T05:10:56.434857+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-20T04:00:00+00:00 EmrJobFlowSensor 2021-04-20T05:00:51.919607+00:00 2021-04-20T05:10:54.688039+00:00 0:10:02.768432 19151 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T05:00:49.717671+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-20T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-20T05:00:28.127094+00:00 2021-04-20T05:00:29.877427+00:00 0:00:01.750333 19150 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-20T05:00:25.753935+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-20T04:00:00+00:00 PythonOperator 2021-04-20T05:00:08.176751+00:00 2021-04-20T05:00:11.130439+00:00 0:00:02.953688 19149 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-20T05:00:05.680656+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-20T03:00:00+00:00 TriggerDagRunOperator 2021-04-20T04:09:27.598656+00:00 2021-04-20T04:09:28.117838+00:00 0:00:00.519182 19141 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T04:09:24.596769+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-20T03:00:00+00:00 TriggerDagRunOperator 2021-04-20T04:09:27.019485+00:00 2021-04-20T04:09:27.395471+00:00 0:00:00.375986 19140 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T04:09:24.596734+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-20T03:00:00+00:00 EmrJobFlowSensor 2021-04-20T04:01:06.091800+00:00 2021-04-20T04:09:08.616869+00:00 0:08:02.525069 19136 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T04:01:03.759286+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-20T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-20T04:00:43.837198+00:00 2021-04-20T04:00:45.521366+00:00 0:00:01.684168 19135 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-20T04:00:41.696254+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-20T03:00:00+00:00 PythonOperator 2021-04-20T04:00:22.014344+00:00 2021-04-20T04:00:24.927367+00:00 0:00:02.913023 19134 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-20T04:00:19.645986+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-20T02:00:00+00:00 TriggerDagRunOperator 2021-04-20T03:11:11.015977+00:00 2021-04-20T03:11:11.630326+00:00 0:00:00.614349 19126 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T03:11:08.159475+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-20T02:00:00+00:00 TriggerDagRunOperator 2021-04-20T03:11:11.006348+00:00 2021-04-20T03:11:11.492532+00:00 0:00:00.486184 19125 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T03:11:08.159438+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-20T02:00:00+00:00 EmrJobFlowSensor 2021-04-20T03:01:01.851526+00:00 2021-04-20T03:11:04.748039+00:00 0:10:02.896513 19121 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T03:00:59.363836+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-20T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-20T03:00:39.859921+00:00 2021-04-20T03:00:41.726867+00:00 0:00:01.866946 19120 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-20T03:00:37.343421+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-20T02:00:00+00:00 PythonOperator 2021-04-20T03:00:19.773165+00:00 2021-04-20T03:00:22.730861+00:00 0:00:02.957696 19119 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-20T03:00:17.257816+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-20T01:00:00+00:00 TriggerDagRunOperator 2021-04-20T02:11:30.290199+00:00 2021-04-20T02:11:30.835594+00:00 0:00:00.545395 19111 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T02:11:27.553838+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-20T01:00:00+00:00 TriggerDagRunOperator 2021-04-20T02:11:30.097805+00:00 2021-04-20T02:11:30.502229+00:00 0:00:00.404424 19110 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T02:11:27.553871+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-20T01:00:00+00:00 EmrJobFlowSensor 2021-04-20T02:01:04.424458+00:00 2021-04-20T02:11:07.432856+00:00 0:10:03.008398 19106 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T02:01:02.012826+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-20T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-20T02:00:44.368232+00:00 2021-04-20T02:00:46.069777+00:00 0:00:01.701545 19105 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-20T02:00:41.992572+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-20T01:00:00+00:00 PythonOperator 2021-04-20T02:00:22.568382+00:00 2021-04-20T02:00:25.606079+00:00 0:00:03.037697 19104 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-20T02:00:19.952825+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-20T00:00:00+00:00 TriggerDagRunOperator 2021-04-20T01:11:17.006032+00:00 2021-04-20T01:11:17.594141+00:00 0:00:00.588109 19096 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T01:11:14.730866+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-20T00:00:00+00:00 TriggerDagRunOperator 2021-04-20T01:11:16.979705+00:00 2021-04-20T01:11:17.409800+00:00 0:00:00.430095 19095 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T01:11:14.730896+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-20T00:00:00+00:00 EmrJobFlowSensor 2021-04-20T01:01:04.128268+00:00 2021-04-20T01:11:06.925983+00:00 0:10:02.797715 19091 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T01:01:01.950919+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-20T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-20T01:00:42.096559+00:00 2021-04-20T01:00:43.804141+00:00 0:00:01.707582 19090 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-20T01:00:39.930335+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-20T00:00:00+00:00 PythonOperator 2021-04-20T01:00:20.936169+00:00 2021-04-20T01:00:23.894221+00:00 0:00:02.958052 19089 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-20T01:00:17.903169+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-19T23:00:00+00:00 TriggerDagRunOperator 2021-04-20T00:11:24.231272+00:00 2021-04-20T00:11:24.857907+00:00 0:00:00.626635 19081 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T00:11:21.581135+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-19T23:00:00+00:00 TriggerDagRunOperator 2021-04-20T00:11:24.213200+00:00 2021-04-20T00:11:24.626724+00:00 0:00:00.413524 19080 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T00:11:21.581185+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-19T23:00:00+00:00 EmrJobFlowSensor 2021-04-20T00:01:04.981492+00:00 2021-04-20T00:11:07.836437+00:00 0:10:02.854945 19076 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T00:01:02.374088+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-19T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-20T00:00:42.680556+00:00 2021-04-20T00:00:44.352852+00:00 0:00:01.672296 19075 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-20T00:00:40.362545+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-19T23:00:00+00:00 PythonOperator 2021-04-20T00:00:22.665736+00:00 2021-04-20T00:00:25.649786+00:00 0:00:02.984050 19074 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-20T00:00:20.226807+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-19T22:00:00+00:00 TriggerDagRunOperator 2021-04-19T23:09:06.872388+00:00 2021-04-19T23:09:07.417475+00:00 0:00:00.545087 19066 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T23:09:04.252979+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-19T22:00:00+00:00 TriggerDagRunOperator 2021-04-19T23:09:06.679289+00:00 2021-04-19T23:09:07.111923+00:00 0:00:00.432634 19065 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T23:09:04.253016+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-19T22:00:00+00:00 EmrJobFlowSensor 2021-04-19T23:00:56.021079+00:00 2021-04-19T23:08:58.759592+00:00 0:08:02.738513 19061 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T23:00:53.603233+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-19T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T23:00:34.084868+00:00 2021-04-19T23:00:35.768490+00:00 0:00:01.683622 19060 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-19T23:00:31.643524+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-19T22:00:00+00:00 PythonOperator 2021-04-19T23:00:14.459058+00:00 2021-04-19T23:00:17.512031+00:00 0:00:03.052973 19059 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-19T23:00:11.567679+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-19T21:00:00+00:00 TriggerDagRunOperator 2021-04-19T22:22:09.289446+00:00 2021-04-19T22:22:09.744987+00:00 0:00:00.455541 19051 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T22:22:06.487483+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-19T21:00:00+00:00 TriggerDagRunOperator 2021-04-19T22:22:09.174251+00:00 2021-04-19T22:22:09.750249+00:00 0:00:00.575998 19050 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T22:22:06.487519+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-19T21:00:00+00:00 EmrJobFlowSensor 2021-04-19T22:00:56.760100+00:00 2021-04-19T22:22:01.135373+00:00 0:21:04.375273 19046 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T22:00:54.503426+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-19T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T22:00:34.970495+00:00 2021-04-19T22:00:36.807104+00:00 0:00:01.836609 19045 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-19T22:00:32.482755+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-19T21:00:00+00:00 PythonOperator 2021-04-19T22:00:12.769754+00:00 2021-04-19T22:00:15.972792+00:00 0:00:03.203038 19044 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-19T22:00:10.448055+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-19T20:00:00+00:00 TriggerDagRunOperator 2021-04-19T21:11:38.957037+00:00 2021-04-19T21:11:39.465407+00:00 0:00:00.508370 19036 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T21:11:36.361330+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-19T20:00:00+00:00 TriggerDagRunOperator 2021-04-19T21:11:38.797550+00:00 2021-04-19T21:11:39.224248+00:00 0:00:00.426698 19035 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T21:11:36.361287+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-19T20:00:00+00:00 EmrJobFlowSensor 2021-04-19T21:01:11.833517+00:00 2021-04-19T21:11:14.818857+00:00 0:10:02.985340 19031 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T21:01:09.447668+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-19T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T21:00:45.722914+00:00 2021-04-19T21:00:47.522449+00:00 0:00:01.799535 19030 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-19T21:00:43.417480+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-19T20:00:00+00:00 PythonOperator 2021-04-19T21:00:25.792032+00:00 2021-04-19T21:00:28.831742+00:00 0:00:03.039710 19029 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-19T21:00:23.401827+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-19T19:00:00+00:00 TriggerDagRunOperator 2021-04-19T20:10:16.695580+00:00 2021-04-19T20:10:17.218094+00:00 0:00:00.522514 19021 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T20:10:14.160177+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-19T19:00:00+00:00 TriggerDagRunOperator 2021-04-19T20:10:16.525454+00:00 2021-04-19T20:10:16.957900+00:00 0:00:00.432446 19020 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T20:10:14.160124+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-19T19:00:00+00:00 EmrJobFlowSensor 2021-04-19T20:00:55.569992+00:00 2021-04-19T20:09:58.137533+00:00 0:09:02.567541 19016 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T20:00:53.160326+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-19T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T20:00:33.326206+00:00 2021-04-19T20:00:35.190965+00:00 0:00:01.864759 19015 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-19T20:00:31.074240+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-19T19:00:00+00:00 PythonOperator 2021-04-19T20:00:11.658509+00:00 2021-04-19T20:00:14.837246+00:00 0:00:03.178737 19014 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-19T20:00:09.046567+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-19T18:00:00+00:00 TriggerDagRunOperator 2021-04-19T19:10:08.374055+00:00 2021-04-19T19:10:08.945271+00:00 0:00:00.571216 19006 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T19:10:05.451126+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-19T18:00:00+00:00 TriggerDagRunOperator 2021-04-19T19:10:07.847247+00:00 2021-04-19T19:10:08.234278+00:00 0:00:00.387031 19005 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T19:10:05.451094+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-19T18:00:00+00:00 EmrJobFlowSensor 2021-04-19T19:00:58.873794+00:00 2021-04-19T19:10:01.877068+00:00 0:09:03.003274 19001 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T19:00:56.642991+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-19T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T19:00:39.497075+00:00 2021-04-19T19:00:41.195336+00:00 0:00:01.698261 19000 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-19T19:00:36.659940+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-19T18:00:00+00:00 PythonOperator 2021-04-19T19:00:16.990654+00:00 2021-04-19T19:00:19.963816+00:00 0:00:02.973162 18999 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-19T19:00:14.598123+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-19T17:00:00+00:00 TriggerDagRunOperator 2021-04-19T18:10:06.409715+00:00 2021-04-19T18:10:06.932292+00:00 0:00:00.522577 18991 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T18:10:04.047472+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-19T17:00:00+00:00 TriggerDagRunOperator 2021-04-19T18:10:06.365578+00:00 2021-04-19T18:10:06.781125+00:00 0:00:00.415547 18990 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T18:10:04.047516+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-19T17:00:00+00:00 EmrJobFlowSensor 2021-04-19T18:00:49.611114+00:00 2021-04-19T18:09:52.440090+00:00 0:09:02.828976 18986 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T18:00:47.047803+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-19T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T18:00:27.406721+00:00 2021-04-19T18:00:29.103601+00:00 0:00:01.696880 18985 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-19T18:00:24.943427+00:00 2 default_pool