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-01T09:00:00+00:00 PythonOperator 2021-05-01T10:00:05.903326+00:00 2021-05-01T10:00:08.998633+00:00 0:00:03.095307 23241 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-01T10:00:03.120735+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-01T08:00:00+00:00 TriggerDagRunOperator 2021-05-01T09:10:30.306709+00:00 2021-05-01T09:10:30.765092+00:00 0:00:00.458383 23233 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T09:10:27.662813+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-01T08:00:00+00:00 TriggerDagRunOperator 2021-05-01T09:10:30.205268+00:00 2021-05-01T09:10:30.803657+00:00 0:00:00.598389 23232 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T09:10:27.662858+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-01T08:00:00+00:00 EmrJobFlowSensor 2021-05-01T09:01:04.913245+00:00 2021-05-01T09:10:07.727010+00:00 0:09:02.813765 23228 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T09:01:02.489833+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-01T08:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T09:00:38.774662+00:00 2021-05-01T09:00:40.517509+00:00 0:00:01.742847 23227 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-01T09:00:36.421025+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-01T08:00:00+00:00 PythonOperator 2021-05-01T09:00:17.135343+00:00 2021-05-01T09:00:20.165138+00:00 0:00:03.029795 23226 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-01T09:00:14.403824+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-01T07:00:00+00:00 TriggerDagRunOperator 2021-05-01T08:11:16.139584+00:00 2021-05-01T08:11:16.568036+00:00 0:00:00.428452 23218 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T08:11:13.571127+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-01T07:00:00+00:00 TriggerDagRunOperator 2021-05-01T08:11:16.118563+00:00 2021-05-01T08:11:16.681737+00:00 0:00:00.563174 23217 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T08:11:13.571081+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-01T07:00:00+00:00 EmrJobFlowSensor 2021-05-01T08:00:54.852562+00:00 2021-05-01T08:10:57.679307+00:00 0:10:02.826745 23213 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T08:00:52.493675+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-01T07:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T08:00:32.625056+00:00 2021-05-01T08:00:34.364927+00:00 0:00:01.739871 23212 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-01T08:00:30.467082+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-01T07:00:00+00:00 PythonOperator 2021-05-01T08:00:12.746087+00:00 2021-05-01T08:00:15.807552+00:00 0:00:03.061465 23211 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-01T08:00:10.449321+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-01T06:00:00+00:00 TriggerDagRunOperator 2021-05-01T07:10:04.996097+00:00 2021-05-01T07:10:05.631537+00:00 0:00:00.635440 23203 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T07:10:02.268640+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-01T06:00:00+00:00 TriggerDagRunOperator 2021-05-01T07:10:04.890088+00:00 2021-05-01T07:10:05.450724+00:00 0:00:00.560636 23202 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T07:10:02.268590+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-01T06:00:00+00:00 EmrJobFlowSensor 2021-05-01T07:00:51.397592+00:00 2021-05-01T07:09:53.996733+00:00 0:09:02.599141 23198 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T07:00:49.198857+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-01T06:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T07:00:31.647007+00:00 2021-05-01T07:00:33.363461+00:00 0:00:01.716454 23197 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-01T07:00:29.259288+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-01T06:00:00+00:00 PythonOperator 2021-05-01T07:00:09.635911+00:00 2021-05-01T07:00:12.753292+00:00 0:00:03.117381 23196 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-01T07:00:07.165280+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-01T05:00:00+00:00 TriggerDagRunOperator 2021-05-01T06:16:31.426971+00:00 2021-05-01T06:16:31.849781+00:00 0:00:00.422810 23189 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T06:16:28.274725+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-01T05:00:00+00:00 TriggerDagRunOperator 2021-05-01T06:16:31.400414+00:00 2021-05-01T06:16:31.968917+00:00 0:00:00.568503 23188 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T06:16:28.274782+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-01T05:00:00+00:00 EmrJobFlowSensor 2021-05-01T06:01:04.879032+00:00 2021-05-01T06:11:07.808321+00:00 0:10:02.929289 23183 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T06:01:02.483518+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-01T05:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T06:00:42.815580+00:00 2021-05-01T06:00:44.503486+00:00 0:00:01.687906 23182 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-01T06:00:40.479582+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-01T05:00:00+00:00 PythonOperator 2021-05-01T06:00:20.842263+00:00 2021-05-01T06:00:24.164434+00:00 0:00:03.322171 23181 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-01T06:00:18.443622+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-01T04:00:00+00:00 TriggerDagRunOperator 2021-05-01T05:10:46.798643+00:00 2021-05-01T05:10:47.558893+00:00 0:00:00.760250 23173 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T05:10:43.166001+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-01T04:00:00+00:00 TriggerDagRunOperator 2021-05-01T05:10:45.910861+00:00 2021-05-01T05:10:46.439814+00:00 0:00:00.528953 23172 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T05:10:43.165975+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-01T04:00:00+00:00 EmrJobFlowSensor 2021-05-01T05:00:56.302292+00:00 2021-05-01T05:09:58.943719+00:00 0:09:02.641427 23168 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T05:00:54.154645+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-01T04:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T05:00:36.315201+00:00 2021-05-01T05:00:38.093704+00:00 0:00:01.778503 23167 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-01T05:00:34.138202+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-01T04:00:00+00:00 PythonOperator 2021-05-01T05:00:12.357246+00:00 2021-05-01T05:00:15.434444+00:00 0:00:03.077198 23166 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-01T05:00:10.115465+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-01T03:00:00+00:00 TriggerDagRunOperator 2021-05-01T04:09:27.371233+00:00 2021-05-01T04:09:27.957012+00:00 0:00:00.585779 23159 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T04:09:25.029201+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-01T03:00:00+00:00 TriggerDagRunOperator 2021-05-01T04:09:27.342644+00:00 2021-05-01T04:09:27.774218+00:00 0:00:00.431574 23158 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T04:09:25.029233+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-01T03:00:00+00:00 EmrJobFlowSensor 2021-05-01T04:01:06.563440+00:00 2021-05-01T04:09:09.294253+00:00 0:08:02.730813 23153 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T04:01:04.287102+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-01T03:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T04:00:44.522540+00:00 2021-05-01T04:00:46.334785+00:00 0:00:01.812245 23152 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-01T04:00:42.206393+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-01T03:00:00+00:00 PythonOperator 2021-05-01T04:00:24.435858+00:00 2021-05-01T04:00:27.478239+00:00 0:00:03.042381 23151 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-01T04:00:22.185573+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-01T02:00:00+00:00 TriggerDagRunOperator 2021-05-01T03:14:35.392524+00:00 2021-05-01T03:14:35.822234+00:00 0:00:00.429710 23144 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T03:14:32.910697+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-01T02:00:00+00:00 TriggerDagRunOperator 2021-05-01T03:14:35.381091+00:00 2021-05-01T03:14:35.925097+00:00 0:00:00.544006 23143 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T03:14:32.910666+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-01T02:00:00+00:00 EmrJobFlowSensor 2021-05-01T03:04:22.174622+00:00 2021-05-01T03:14:25.150009+00:00 0:10:02.975387 23139 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T03:04:19.844054+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-01T02:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T03:04:01.931797+00:00 2021-05-01T03:04:03.823927+00:00 0:00:01.892130 23138 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-01T03:03:59.693151+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-01T02:00:00+00:00 PythonOperator 2021-05-01T03:03:39.927286+00:00 2021-05-01T03:03:43.035221+00:00 0:00:03.107935 23137 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-01T03:03:37.675411+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-01T01:00:00+00:00 TriggerDagRunOperator 2021-05-01T02:09:17.687441+00:00 2021-05-01T02:09:18.297225+00:00 0:00:00.609784 23129 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T02:09:15.345249+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-01T01:00:00+00:00 TriggerDagRunOperator 2021-05-01T02:09:17.626094+00:00 2021-05-01T02:09:18.047910+00:00 0:00:00.421816 23128 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T02:09:15.345285+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-01T01:00:00+00:00 EmrJobFlowSensor 2021-05-01T02:00:57.002527+00:00 2021-05-01T02:08:59.614606+00:00 0:08:02.612079 23124 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T02:00:54.581727+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-01T01:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T02:00:36.725251+00:00 2021-05-01T02:00:38.488600+00:00 0:00:01.763349 23123 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-01T02:00:34.513202+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-01T01:00:00+00:00 PythonOperator 2021-05-01T02:00:15.195674+00:00 2021-05-01T02:00:18.230652+00:00 0:00:03.034978 23122 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-01T02:00:12.499064+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-01T00:00:00+00:00 TriggerDagRunOperator 2021-05-01T01:10:06.719878+00:00 2021-05-01T01:10:07.124714+00:00 0:00:00.404836 23114 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T01:10:04.350249+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-01T00:00:00+00:00 TriggerDagRunOperator 2021-05-01T01:10:06.747199+00:00 2021-05-01T01:10:07.277285+00:00 0:00:00.530086 23113 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T01:10:04.350294+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-01T00:00:00+00:00 EmrJobFlowSensor 2021-05-01T01:00:47.795390+00:00 2021-05-01T01:09:50.655504+00:00 0:09:02.860114 23109 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T01:00:45.403298+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-01T00:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T01:00:25.753440+00:00 2021-05-01T01:00:27.550339+00:00 0:00:01.796899 23108 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-01T01:00:23.448673+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-01T00:00:00+00:00 PythonOperator 2021-05-01T01:00:05.786929+00:00 2021-05-01T01:00:08.959471+00:00 0:00:03.172542 23107 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-01T01:00:03.284924+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-30T23:00:00+00:00 TriggerDagRunOperator 2021-05-01T00:10:26.745954+00:00 2021-05-01T00:10:27.167718+00:00 0:00:00.421764 23099 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T00:10:24.256600+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-30T23:00:00+00:00 TriggerDagRunOperator 2021-05-01T00:10:26.682856+00:00 2021-05-01T00:10:27.241765+00:00 0:00:00.558909 23098 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T00:10:24.256556+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-30T23:00:00+00:00 EmrJobFlowSensor 2021-05-01T00:00:59.779748+00:00 2021-05-01T00:10:02.690361+00:00 0:09:02.910613 23094 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T00:00:57.317095+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-30T23:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T00:00:37.693082+00:00 2021-05-01T00:00:39.506689+00:00 0:00:01.813607 23093 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-01T00:00:35.359631+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-30T23:00:00+00:00 PythonOperator 2021-05-01T00:00:17.428374+00:00 2021-05-01T00:00:20.434764+00:00 0:00:03.006390 23092 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-01T00:00:15.235179+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-30T22:00:00+00:00 TriggerDagRunOperator 2021-04-30T23:11:42.995224+00:00 2021-04-30T23:11:43.504108+00:00 0:00:00.508884 23085 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T23:11:39.991744+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-30T22:00:00+00:00 TriggerDagRunOperator 2021-04-30T23:11:42.898280+00:00 2021-04-30T23:11:43.311148+00:00 0:00:00.412868 23084 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T23:11:39.991781+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-30T22:00:00+00:00 EmrJobFlowSensor 2021-04-30T23:01:05.759515+00:00 2021-04-30T23:11:08.589866+00:00 0:10:02.830351 23079 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T23:01:03.375441+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-30T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-30T23:00:43.789402+00:00 2021-04-30T23:00:45.523655+00:00 0:00:01.734253 23077 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-30T23:00:41.293351+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-30T22:00:00+00:00 PythonOperator 2021-04-30T23:00:19.468146+00:00 2021-04-30T23:00:22.527709+00:00 0:00:03.059563 23075 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-30T23:00:17.250208+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-30T21:00:00+00:00 TriggerDagRunOperator 2021-04-30T22:11:15.392660+00:00 2021-04-30T22:11:15.917748+00:00 0:00:00.525088 23067 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T22:11:12.372633+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-30T21:00:00+00:00 TriggerDagRunOperator 2021-04-30T22:11:15.255630+00:00 2021-04-30T22:11:15.682002+00:00 0:00:00.426372 23066 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T22:11:12.372674+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-30T21:00:00+00:00 EmrJobFlowSensor 2021-04-30T22:01:01.091548+00:00 2021-04-30T22:10:03.853073+00:00 0:09:02.761525 23061 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T22:00:58.922360+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-30T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-30T22:00:39.135203+00:00 2021-04-30T22:00:40.807471+00:00 0:00:01.672268 23060 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-30T22:00:36.904986+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-30T21:00:00+00:00 PythonOperator 2021-04-30T22:00:19.287681+00:00 2021-04-30T22:00:22.315011+00:00 0:00:03.027330 23059 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-30T22:00:16.885991+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-30T20:00:00+00:00 TriggerDagRunOperator 2021-04-30T21:09:30.681374+00:00 2021-04-30T21:09:31.234044+00:00 0:00:00.552670 23052 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T21:09:27.785094+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-30T20:00:00+00:00 TriggerDagRunOperator 2021-04-30T21:09:30.629408+00:00 2021-04-30T21:09:31.108396+00:00 0:00:00.478988 23051 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T21:09:27.785123+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-30T20:00:00+00:00 EmrJobFlowSensor 2021-04-30T21:01:02.010329+00:00 2021-04-30T21:09:04.732637+00:00 0:08:02.722308 23046 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T21:00:59.817623+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-30T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-30T21:00:42.074045+00:00 2021-04-30T21:00:43.798492+00:00 0:00:01.724447 23045 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-30T21:00:39.801112+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-30T20:00:00+00:00 PythonOperator 2021-04-30T21:00:20.263775+00:00 2021-04-30T21:00:23.313071+00:00 0:00:03.049296 23044 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-30T21:00:17.782982+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-30T19:00:00+00:00 TriggerDagRunOperator 2021-04-30T20:11:07.645438+00:00 2021-04-30T20:11:08.175245+00:00 0:00:00.529807 23037 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T20:11:04.957567+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-30T19:00:00+00:00 TriggerDagRunOperator 2021-04-30T20:11:07.428018+00:00 2021-04-30T20:11:07.858819+00:00 0:00:00.430801 23036 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T20:11:04.957525+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-30T19:00:00+00:00 EmrJobFlowSensor 2021-04-30T20:00:56.405169+00:00 2021-04-30T20:10:59.222666+00:00 0:10:02.817497 23031 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T20:00:54.161371+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-30T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-30T20:00:34.466392+00:00 2021-04-30T20:00:36.292487+00:00 0:00:01.826095 23030 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-30T20:00:32.083173+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-30T19:00:00+00:00 PythonOperator 2021-04-30T20:00:12.258237+00:00 2021-04-30T20:00:15.291525+00:00 0:00:03.033288 23029 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-30T20:00:10.018906+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-30T18:00:00+00:00 TriggerDagRunOperator 2021-04-30T19:11:06.369249+00:00 2021-04-30T19:11:06.825672+00:00 0:00:00.456423 23022 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T19:11:03.519697+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-30T18:00:00+00:00 TriggerDagRunOperator 2021-04-30T19:11:06.326385+00:00 2021-04-30T19:11:06.928795+00:00 0:00:00.602410 23021 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T19:11:03.519726+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-30T18:00:00+00:00 EmrJobFlowSensor 2021-04-30T19:00:56.924354+00:00 2021-04-30T19:10:59.685594+00:00 0:10:02.761240 23016 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T19:00:54.659873+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-30T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-30T19:00:34.998896+00:00 2021-04-30T19:00:36.896017+00:00 0:00:01.897121 23015 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-30T19:00:32.591604+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-30T18:00:00+00:00 PythonOperator 2021-04-30T19:00:12.811090+00:00 2021-04-30T19:00:15.879240+00:00 0:00:03.068150 23014 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-30T19:00:10.504081+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-30T17:00:00+00:00 TriggerDagRunOperator 2021-04-30T18:10:29.719417+00:00 2021-04-30T18:10:30.244830+00:00 0:00:00.525413 23007 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T18:10:27.245383+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-30T17:00:00+00:00 TriggerDagRunOperator 2021-04-30T18:10:29.460414+00:00 2021-04-30T18:10:29.874875+00:00 0:00:00.414461 23006 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T18:10:27.245344+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-30T17:00:00+00:00 EmrJobFlowSensor 2021-04-30T18:01:06.415474+00:00 2021-04-30T18:10:09.113581+00:00 0:09:02.698107 23001 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T18:01:04.289441+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-30T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-30T18:00:46.389158+00:00 2021-04-30T18:00:48.095177+00:00 0:00:01.706019 23000 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-30T18:00:44.228416+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-30T17:00:00+00:00 PythonOperator 2021-04-30T18:00:25.109305+00:00 2021-04-30T18:00:28.095525+00:00 0:00:02.986220 22999 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-30T18:00:22.268493+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-30T16:00:00+00:00 TriggerDagRunOperator 2021-04-30T17:11:26.168264+00:00 2021-04-30T17:11:26.566479+00:00 0:00:00.398215 22992 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T17:11:23.484809+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-30T16:00:00+00:00 TriggerDagRunOperator 2021-04-30T17:11:25.799829+00:00 2021-04-30T17:11:26.344693+00:00 0:00:00.544864 22991 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T17:11:23.484838+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-30T16:00:00+00:00 EmrJobFlowSensor 2021-04-30T17:02:14.744482+00:00 2021-04-30T17:11:17.432407+00:00 0:09:02.687925 22987 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T17:02:12.380405+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-30T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-30T17:01:54.541232+00:00 2021-04-30T17:01:56.371092+00:00 0:00:01.829860 22986 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-30T17:01:52.305273+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-30T16:00:00+00:00 PythonOperator 2021-04-30T17:01:32.933052+00:00 2021-04-30T17:01:35.967719+00:00 0:00:03.034667 22985 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-30T17:01:30.288222+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-30T15:00:00+00:00 TriggerDagRunOperator 2021-04-30T16:18:19.714108+00:00 2021-04-30T16:18:20.263511+00:00 0:00:00.549403 22977 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T16:18:17.152235+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-30T15:00:00+00:00 TriggerDagRunOperator 2021-04-30T16:18:19.468672+00:00 2021-04-30T16:18:19.878624+00:00 0:00:00.409952 22976 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T16:18:17.152263+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-30T15:00:00+00:00 EmrJobFlowSensor 2021-04-30T16:00:59.645996+00:00 2021-04-30T16:18:03.616238+00:00 0:17:03.970242 22972 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T16:00:57.060913+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-30T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-30T16:00:37.116585+00:00 2021-04-30T16:00:38.802683+00:00 0:00:01.686098 22971 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-30T16:00:34.927303+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-30T15:00:00+00:00 PythonOperator 2021-04-30T16:00:17.533719+00:00 2021-04-30T16:00:20.549214+00:00 0:00:03.015495 22970 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-30T16:00:14.907683+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-30T14:00:00+00:00 TriggerDagRunOperator 2021-04-30T15:10:13.175897+00:00 2021-04-30T15:10:13.723182+00:00 0:00:00.547285 22962 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T15:10:10.865267+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-30T14:00:00+00:00 TriggerDagRunOperator 2021-04-30T15:10:13.122230+00:00 2021-04-30T15:10:13.527558+00:00 0:00:00.405328 22961 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T15:10:10.865234+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-30T14:00:00+00:00 EmrJobFlowSensor 2021-04-30T15:00:56.302548+00:00 2021-04-30T15:09:59.080655+00:00 0:09:02.778107 22957 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T15:00:53.940085+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-30T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-30T15:00:32.410923+00:00 2021-04-30T15:00:34.292844+00:00 0:00:01.881921 22956 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-30T15:00:29.971081+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-30T14:00:00+00:00 PythonOperator 2021-04-30T15:00:10.189168+00:00 2021-04-30T15:00:13.194729+00:00 0:00:03.005561 22955 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-30T15:00:07.899928+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-30T13:00:00+00:00 TriggerDagRunOperator 2021-04-30T14:22:44.557654+00:00 2021-04-30T14:22:45.141117+00:00 0:00:00.583463 22948 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T14:22:42.194950+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-30T13:00:00+00:00 TriggerDagRunOperator 2021-04-30T14:22:44.420159+00:00 2021-04-30T14:22:44.834822+00:00 0:00:00.414663 22947 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T14:22:42.194923+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-30T13:00:00+00:00 EmrJobFlowSensor 2021-04-30T14:12:25.664062+00:00 2021-04-30T14:22:28.571773+00:00 0:10:02.907711 22945 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T14:12:23.350617+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-30T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-30T14:12:03.452087+00:00 2021-04-30T14:12:05.201763+00:00 0:00:01.749676 22943 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-30T14:12:01.231488+00:00 2 default_pool