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-15T13:00:00+00:00 PythonOperator 2021-04-15T14:05:00.099855+00:00 2021-04-15T14:05:03.124681+00:00 0:00:03.024826 17481 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-15T14:04:57.339982+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-15T12:00:00+00:00 TriggerDagRunOperator 2021-04-15T13:11:34.732893+00:00 2021-04-15T13:11:35.363206+00:00 0:00:00.630313 17473 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T13:11:32.360335+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-15T12:00:00+00:00 TriggerDagRunOperator 2021-04-15T13:11:34.534422+00:00 2021-04-15T13:11:35.067753+00:00 0:00:00.533331 17472 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T13:11:32.360363+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-15T12:00:00+00:00 EmrJobFlowSensor 2021-04-15T13:01:03.639529+00:00 2021-04-15T13:11:06.445490+00:00 0:10:02.805961 17468 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T13:01:01.391430+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-15T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-15T13:00:41.522619+00:00 2021-04-15T13:00:43.324241+00:00 0:00:01.801622 17467 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-15T13:00:39.300871+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-15T12:00:00+00:00 PythonOperator 2021-04-15T13:00:21.600758+00:00 2021-04-15T13:00:24.583962+00:00 0:00:02.983204 17466 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-15T13:00:19.284766+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-15T11:00:00+00:00 TriggerDagRunOperator 2021-04-15T12:10:03.874574+00:00 2021-04-15T12:10:04.337439+00:00 0:00:00.462865 17458 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T12:10:01.503850+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-15T11:00:00+00:00 TriggerDagRunOperator 2021-04-15T12:10:03.743616+00:00 2021-04-15T12:10:04.307431+00:00 0:00:00.563815 17457 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T12:10:01.503880+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-15T11:00:00+00:00 EmrJobFlowSensor 2021-04-15T12:00:46.944421+00:00 2021-04-15T12:09:49.654929+00:00 0:09:02.710508 17451 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T12:00:44.664473+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-15T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-15T12:00:24.795096+00:00 2021-04-15T12:00:26.671519+00:00 0:00:01.876423 17450 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-15T12:00:22.543307+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-15T11:00:00+00:00 PythonOperator 2021-04-15T12:00:05.373722+00:00 2021-04-15T12:00:08.711338+00:00 0:00:03.337616 17449 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-15T12:00:02.524643+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-15T10:00:00+00:00 TriggerDagRunOperator 2021-04-15T11:10:25.538422+00:00 2021-04-15T11:10:26.053774+00:00 0:00:00.515352 17441 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T11:10:22.893046+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-15T10:00:00+00:00 TriggerDagRunOperator 2021-04-15T11:10:25.407327+00:00 2021-04-15T11:10:25.834538+00:00 0:00:00.427211 17440 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T11:10:22.893076+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-15T10:00:00+00:00 EmrJobFlowSensor 2021-04-15T11:01:04.574212+00:00 2021-04-15T11:10:07.367431+00:00 0:09:02.793219 17436 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T11:01:02.088389+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-15T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-15T11:00:42.224109+00:00 2021-04-15T11:00:44.111867+00:00 0:00:01.887758 17435 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-15T11:00:40.043582+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-15T10:00:00+00:00 PythonOperator 2021-04-15T11:00:20.723297+00:00 2021-04-15T11:00:23.579991+00:00 0:00:02.856694 17434 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-15T11:00:18.051126+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-15T09:00:00+00:00 TriggerDagRunOperator 2021-04-15T10:09:10.960033+00:00 2021-04-15T10:09:11.514110+00:00 0:00:00.554077 17426 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T10:09:08.460877+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-15T09:00:00+00:00 TriggerDagRunOperator 2021-04-15T10:09:10.883408+00:00 2021-04-15T10:09:11.292510+00:00 0:00:00.409102 17425 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T10:09:08.460809+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-15T09:00:00+00:00 EmrJobFlowSensor 2021-04-15T10:00:51.806611+00:00 2021-04-15T10:08:54.430050+00:00 0:08:02.623439 17421 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T10:00:49.422334+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-15T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-15T10:00:31.798666+00:00 2021-04-15T10:00:33.524217+00:00 0:00:01.725551 17420 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-15T10:00:29.481056+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-15T09:00:00+00:00 PythonOperator 2021-04-15T10:00:10.018024+00:00 2021-04-15T10:00:13.206901+00:00 0:00:03.188877 17419 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-15T10:00:07.388159+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-15T08:00:00+00:00 TriggerDagRunOperator 2021-04-15T09:11:24.018244+00:00 2021-04-15T09:11:24.447439+00:00 0:00:00.429195 17411 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T09:11:21.593832+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-15T08:00:00+00:00 TriggerDagRunOperator 2021-04-15T09:11:23.956456+00:00 2021-04-15T09:11:24.545512+00:00 0:00:00.589056 17410 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T09:11:21.593879+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-15T08:00:00+00:00 EmrJobFlowSensor 2021-04-15T09:01:02.676237+00:00 2021-04-15T09:11:05.412887+00:00 0:10:02.736650 17406 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T09:01:00.244394+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-15T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-15T09:00:42.321980+00:00 2021-04-15T09:00:44.020692+00:00 0:00:01.698712 17405 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-15T09:00:40.116872+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-15T08:00:00+00:00 PythonOperator 2021-04-15T09:00:20.581512+00:00 2021-04-15T09:00:23.540520+00:00 0:00:02.959008 17404 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-15T09:00:18.099219+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-15T07:00:00+00:00 TriggerDagRunOperator 2021-04-15T08:10:26.903830+00:00 2021-04-15T08:10:27.452988+00:00 0:00:00.549158 17394 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T08:10:24.634669+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-15T07:00:00+00:00 TriggerDagRunOperator 2021-04-15T08:10:26.879419+00:00 2021-04-15T08:10:27.305853+00:00 0:00:00.426434 17393 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T08:10:24.634639+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-15T07:00:00+00:00 EmrJobFlowSensor 2021-04-15T08:01:00.204969+00:00 2021-04-15T08:10:02.955857+00:00 0:09:02.750888 17389 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T08:00:57.715894+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-15T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-15T08:00:37.928728+00:00 2021-04-15T08:00:39.805343+00:00 0:00:01.876615 17388 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-15T08:00:35.703290+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-15T07:00:00+00:00 PythonOperator 2021-04-15T08:00:16.663134+00:00 2021-04-15T08:00:19.582896+00:00 0:00:02.919762 17387 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-15T08:00:13.659262+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-15T06:00:00+00:00 TriggerDagRunOperator 2021-04-15T07:09:19.682992+00:00 2021-04-15T07:09:20.216802+00:00 0:00:00.533810 17378 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T07:09:17.205871+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-15T06:00:00+00:00 TriggerDagRunOperator 2021-04-15T07:09:19.390337+00:00 2021-04-15T07:09:19.844699+00:00 0:00:00.454362 17377 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T07:09:17.205822+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-15T06:00:00+00:00 EmrJobFlowSensor 2021-04-15T07:01:00.716737+00:00 2021-04-15T07:09:03.243792+00:00 0:08:02.527055 17373 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T07:00:58.356018+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-15T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-15T07:00:38.613176+00:00 2021-04-15T07:00:40.400613+00:00 0:00:01.787437 17372 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-15T07:00:36.243385+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-15T06:00:00+00:00 PythonOperator 2021-04-15T07:00:18.694483+00:00 2021-04-15T07:00:21.643954+00:00 0:00:02.949471 17371 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-15T07:00:16.226194+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-15T05:00:00+00:00 TriggerDagRunOperator 2021-04-15T06:10:25.210581+00:00 2021-04-15T06:10:25.634901+00:00 0:00:00.424320 17363 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T06:10:22.089818+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-15T05:00:00+00:00 TriggerDagRunOperator 2021-04-15T06:10:25.198365+00:00 2021-04-15T06:10:25.752147+00:00 0:00:00.553782 17362 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T06:10:22.089855+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-15T05:00:00+00:00 EmrJobFlowSensor 2021-04-15T06:00:59.309307+00:00 2021-04-15T06:10:02.024497+00:00 0:09:02.715190 17358 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T06:00:56.956917+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-15T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-15T06:00:37.178941+00:00 2021-04-15T06:00:38.906156+00:00 0:00:01.727215 17357 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-15T06:00:34.940765+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-15T05:00:00+00:00 PythonOperator 2021-04-15T06:00:17.281244+00:00 2021-04-15T06:00:20.235570+00:00 0:00:02.954326 17356 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-15T06:00:14.919086+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-15T04:00:00+00:00 TriggerDagRunOperator 2021-04-15T05:18:34.222306+00:00 2021-04-15T05:18:34.772676+00:00 0:00:00.550370 17348 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T05:18:31.884423+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-15T04:00:00+00:00 TriggerDagRunOperator 2021-04-15T05:18:34.188894+00:00 2021-04-15T05:18:34.580476+00:00 0:00:00.391582 17347 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T05:18:31.884395+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-15T04:00:00+00:00 EmrJobFlowSensor 2021-04-15T05:01:08.236131+00:00 2021-04-15T05:18:11.875359+00:00 0:17:03.639228 17343 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T05:01:06.037487+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-15T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-15T05:00:46.540021+00:00 2021-04-15T05:00:48.349716+00:00 0:00:01.809695 17342 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-15T05:00:44.082465+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-15T04:00:00+00:00 PythonOperator 2021-04-15T05:00:24.469823+00:00 2021-04-15T05:00:27.434082+00:00 0:00:02.964259 17341 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-15T05:00:21.995975+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-15T03:00:00+00:00 TriggerDagRunOperator 2021-04-15T04:10:02.602277+00:00 2021-04-15T04:10:03.086423+00:00 0:00:00.484146 17333 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T04:10:00.366258+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-15T03:00:00+00:00 TriggerDagRunOperator 2021-04-15T04:10:02.601047+00:00 2021-04-15T04:10:03.174263+00:00 0:00:00.573216 17332 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T04:10:00.366289+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-15T03:00:00+00:00 EmrJobFlowSensor 2021-04-15T04:00:47.893584+00:00 2021-04-15T04:09:50.760545+00:00 0:09:02.866961 17328 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T04:00:45.540853+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-15T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-15T04:00:25.844558+00:00 2021-04-15T04:00:27.741616+00:00 0:00:01.897058 17327 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-15T04:00:23.503590+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-15T03:00:00+00:00 PythonOperator 2021-04-15T04:00:03.830921+00:00 2021-04-15T04:00:06.778136+00:00 0:00:02.947215 17326 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-15T04:00:01.459612+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-15T02:00:00+00:00 TriggerDagRunOperator 2021-04-15T03:10:04.444612+00:00 2021-04-15T03:10:05.216255+00:00 0:00:00.771643 17318 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T03:10:02.094838+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-15T02:00:00+00:00 TriggerDagRunOperator 2021-04-15T03:10:04.324574+00:00 2021-04-15T03:10:05.012695+00:00 0:00:00.688121 17317 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T03:10:02.094869+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-15T02:00:00+00:00 EmrJobFlowSensor 2021-04-15T03:00:46.931113+00:00 2021-04-15T03:09:49.723290+00:00 0:09:02.792177 17313 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T03:00:44.729996+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-15T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-15T03:00:26.951963+00:00 2021-04-15T03:00:28.705854+00:00 0:00:01.753891 17312 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-15T03:00:24.711185+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-15T02:00:00+00:00 PythonOperator 2021-04-15T03:00:05.514390+00:00 2021-04-15T03:00:08.407180+00:00 0:00:02.892790 17311 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-15T03:00:02.752706+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-15T01:00:00+00:00 TriggerDagRunOperator 2021-04-15T02:10:16.781323+00:00 2021-04-15T02:10:17.191238+00:00 0:00:00.409915 17303 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T02:10:14.053355+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-15T01:00:00+00:00 TriggerDagRunOperator 2021-04-15T02:10:16.798564+00:00 2021-04-15T02:10:17.313499+00:00 0:00:00.514935 17302 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T02:10:14.053402+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-15T01:00:00+00:00 EmrJobFlowSensor 2021-04-15T02:00:51.145632+00:00 2021-04-15T02:09:54.170149+00:00 0:09:03.024517 17298 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T02:00:48.825188+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-15T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-15T02:00:29.094892+00:00 2021-04-15T02:00:30.795255+00:00 0:00:01.700363 17297 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-15T02:00:26.811013+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-15T01:00:00+00:00 PythonOperator 2021-04-15T02:00:09.257859+00:00 2021-04-15T02:00:12.103665+00:00 0:00:02.845806 17296 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-15T02:00:06.790086+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-15T00:00:00+00:00 TriggerDagRunOperator 2021-04-15T01:09:16.081082+00:00 2021-04-15T01:09:16.608506+00:00 0:00:00.527424 17288 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T01:09:13.616982+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-15T00:00:00+00:00 TriggerDagRunOperator 2021-04-15T01:09:15.973128+00:00 2021-04-15T01:09:16.391811+00:00 0:00:00.418683 17287 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T01:09:13.616924+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-15T00:00:00+00:00 EmrJobFlowSensor 2021-04-15T01:01:02.893414+00:00 2021-04-15T01:09:05.379834+00:00 0:08:02.486420 17283 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T01:01:00.551311+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-15T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-15T01:00:40.667239+00:00 2021-04-15T01:00:42.369720+00:00 0:00:01.702481 17282 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-15T01:00:38.395662+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-15T00:00:00+00:00 PythonOperator 2021-04-15T01:00:18.795281+00:00 2021-04-15T01:00:21.932480+00:00 0:00:03.137199 17281 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-15T01:00:16.334749+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-14T23:00:00+00:00 TriggerDagRunOperator 2021-04-15T00:11:32.275808+00:00 2021-04-15T00:11:32.699141+00:00 0:00:00.423333 17273 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T00:11:29.992158+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-14T23:00:00+00:00 TriggerDagRunOperator 2021-04-15T00:11:32.277167+00:00 2021-04-15T00:11:32.841056+00:00 0:00:00.563889 17272 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T00:11:29.992191+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-14T23:00:00+00:00 EmrJobFlowSensor 2021-04-15T00:01:05.311654+00:00 2021-04-15T00:11:08.194897+00:00 0:10:02.883243 17268 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T00:01:03.052251+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-14T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-15T00:00:45.230981+00:00 2021-04-15T00:00:46.936718+00:00 0:00:01.705737 17267 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-15T00:00:42.993631+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-14T23:00:00+00:00 PythonOperator 2021-04-15T00:00:23.221966+00:00 2021-04-15T00:00:26.081636+00:00 0:00:02.859670 17266 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-15T00:00:20.907757+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-14T22:00:00+00:00 TriggerDagRunOperator 2021-04-14T23:10:34.930271+00:00 2021-04-14T23:10:35.510746+00:00 0:00:00.580475 17258 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T23:10:32.488041+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-14T22:00:00+00:00 TriggerDagRunOperator 2021-04-14T23:10:34.716647+00:00 2021-04-14T23:10:35.365208+00:00 0:00:00.648561 17257 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T23:10:32.488072+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-14T22:00:00+00:00 EmrJobFlowSensor 2021-04-14T23:01:09.795554+00:00 2021-04-14T23:10:12.478328+00:00 0:09:02.682774 17253 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T23:01:07.523167+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-14T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T23:00:48.239210+00:00 2021-04-14T23:00:50.339206+00:00 0:00:02.099996 17252 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-14T23:00:45.568750+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-14T22:00:00+00:00 PythonOperator 2021-04-14T23:00:25.791445+00:00 2021-04-14T23:00:28.667699+00:00 0:00:02.876254 17251 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-14T23:00:23.488068+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-14T21:00:00+00:00 TriggerDagRunOperator 2021-04-14T22:10:18.441513+00:00 2021-04-14T22:10:18.970047+00:00 0:00:00.528534 17243 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T22:10:16.051484+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-14T21:00:00+00:00 TriggerDagRunOperator 2021-04-14T22:10:18.369635+00:00 2021-04-14T22:10:18.815072+00:00 0:00:00.445437 17242 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T22:10:16.051521+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-14T21:00:00+00:00 EmrJobFlowSensor 2021-04-14T22:00:51.413329+00:00 2021-04-14T22:09:54.140900+00:00 0:09:02.727571 17238 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T22:00:49.299336+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-14T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T22:00:29.731326+00:00 2021-04-14T22:00:31.748013+00:00 0:00:02.016687 17237 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-14T22:00:27.290931+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-14T21:00:00+00:00 PythonOperator 2021-04-14T22:00:07.481597+00:00 2021-04-14T22:00:10.559305+00:00 0:00:03.077708 17236 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-14T22:00:05.267848+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-14T20:00:00+00:00 TriggerDagRunOperator 2021-04-14T21:10:25.722349+00:00 2021-04-14T21:10:26.139435+00:00 0:00:00.417086 17228 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T21:10:23.429785+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-14T20:00:00+00:00 TriggerDagRunOperator 2021-04-14T21:10:25.732103+00:00 2021-04-14T21:10:26.268892+00:00 0:00:00.536789 17227 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T21:10:23.429816+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-14T20:00:00+00:00 EmrJobFlowSensor 2021-04-14T21:01:04.895840+00:00 2021-04-14T21:10:07.666238+00:00 0:09:02.770398 17223 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T21:01:02.510734+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-14T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T21:00:40.724562+00:00 2021-04-14T21:00:42.415855+00:00 0:00:01.691293 17222 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-14T21:00:38.486208+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-14T20:00:00+00:00 PythonOperator 2021-04-14T21:00:20.691901+00:00 2021-04-14T21:00:23.729483+00:00 0:00:03.037582 17221 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-14T21:00:18.425255+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-14T19:00:00+00:00 TriggerDagRunOperator 2021-04-14T20:09:17.646396+00:00 2021-04-14T20:09:18.159362+00:00 0:00:00.512966 17213 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T20:09:15.385950+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-14T19:00:00+00:00 TriggerDagRunOperator 2021-04-14T20:09:17.521101+00:00 2021-04-14T20:09:17.942570+00:00 0:00:00.421469 17212 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T20:09:15.385919+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-14T19:00:00+00:00 EmrJobFlowSensor 2021-04-14T20:00:50.900530+00:00 2021-04-14T20:08:54.071399+00:00 0:08:03.170869 17208 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T20:00:48.697942+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-14T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T20:00:28.911650+00:00 2021-04-14T20:00:30.626581+00:00 0:00:01.714931 17207 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-14T20:00:26.641302+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-14T19:00:00+00:00 PythonOperator 2021-04-14T20:00:09.010002+00:00 2021-04-14T20:00:12.864819+00:00 0:00:03.854817 17206 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-14T20:00:06.161229+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-14T18:00:00+00:00 TriggerDagRunOperator 2021-04-14T19:10:13.853677+00:00 2021-04-14T19:10:14.790808+00:00 0:00:00.937131 17198 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T19:10:11.354929+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-14T18:00:00+00:00 TriggerDagRunOperator 2021-04-14T19:10:13.809479+00:00 2021-04-14T19:10:14.719785+00:00 0:00:00.910306 17197 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T19:10:11.354973+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-14T18:00:00+00:00 EmrJobFlowSensor 2021-04-14T19:01:00.840422+00:00 2021-04-14T19:10:03.429065+00:00 0:09:02.588643 17193 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T19:00:58.356672+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-14T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T19:00:40.408835+00:00 2021-04-14T19:00:42.228759+00:00 0:00:01.819924 17192 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-14T19:00:38.215653+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-14T18:00:00+00:00 PythonOperator 2021-04-14T19:00:18.593671+00:00 2021-04-14T19:00:21.508330+00:00 0:00:02.914659 17191 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-14T19:00:16.200687+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-14T17:00:00+00:00 TriggerDagRunOperator 2021-04-14T18:09:24.481425+00:00 2021-04-14T18:09:24.911784+00:00 0:00:00.430359 17183 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T18:09:22.135411+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-14T17:00:00+00:00 TriggerDagRunOperator 2021-04-14T18:09:24.376820+00:00 2021-04-14T18:09:24.923243+00:00 0:00:00.546423 17182 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-14T18:09:22.135384+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-14T17:00:00+00:00 EmrJobFlowSensor 2021-04-14T18:01:00.150488+00:00 2021-04-14T18:09:02.795789+00:00 0:08:02.645301 17178 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-14T18:00:57.645374+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-14T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-14T18:00:37.689895+00:00 2021-04-14T18:00:39.495981+00:00 0:00:01.806086 17177 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-14T18:00:35.487373+00:00 2 default_pool