Task Instances

Reset Filters
  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success campaign-flow-job_v002 create_emr_steps 2021-05-03T21:00:00+00:00 PythonOperator 2021-05-03T22:00:19.817900+00:00 2021-05-03T22:00:22.859416+00:00 0:00:03.041516 24147 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-03T22:00:17.260346+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-03T20:00:00+00:00 TriggerDagRunOperator 2021-05-03T21:10:19.933684+00:00 2021-05-03T21:10:20.429830+00:00 0:00:00.496146 24139 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T21:10:17.347979+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-03T20:00:00+00:00 TriggerDagRunOperator 2021-05-03T21:10:19.830842+00:00 2021-05-03T21:10:20.240488+00:00 0:00:00.409646 24138 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T21:10:17.347930+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-03T20:00:00+00:00 EmrJobFlowSensor 2021-05-03T21:01:03.037417+00:00 2021-05-03T21:10:05.730967+00:00 0:09:02.693550 24134 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T21:01:00.450208+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-03T20:00:00+00:00 EmrCreateJobFlowOperator 2021-05-03T21:00:40.615319+00:00 2021-05-03T21:00:42.338452+00:00 0:00:01.723133 24133 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-03T21:00:38.263165+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-03T20:00:00+00:00 PythonOperator 2021-05-03T21:00:20.594703+00:00 2021-05-03T21:00:23.665400+00:00 0:00:03.070697 24132 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-03T21:00:18.189804+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-03T19:00:00+00:00 TriggerDagRunOperator 2021-05-03T20:10:03.847193+00:00 2021-05-03T20:10:04.293757+00:00 0:00:00.446564 24124 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T20:10:01.257695+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-03T19:00:00+00:00 TriggerDagRunOperator 2021-05-03T20:10:03.715147+00:00 2021-05-03T20:10:04.230283+00:00 0:00:00.515136 24123 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T20:10:01.257750+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-03T19:00:00+00:00 EmrJobFlowSensor 2021-05-03T20:00:46.425286+00:00 2021-05-03T20:09:49.140441+00:00 0:09:02.715155 24119 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T20:00:44.220372+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-03T19:00:00+00:00 EmrCreateJobFlowOperator 2021-05-03T20:00:26.390428+00:00 2021-05-03T20:00:28.130706+00:00 0:00:01.740278 24118 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-03T20:00:24.201792+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-03T19:00:00+00:00 PythonOperator 2021-05-03T20:00:05.046372+00:00 2021-05-03T20:00:08.336299+00:00 0:00:03.289927 24117 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-03T20:00:02.184236+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-03T18:00:00+00:00 TriggerDagRunOperator 2021-05-03T19:10:04.035517+00:00 2021-05-03T19:10:04.454744+00:00 0:00:00.419227 24109 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T19:10:01.567910+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-03T18:00:00+00:00 TriggerDagRunOperator 2021-05-03T19:10:03.940045+00:00 2021-05-03T19:10:04.491801+00:00 0:00:00.551756 24108 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T19:10:01.567945+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-03T18:00:00+00:00 EmrJobFlowSensor 2021-05-03T19:00:54.991745+00:00 2021-05-03T19:09:57.755235+00:00 0:09:02.763490 24104 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T19:00:52.664232+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-03T18:00:00+00:00 EmrCreateJobFlowOperator 2021-05-03T19:00:33.054858+00:00 2021-05-03T19:00:34.833394+00:00 0:00:01.778536 24103 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-03T19:00:30.555323+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-03T18:00:00+00:00 PythonOperator 2021-05-03T19:00:12.889741+00:00 2021-05-03T19:00:15.955689+00:00 0:00:03.065948 24102 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-03T19:00:10.491734+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-03T17:00:00+00:00 TriggerDagRunOperator 2021-05-03T18:11:19.619280+00:00 2021-05-03T18:11:20.193482+00:00 0:00:00.574202 24094 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T18:11:16.558259+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-03T17:00:00+00:00 TriggerDagRunOperator 2021-05-03T18:11:19.608720+00:00 2021-05-03T18:11:20.057990+00:00 0:00:00.449270 24093 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T18:11:16.558220+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-03T17:00:00+00:00 EmrJobFlowSensor 2021-05-03T18:01:00.205802+00:00 2021-05-03T18:11:03.318352+00:00 0:10:03.112550 24089 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T18:00:57.566977+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-03T17:00:00+00:00 EmrCreateJobFlowOperator 2021-05-03T18:00:37.626802+00:00 2021-05-03T18:00:39.371965+00:00 0:00:01.745163 24088 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-03T18:00:35.468268+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-03T17:00:00+00:00 PythonOperator 2021-05-03T18:00:17.952520+00:00 2021-05-03T18:00:21.033205+00:00 0:00:03.080685 24087 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-03T18:00:15.451419+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-03T16:00:00+00:00 TriggerDagRunOperator 2021-05-03T17:11:06.309051+00:00 2021-05-03T17:11:06.878515+00:00 0:00:00.569464 24079 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T17:11:03.844834+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-03T16:00:00+00:00 TriggerDagRunOperator 2021-05-03T17:11:06.212248+00:00 2021-05-03T17:11:06.662604+00:00 0:00:00.450356 24078 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T17:11:03.844783+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-03T16:00:00+00:00 EmrJobFlowSensor 2021-05-03T17:00:47.007405+00:00 2021-05-03T17:10:49.658714+00:00 0:10:02.651309 24074 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T17:00:44.751145+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-03T16:00:00+00:00 EmrCreateJobFlowOperator 2021-05-03T17:00:27.099841+00:00 2021-05-03T17:00:28.870966+00:00 0:00:01.771125 24073 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-03T17:00:24.684735+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-03T16:00:00+00:00 PythonOperator 2021-05-03T17:00:05.354213+00:00 2021-05-03T17:00:08.519013+00:00 0:00:03.164800 24072 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-03T17:00:02.740908+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-03T15:00:00+00:00 TriggerDagRunOperator 2021-05-03T16:11:25.610894+00:00 2021-05-03T16:11:26.174649+00:00 0:00:00.563755 24064 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T16:11:23.123003+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-03T15:00:00+00:00 TriggerDagRunOperator 2021-05-03T16:11:25.374198+00:00 2021-05-03T16:11:25.829256+00:00 0:00:00.455058 24063 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T16:11:23.122972+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-03T15:00:00+00:00 EmrJobFlowSensor 2021-05-03T16:01:00.744495+00:00 2021-05-03T16:11:03.728119+00:00 0:10:02.983624 24059 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T16:00:58.175164+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-03T15:00:00+00:00 EmrCreateJobFlowOperator 2021-05-03T16:00:38.340678+00:00 2021-05-03T16:00:40.033016+00:00 0:00:01.692338 24058 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-03T16:00:36.044152+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-03T15:00:00+00:00 PythonOperator 2021-05-03T16:00:18.352504+00:00 2021-05-03T16:00:21.399473+00:00 0:00:03.046969 24057 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-03T16:00:15.999266+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-03T14:00:00+00:00 TriggerDagRunOperator 2021-05-03T15:10:24.070773+00:00 2021-05-03T15:10:24.619999+00:00 0:00:00.549226 24049 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T15:10:21.744095+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-03T14:00:00+00:00 TriggerDagRunOperator 2021-05-03T15:10:23.993486+00:00 2021-05-03T15:10:24.404867+00:00 0:00:00.411381 24048 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T15:10:21.744128+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-03T14:00:00+00:00 EmrJobFlowSensor 2021-05-03T15:01:07.319392+00:00 2021-05-03T15:10:09.986973+00:00 0:09:02.667581 24044 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T15:01:04.961653+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-03T14:00:00+00:00 EmrCreateJobFlowOperator 2021-05-03T15:00:45.248470+00:00 2021-05-03T15:00:46.937665+00:00 0:00:01.689195 24043 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-03T15:00:42.868081+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-03T14:00:00+00:00 PythonOperator 2021-05-03T15:00:23.665381+00:00 2021-05-03T15:00:26.759754+00:00 0:00:03.094373 24042 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-03T15:00:20.852280+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-03T13:00:00+00:00 TriggerDagRunOperator 2021-05-03T14:10:25.203312+00:00 2021-05-03T14:10:25.746547+00:00 0:00:00.543235 24034 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T14:10:22.566977+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-03T13:00:00+00:00 TriggerDagRunOperator 2021-05-03T14:10:25.112403+00:00 2021-05-03T14:10:25.523811+00:00 0:00:00.411408 24033 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T14:10:22.566899+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-03T13:00:00+00:00 EmrJobFlowSensor 2021-05-03T14:01:09.852122+00:00 2021-05-03T14:10:12.637439+00:00 0:09:02.785317 24029 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T14:01:07.573612+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-03T13:00:00+00:00 EmrCreateJobFlowOperator 2021-05-03T14:00:49.839626+00:00 2021-05-03T14:00:51.646057+00:00 0:00:01.806431 24028 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-03T14:00:47.520055+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-03T13:00:00+00:00 PythonOperator 2021-05-03T14:00:28.487591+00:00 2021-05-03T14:00:31.641197+00:00 0:00:03.153606 24027 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-03T14:00:25.555863+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-03T12:00:00+00:00 TriggerDagRunOperator 2021-05-03T13:10:23.035691+00:00 2021-05-03T13:10:23.561504+00:00 0:00:00.525813 24019 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T13:10:20.619700+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-03T12:00:00+00:00 TriggerDagRunOperator 2021-05-03T13:10:22.875668+00:00 2021-05-03T13:10:23.305732+00:00 0:00:00.430064 24018 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T13:10:20.619668+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-03T12:00:00+00:00 EmrJobFlowSensor 2021-05-03T13:01:08.001807+00:00 2021-05-03T13:10:10.548373+00:00 0:09:02.546566 24014 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T13:01:05.838213+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-03T12:00:00+00:00 EmrCreateJobFlowOperator 2021-05-03T13:00:46.144364+00:00 2021-05-03T13:00:47.831764+00:00 0:00:01.687400 24013 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-03T13:00:43.872391+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-03T12:00:00+00:00 PythonOperator 2021-05-03T13:00:24.687924+00:00 2021-05-03T13:00:27.751518+00:00 0:00:03.063594 24012 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-03T13:00:21.860927+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-03T11:00:00+00:00 TriggerDagRunOperator 2021-05-03T12:10:15.710379+00:00 2021-05-03T12:10:16.142160+00:00 0:00:00.431781 24004 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T12:10:13.183528+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-03T11:00:00+00:00 TriggerDagRunOperator 2021-05-03T12:10:15.704781+00:00 2021-05-03T12:10:16.250992+00:00 0:00:00.546211 24003 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T12:10:13.183563+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-03T11:00:00+00:00 EmrJobFlowSensor 2021-05-03T12:00:54.390648+00:00 2021-05-03T12:09:57.054966+00:00 0:09:02.664318 23999 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T12:00:52.120105+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-03T11:00:00+00:00 EmrCreateJobFlowOperator 2021-05-03T12:00:32.311631+00:00 2021-05-03T12:00:34.008799+00:00 0:00:01.697168 23998 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-03T12:00:30.100613+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-03T11:00:00+00:00 PythonOperator 2021-05-03T12:00:10.437916+00:00 2021-05-03T12:00:13.476308+00:00 0:00:03.038392 23997 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-03T12:00:08.076038+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-03T10:00:00+00:00 TriggerDagRunOperator 2021-05-03T11:10:30.670688+00:00 2021-05-03T11:10:31.199323+00:00 0:00:00.528635 23989 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T11:10:27.617869+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-03T10:00:00+00:00 TriggerDagRunOperator 2021-05-03T11:10:30.424859+00:00 2021-05-03T11:10:30.872919+00:00 0:00:00.448060 23988 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T11:10:27.617836+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-03T10:00:00+00:00 EmrJobFlowSensor 2021-05-03T11:01:03.039972+00:00 2021-05-03T11:10:05.737358+00:00 0:09:02.697386 23984 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T11:01:00.788277+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-03T10:00:00+00:00 EmrCreateJobFlowOperator 2021-05-03T11:00:40.906190+00:00 2021-05-03T11:00:42.650798+00:00 0:00:01.744608 23983 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-03T11:00:38.773702+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-03T10:00:00+00:00 PythonOperator 2021-05-03T11:00:16.922240+00:00 2021-05-03T11:00:19.958570+00:00 0:00:03.036330 23982 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-03T11:00:14.695478+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-03T09:00:00+00:00 TriggerDagRunOperator 2021-05-03T10:10:50.587197+00:00 2021-05-03T10:10:51.021120+00:00 0:00:00.433923 23975 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T10:10:47.497050+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-03T09:00:00+00:00 TriggerDagRunOperator 2021-05-03T10:10:50.390295+00:00 2021-05-03T10:10:50.938435+00:00 0:00:00.548140 23974 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T10:10:47.497007+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-03T09:00:00+00:00 EmrJobFlowSensor 2021-05-03T10:01:02.130368+00:00 2021-05-03T10:10:05.101669+00:00 0:09:02.971301 23969 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T10:00:59.762954+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-03T09:00:00+00:00 EmrCreateJobFlowOperator 2021-05-03T10:00:39.815664+00:00 2021-05-03T10:00:41.550519+00:00 0:00:01.734855 23968 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-03T10:00:37.585258+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-03T09:00:00+00:00 PythonOperator 2021-05-03T10:00:17.861467+00:00 2021-05-03T10:00:20.931274+00:00 0:00:03.069807 23967 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-03T10:00:15.520863+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-03T08:00:00+00:00 TriggerDagRunOperator 2021-05-03T09:11:24.777051+00:00 2021-05-03T09:11:25.200375+00:00 0:00:00.423324 23960 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T09:11:22.186595+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-03T08:00:00+00:00 TriggerDagRunOperator 2021-05-03T09:11:24.776934+00:00 2021-05-03T09:11:25.310604+00:00 0:00:00.533670 23959 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T09:11:22.186641+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-03T08:00:00+00:00 EmrJobFlowSensor 2021-05-03T09:01:05.999036+00:00 2021-05-03T09:11:08.907666+00:00 0:10:02.908630 23954 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T09:01:03.658405+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-03T08:00:00+00:00 EmrCreateJobFlowOperator 2021-05-03T09:00:41.811198+00:00 2021-05-03T09:00:43.513066+00:00 0:00:01.701868 23953 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-03T09:00:39.584482+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-03T08:00:00+00:00 PythonOperator 2021-05-03T09:00:21.742881+00:00 2021-05-03T09:00:24.865800+00:00 0:00:03.122919 23952 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-03T09:00:19.495816+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-03T07:00:00+00:00 TriggerDagRunOperator 2021-05-03T08:11:17.380300+00:00 2021-05-03T08:11:17.940128+00:00 0:00:00.559828 23945 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T08:11:14.560281+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-03T07:00:00+00:00 TriggerDagRunOperator 2021-05-03T08:11:17.336387+00:00 2021-05-03T08:11:17.771167+00:00 0:00:00.434780 23944 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T08:11:14.560237+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-03T07:00:00+00:00 EmrJobFlowSensor 2021-05-03T08:00:56.200221+00:00 2021-05-03T08:10:58.998178+00:00 0:10:02.797957 23939 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T08:00:53.790277+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-03T07:00:00+00:00 EmrCreateJobFlowOperator 2021-05-03T08:00:33.988847+00:00 2021-05-03T08:00:35.713696+00:00 0:00:01.724849 23938 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-03T08:00:31.670516+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-03T07:00:00+00:00 PythonOperator 2021-05-03T08:00:13.811622+00:00 2021-05-03T08:00:16.896241+00:00 0:00:03.084619 23937 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-03T08:00:11.652809+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-03T06:00:00+00:00 TriggerDagRunOperator 2021-05-03T07:10:10.408076+00:00 2021-05-03T07:10:10.928597+00:00 0:00:00.520521 23930 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T07:10:08.014257+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-03T06:00:00+00:00 TriggerDagRunOperator 2021-05-03T07:10:10.275396+00:00 2021-05-03T07:10:10.706551+00:00 0:00:00.431155 23929 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T07:10:08.014225+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-03T06:00:00+00:00 EmrJobFlowSensor 2021-05-03T07:00:51.858238+00:00 2021-05-03T07:09:54.547496+00:00 0:09:02.689258 23924 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T07:00:49.471983+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-03T06:00:00+00:00 EmrCreateJobFlowOperator 2021-05-03T07:00:29.713007+00:00 2021-05-03T07:00:31.438663+00:00 0:00:01.725656 23923 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-03T07:00:27.421779+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-03T06:00:00+00:00 PythonOperator 2021-05-03T07:00:10.040827+00:00 2021-05-03T07:00:13.138097+00:00 0:00:03.097270 23922 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-03T07:00:07.397572+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-03T05:00:00+00:00 TriggerDagRunOperator 2021-05-03T06:10:34.875523+00:00 2021-05-03T06:10:35.488395+00:00 0:00:00.612872 23913 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T06:10:32.249367+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-03T05:00:00+00:00 TriggerDagRunOperator 2021-05-03T06:10:34.655164+00:00 2021-05-03T06:10:35.363709+00:00 0:00:00.708545 23912 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T06:10:32.249395+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-03T05:00:00+00:00 EmrJobFlowSensor 2021-05-03T06:01:23.902695+00:00 2021-05-03T06:10:26.440853+00:00 0:09:02.538158 23908 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T06:01:21.384765+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-03T05:00:00+00:00 EmrCreateJobFlowOperator 2021-05-03T06:00:42.195687+00:00 2021-05-03T06:00:43.874104+00:00 0:00:01.678417 23906 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-03T06:00:39.857206+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-03T05:00:00+00:00 PythonOperator 2021-05-03T06:00:19.979813+00:00 2021-05-03T06:00:23.027908+00:00 0:00:03.048095 23905 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-03T06:00:17.746700+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-03T04:00:00+00:00 TriggerDagRunOperator 2021-05-03T05:11:58.397404+00:00 2021-05-03T05:11:58.881770+00:00 0:00:00.484366 23898 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T05:11:55.768368+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-03T04:00:00+00:00 TriggerDagRunOperator 2021-05-03T05:11:58.276378+00:00 2021-05-03T05:11:58.859149+00:00 0:00:00.582771 23897 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T05:11:55.768418+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-03T04:00:00+00:00 EmrJobFlowSensor 2021-05-03T05:01:32.515174+00:00 2021-05-03T05:11:35.268736+00:00 0:10:02.753562 23893 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T05:01:30.253721+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-03T04:00:00+00:00 EmrCreateJobFlowOperator 2021-05-03T05:01:10.334253+00:00 2021-05-03T05:01:12.176746+00:00 0:00:01.842493 23892 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-03T05:01:08.117478+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-03T04:00:00+00:00 PythonOperator 2021-05-03T05:00:50.835409+00:00 2021-05-03T05:00:53.902191+00:00 0:00:03.066782 23891 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-03T05:00:48.016203+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-03T03:00:00+00:00 TriggerDagRunOperator 2021-05-03T04:09:08.129224+00:00 2021-05-03T04:09:08.690983+00:00 0:00:00.561759 23883 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T04:09:05.544373+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-03T03:00:00+00:00 TriggerDagRunOperator 2021-05-03T04:09:07.938592+00:00 2021-05-03T04:09:08.445195+00:00 0:00:00.506603 23882 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T04:09:05.544420+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-03T03:00:00+00:00 EmrJobFlowSensor 2021-05-03T04:00:59.008839+00:00 2021-05-03T04:09:01.650627+00:00 0:08:02.641788 23878 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T04:00:56.540853+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-03T03:00:00+00:00 EmrCreateJobFlowOperator 2021-05-03T04:00:36.794078+00:00 2021-05-03T04:00:38.568155+00:00 0:00:01.774077 23877 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-03T04:00:34.461922+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-03T03:00:00+00:00 PythonOperator 2021-05-03T04:00:16.744996+00:00 2021-05-03T04:00:19.739164+00:00 0:00:02.994168 23876 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-03T04:00:14.335625+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-03T02:00:00+00:00 TriggerDagRunOperator 2021-05-03T03:10:20.560315+00:00 2021-05-03T03:10:20.985082+00:00 0:00:00.424767 23868 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T03:10:17.875303+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-03T02:00:00+00:00 TriggerDagRunOperator 2021-05-03T03:10:20.299673+00:00 2021-05-03T03:10:20.822111+00:00 0:00:00.522438 23867 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T03:10:17.875337+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-03T02:00:00+00:00 EmrJobFlowSensor 2021-05-03T03:01:02.620243+00:00 2021-05-03T03:10:05.383760+00:00 0:09:02.763517 23863 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T03:01:00.400249+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-03T02:00:00+00:00 EmrCreateJobFlowOperator 2021-05-03T03:00:40.796385+00:00 2021-05-03T03:00:42.544458+00:00 0:00:01.748073 23862 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-03T03:00:38.372557+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-03T02:00:00+00:00 PythonOperator 2021-05-03T03:00:20.942948+00:00 2021-05-03T03:00:23.976662+00:00 0:00:03.033714 23861 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-03T03:00:18.369564+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-03T01:00:00+00:00 TriggerDagRunOperator 2021-05-03T02:09:18.846944+00:00 2021-05-03T02:09:19.378815+00:00 0:00:00.531871 23853 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T02:09:16.354115+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-03T01:00:00+00:00 TriggerDagRunOperator 2021-05-03T02:09:18.735301+00:00 2021-05-03T02:09:19.173786+00:00 0:00:00.438485 23852 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T02:09:16.354162+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-03T01:00:00+00:00 EmrJobFlowSensor 2021-05-03T02:01:05.855195+00:00 2021-05-03T02:09:08.599934+00:00 0:08:02.744739 23848 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T02:01:03.383519+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-03T01:00:00+00:00 EmrCreateJobFlowOperator 2021-05-03T02:00:41.874531+00:00 2021-05-03T02:00:43.576678+00:00 0:00:01.702147 23847 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-03T02:00:39.362210+00:00 2 default_pool