Task Instances

  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_cluster_and_add_emr_steps 2021-04-17T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T23:00:44.362971+00:00 2021-04-17T23:00:46.178089+00:00 0:00:01.815118 18337 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-17T23:00:41.947729+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-17T22:00:00+00:00 PythonOperator 2021-04-17T23:00:20.585486+00:00 2021-04-17T23:00:23.501012+00:00 0:00:02.915526 18336 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-17T23:00:17.852012+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-17T21:00:00+00:00 EmrJobFlowSensor 2021-04-17T22:11:12.039267+00:00 2021-04-17T22:21:14.807039+00:00 0:10:02.767772 18334 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T22:11:09.806053+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-17T21:00:00+00:00 EmrJobFlowSensor 2021-04-17T22:11:12.074407+00:00 2021-04-17T22:21:15.107040+00:00 0:10:03.032633 18333 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T22:11:09.806087+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-17T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T22:10:52.681458+00:00 2021-04-17T22:10:54.312934+00:00 0:00:01.631476 18332 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T22:10:49.789086+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-17T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T22:10:50.223313+00:00 2021-04-17T22:10:52.627849+00:00 0:00:02.404536 18331 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T22:10:47.796520+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-17T21:00:00+00:00 PythonOperator 2021-04-17T22:10:30.335836+00:00 2021-04-17T22:10:33.274457+00:00 0:00:02.938621 18330 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T22:10:27.762261+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-17T21:00:00+00:00 PythonOperator 2021-04-17T22:10:28.660133+00:00 2021-04-17T22:10:31.938217+00:00 0:00:03.278084 18329 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T22:10:25.845622+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-17T21:00:00+00:00 TriggerDagRunOperator 2021-04-17T22:10:20.289612+00:00 2021-04-17T22:10:20.811499+00:00 0:00:00.521887 18328 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T22:10:17.779301+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-17T21:00:00+00:00 TriggerDagRunOperator 2021-04-17T22:10:20.095862+00:00 2021-04-17T22:10:20.509912+00:00 0:00:00.414050 18327 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T22:10:17.779345+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-17T21:05:00+00:00 EmrJobFlowSensor 2021-04-17T22:05:59.417005+00:00 2021-04-17T22:15:02.012842+00:00 0:09:02.595837 18326 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T22:05:57.293537+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-17T21:05:00+00:00 EmrCreateJobFlowOperator 2021-04-17T22:05:39.569055+00:00 2021-04-17T22:05:41.324137+00:00 0:00:01.755082 18325 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T22:05:37.267275+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-17T21:05:00+00:00 PythonOperator 2021-04-17T22:05:17.371768+00:00 2021-04-17T22:05:20.289638+00:00 0:00:02.917870 18324 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T22:05:15.237864+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-17T21:00:00+00:00 EmrJobFlowSensor 2021-04-17T22:01:03.123502+00:00 2021-04-17T22:10:05.807264+00:00 0:09:02.683762 18323 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T22:01:00.642421+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-17T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T22:00:40.792746+00:00 2021-04-17T22:00:42.493618+00:00 0:00:01.700872 18322 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-17T22:00:38.622435+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-17T21:00:00+00:00 PythonOperator 2021-04-17T22:00:21.316220+00:00 2021-04-17T22:00:24.253279+00:00 0:00:02.937059 18321 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-17T22:00:18.598072+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-17T20:00:00+00:00 EmrJobFlowSensor 2021-04-17T21:10:41.210324+00:00 2021-04-17T21:20:44.720803+00:00 0:10:03.510479 18319 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T21:10:38.961687+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-17T20:00:00+00:00 EmrJobFlowSensor 2021-04-17T21:10:33.689070+00:00 2021-04-17T21:20:36.432184+00:00 0:10:02.743114 18318 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T21:10:30.968463+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-17T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T21:10:17.301626+00:00 2021-04-17T21:10:19.575517+00:00 0:00:02.273891 18317 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T21:10:14.966123+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-17T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T21:10:11.293572+00:00 2021-04-17T21:10:13.392308+00:00 0:00:02.098736 18316 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T21:10:08.966575+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-17T20:00:00+00:00 PythonOperator 2021-04-17T21:09:57.428639+00:00 2021-04-17T21:10:00.571074+00:00 0:00:03.142435 18315 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T21:09:54.890625+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-17T20:00:00+00:00 PythonOperator 2021-04-17T21:09:51.459691+00:00 2021-04-17T21:09:54.594358+00:00 0:00:03.134667 18314 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T21:09:48.952726+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-17T20:00:00+00:00 TriggerDagRunOperator 2021-04-17T21:09:35.313477+00:00 2021-04-17T21:09:35.883553+00:00 0:00:00.570076 18313 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T21:09:32.858916+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-17T20:00:00+00:00 TriggerDagRunOperator 2021-04-17T21:09:35.229538+00:00 2021-04-17T21:09:35.711067+00:00 0:00:00.481529 18312 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T21:09:32.858958+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-17T20:05:00+00:00 EmrJobFlowSensor 2021-04-17T21:05:52.757903+00:00 2021-04-17T21:13:55.176304+00:00 0:08:02.418401 18311 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T21:05:50.556850+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-17T20:05:00+00:00 EmrCreateJobFlowOperator 2021-04-17T21:05:30.873251+00:00 2021-04-17T21:05:32.557238+00:00 0:00:01.683987 18310 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T21:05:28.645749+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-17T20:05:00+00:00 PythonOperator 2021-04-17T21:05:09.041487+00:00 2021-04-17T21:05:12.510199+00:00 0:00:03.468712 18309 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T21:05:06.640758+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-17T20:00:00+00:00 EmrJobFlowSensor 2021-04-17T21:01:10.304546+00:00 2021-04-17T21:09:13.211283+00:00 0:08:02.906737 18308 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T21:01:08.107003+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-17T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T21:00:48.659759+00:00 2021-04-17T21:00:50.464142+00:00 0:00:01.804383 18307 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-17T21:00:46.152348+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-17T20:00:00+00:00 PythonOperator 2021-04-17T21:00:25.213323+00:00 2021-04-17T21:00:28.430236+00:00 0:00:03.216913 18306 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-17T21:00:22.031821+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-17T19:00:00+00:00 EmrJobFlowSensor 2021-04-17T20:12:30.467938+00:00 2021-04-17T20:21:33.060920+00:00 0:09:02.592982 18304 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T20:12:28.208218+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-17T19:00:00+00:00 EmrJobFlowSensor 2021-04-17T20:12:22.425918+00:00 2021-04-17T20:22:25.332710+00:00 0:10:02.906792 18303 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T20:12:20.200874+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-17T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T20:12:10.388443+00:00 2021-04-17T20:12:12.104343+00:00 0:00:01.715900 18302 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T20:12:08.189250+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-17T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T20:12:00.742637+00:00 2021-04-17T20:12:02.668735+00:00 0:00:01.926098 18301 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T20:11:58.182486+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-17T19:00:00+00:00 PythonOperator 2021-04-17T20:11:48.519886+00:00 2021-04-17T20:11:51.883135+00:00 0:00:03.363249 18300 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T20:11:46.167127+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-17T19:00:00+00:00 PythonOperator 2021-04-17T20:11:40.394177+00:00 2021-04-17T20:11:43.786845+00:00 0:00:03.392668 18299 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T20:11:38.159481+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-17T19:00:00+00:00 TriggerDagRunOperator 2021-04-17T20:11:22.592645+00:00 2021-04-17T20:11:23.139149+00:00 0:00:00.546504 18298 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T20:11:20.147215+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-17T19:00:00+00:00 TriggerDagRunOperator 2021-04-17T20:11:22.378476+00:00 2021-04-17T20:11:22.808744+00:00 0:00:00.430268 18297 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T20:11:20.147248+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-17T19:05:00+00:00 EmrJobFlowSensor 2021-04-17T20:06:08.398428+00:00 2021-04-17T20:15:11.085553+00:00 0:09:02.687125 18296 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T20:06:05.631922+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-17T19:05:00+00:00 EmrCreateJobFlowOperator 2021-04-17T20:05:47.686681+00:00 2021-04-17T20:05:49.528962+00:00 0:00:01.842281 18295 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T20:05:45.557696+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-17T19:05:00+00:00 PythonOperator 2021-04-17T20:05:25.781469+00:00 2021-04-17T20:05:28.697302+00:00 0:00:02.915833 18294 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T20:05:23.537778+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-17T19:00:00+00:00 EmrJobFlowSensor 2021-04-17T20:01:07.402190+00:00 2021-04-17T20:11:10.202611+00:00 0:10:02.800421 18293 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T20:01:05.132164+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-17T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T20:00:45.393890+00:00 2021-04-17T20:00:47.214428+00:00 0:00:01.820538 18292 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-17T20:00:43.101108+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-17T19:00:00+00:00 PythonOperator 2021-04-17T20:00:23.847691+00:00 2021-04-17T20:00:26.849742+00:00 0:00:03.002051 18291 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-17T20:00:21.140668+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-17T18:00:00+00:00 EmrJobFlowSensor 2021-04-17T19:12:45.177653+00:00 2021-04-17T19:21:47.767459+00:00 0:09:02.589806 18289 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T19:12:42.941436+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-17T18:00:00+00:00 EmrJobFlowSensor 2021-04-17T19:12:37.409362+00:00 2021-04-17T19:21:40.206378+00:00 0:09:02.797016 18288 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T19:12:34.943792+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-17T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T19:12:21.094578+00:00 2021-04-17T19:12:22.839482+00:00 0:00:01.744904 18287 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T19:12:18.921798+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-17T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T19:12:03.285160+00:00 2021-04-17T19:12:05.101914+00:00 0:00:01.816754 18286 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T19:12:00.902288+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-17T18:00:00+00:00 PythonOperator 2021-04-17T19:11:55.267278+00:00 2021-04-17T19:11:58.533395+00:00 0:00:03.266117 18285 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T19:11:52.895221+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-17T18:00:00+00:00 PythonOperator 2021-04-17T19:11:39.888963+00:00 2021-04-17T19:11:42.797351+00:00 0:00:02.908388 18284 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T19:11:36.940850+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-17T18:00:00+00:00 TriggerDagRunOperator 2021-04-17T19:11:27.703337+00:00 2021-04-17T19:11:28.662558+00:00 0:00:00.959221 18283 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T19:11:24.765743+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-17T18:00:00+00:00 TriggerDagRunOperator 2021-04-17T19:11:27.489458+00:00 2021-04-17T19:11:28.227116+00:00 0:00:00.737658 18282 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T19:11:24.765688+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-17T18:05:00+00:00 EmrJobFlowSensor 2021-04-17T19:06:06.404175+00:00 2021-04-17T19:15:09.084741+00:00 0:09:02.680566 18281 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T19:06:04.240853+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-17T18:05:00+00:00 EmrCreateJobFlowOperator 2021-04-17T19:05:40.403337+00:00 2021-04-17T19:05:42.052843+00:00 0:00:01.649506 18280 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T19:05:38.223261+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-17T18:05:00+00:00 PythonOperator 2021-04-17T19:05:18.430338+00:00 2021-04-17T19:05:21.499083+00:00 0:00:03.068745 18279 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T19:05:16.189700+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-17T18:00:00+00:00 EmrJobFlowSensor 2021-04-17T19:01:04.277355+00:00 2021-04-17T19:11:07.286552+00:00 0:10:03.009197 18278 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T19:01:01.860087+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-17T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T19:00:42.275607+00:00 2021-04-17T19:00:44.024448+00:00 0:00:01.748841 18277 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-17T19:00:39.872065+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-17T18:00:00+00:00 PythonOperator 2021-04-17T19:00:20.155388+00:00 2021-04-17T19:00:23.061447+00:00 0:00:02.906059 18276 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-17T19:00:17.800756+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-17T17:00:00+00:00 EmrJobFlowSensor 2021-04-17T18:11:06.759282+00:00 2021-04-17T18:21:10.398913+00:00 0:10:03.639631 18274 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T18:11:04.449238+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-17T17:00:00+00:00 EmrJobFlowSensor 2021-04-17T18:11:00.993712+00:00 2021-04-17T18:21:03.850765+00:00 0:10:02.857053 18273 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T18:10:58.461265+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-17T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T18:10:46.502053+00:00 2021-04-17T18:10:48.160808+00:00 0:00:01.658755 18272 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T18:10:44.370627+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-17T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T18:10:40.588626+00:00 2021-04-17T18:10:42.420410+00:00 0:00:01.831784 18271 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T18:10:38.339691+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-17T17:00:00+00:00 PythonOperator 2021-04-17T18:10:25.072833+00:00 2021-04-17T18:10:28.382607+00:00 0:00:03.309774 18270 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T18:10:22.331233+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-17T17:00:00+00:00 PythonOperator 2021-04-17T18:10:19.312312+00:00 2021-04-17T18:10:22.612590+00:00 0:00:03.300278 18269 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T18:10:16.364003+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-17T17:00:00+00:00 TriggerDagRunOperator 2021-04-17T18:10:12.923913+00:00 2021-04-17T18:10:13.346640+00:00 0:00:00.422727 18268 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T18:10:10.317371+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-17T17:00:00+00:00 TriggerDagRunOperator 2021-04-17T18:10:12.825029+00:00 2021-04-17T18:10:13.378784+00:00 0:00:00.553755 18267 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T18:10:10.317403+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-17T17:05:00+00:00 EmrJobFlowSensor 2021-04-17T18:05:52.084069+00:00 2021-04-17T18:14:54.644129+00:00 0:09:02.560060 18266 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T18:05:49.930281+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-17T17:05:00+00:00 EmrCreateJobFlowOperator 2021-04-17T18:05:32.192334+00:00 2021-04-17T18:05:33.998948+00:00 0:00:01.806614 18265 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T18:05:29.918572+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-17T17:05:00+00:00 PythonOperator 2021-04-17T18:05:10.183738+00:00 2021-04-17T18:05:13.271557+00:00 0:00:03.087819 18264 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T18:05:07.952177+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-17T17:00:00+00:00 EmrJobFlowSensor 2021-04-17T18:00:57.867018+00:00 2021-04-17T18:10:00.443509+00:00 0:09:02.576491 18263 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T18:00:55.544005+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-17T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T18:00:37.594709+00:00 2021-04-17T18:00:39.307181+00:00 0:00:01.712472 18262 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-17T18:00:35.469358+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-17T17:00:00+00:00 PythonOperator 2021-04-17T18:00:15.775193+00:00 2021-04-17T18:00:19.275401+00:00 0:00:03.500208 18261 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-17T18:00:13.390769+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-17T16:00:00+00:00 EmrJobFlowSensor 2021-04-17T17:11:16.810743+00:00 2021-04-17T17:21:19.527690+00:00 0:10:02.716947 18259 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T17:11:14.429226+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-17T16:00:00+00:00 EmrJobFlowSensor 2021-04-17T17:10:56.666736+00:00 2021-04-17T17:19:59.227634+00:00 0:09:02.560898 18258 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T17:10:54.409985+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-17T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T17:10:45.655025+00:00 2021-04-17T17:10:47.463906+00:00 0:00:01.808881 18257 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T17:10:42.456913+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-17T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T17:10:34.608947+00:00 2021-04-17T17:10:36.387374+00:00 0:00:01.778427 18256 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T17:10:32.388159+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-17T16:00:00+00:00 PythonOperator 2021-04-17T17:10:24.782703+00:00 2021-04-17T17:10:27.939350+00:00 0:00:03.156647 18255 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T17:10:22.317629+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-17T16:00:00+00:00 PythonOperator 2021-04-17T17:10:12.717035+00:00 2021-04-17T17:10:15.665810+00:00 0:00:02.948775 18254 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T17:10:10.295769+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-17T16:00:00+00:00 TriggerDagRunOperator 2021-04-17T17:10:04.947757+00:00 2021-04-17T17:10:05.608302+00:00 0:00:00.660545 18253 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T17:10:02.291042+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-17T16:00:00+00:00 TriggerDagRunOperator 2021-04-17T17:10:04.886004+00:00 2021-04-17T17:10:05.464399+00:00 0:00:00.578395 18252 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T17:10:02.291074+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-17T16:05:00+00:00 EmrJobFlowSensor 2021-04-17T17:05:47.845565+00:00 2021-04-17T17:14:50.417703+00:00 0:09:02.572138 18251 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T17:05:45.696487+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-17T16:05:00+00:00 EmrCreateJobFlowOperator 2021-04-17T17:05:26.027658+00:00 2021-04-17T17:05:27.778891+00:00 0:00:01.751233 18250 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T17:05:23.686888+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-17T16:05:00+00:00 PythonOperator 2021-04-17T17:05:05.755783+00:00 2021-04-17T17:05:08.822531+00:00 0:00:03.066748 18249 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T17:05:03.609544+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-17T16:00:00+00:00 EmrJobFlowSensor 2021-04-17T17:00:47.363127+00:00 2021-04-17T17:09:50.079142+00:00 0:09:02.716015 18248 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T17:00:45.149567+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-17T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T17:00:25.425438+00:00 2021-04-17T17:00:27.451269+00:00 0:00:02.025831 18247 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-17T17:00:23.128301+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-17T16:00:00+00:00 PythonOperator 2021-04-17T17:00:04.062075+00:00 2021-04-17T17:00:07.074926+00:00 0:00:03.012851 18246 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-17T17:00:01.176108+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-17T15:00:00+00:00 EmrJobFlowSensor 2021-04-17T16:12:29.513175+00:00 2021-04-17T16:21:32.511585+00:00 0:09:02.998410 18244 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T16:12:27.096129+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-17T15:00:00+00:00 EmrJobFlowSensor 2021-04-17T16:12:27.212986+00:00 2021-04-17T16:22:29.928078+00:00 0:10:02.715092 18243 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T16:12:25.086841+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-17T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T16:12:09.285185+00:00 2021-04-17T16:12:10.988243+00:00 0:00:01.703058 18242 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T16:12:07.038946+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-17T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T16:12:05.494215+00:00 2021-04-17T16:12:07.276811+00:00 0:00:01.782596 18241 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T16:12:03.036174+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-17T15:00:00+00:00 PythonOperator 2021-04-17T16:11:43.692102+00:00 2021-04-17T16:11:46.713808+00:00 0:00:03.021706 18240 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T16:11:41.016064+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-17T15:00:00+00:00 PythonOperator 2021-04-17T16:11:31.388555+00:00 2021-04-17T16:11:34.667391+00:00 0:00:03.278836 18239 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T16:11:29.010404+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-17T15:00:00+00:00 TriggerDagRunOperator 2021-04-17T16:11:23.724530+00:00 2021-04-17T16:11:24.268073+00:00 0:00:00.543543 18238 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T16:11:21.062566+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-17T15:00:00+00:00 TriggerDagRunOperator 2021-04-17T16:11:23.404383+00:00 2021-04-17T16:11:23.845886+00:00 0:00:00.441503 18237 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T16:11:21.062521+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-17T15:05:00+00:00 EmrJobFlowSensor 2021-04-17T16:05:58.664260+00:00 2021-04-17T16:15:01.279084+00:00 0:09:02.614824 18236 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-17T16:05:56.421760+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-17T15:05:00+00:00 EmrCreateJobFlowOperator 2021-04-17T16:05:36.835751+00:00 2021-04-17T16:05:38.993450+00:00 0:00:02.157699 18235 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-17T16:05:34.462793+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-17T15:05:00+00:00 PythonOperator 2021-04-17T16:05:14.668754+00:00 2021-04-17T16:05:17.548512+00:00 0:00:02.879758 18234 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T16:05:12.360865+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-17T15:00:00+00:00 EmrJobFlowSensor 2021-04-17T16:01:04.178814+00:00 2021-04-17T16:11:07.179864+00:00 0:10:03.001050 18233 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-17T16:01:01.820347+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-17T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-17T16:00:42.103630+00:00 2021-04-17T16:00:43.804372+00:00 0:00:01.700742 18232 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-17T16:00:39.856896+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-17T15:00:00+00:00 PythonOperator 2021-04-17T16:00:20.145334+00:00 2021-04-17T16:00:23.090385+00:00 0:00:02.945051 18231 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-17T16:00:17.782035+00:00 2 default_pool