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-history-job_v002 check_cluster_status 2021-05-07T21:00:00+00:00 EmrJobFlowSensor 2021-05-07T22:11:30.165549+00:00 2021-05-07T22:19:32.839069+00:00 0:08:02.673520 25611 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T22:11:27.557969+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-07T21:00:00+00:00 EmrJobFlowSensor 2021-05-07T22:11:10.039395+00:00 2021-05-07T22:21:12.900078+00:00 0:10:02.860683 25610 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T22:11:07.541713+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-07T21:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T22:11:07.812506+00:00 2021-05-07T22:11:09.541374+00:00 0:00:01.728868 25609 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T22:11:05.457872+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-07T21:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T22:10:50.050701+00:00 2021-05-07T22:10:51.726906+00:00 0:00:01.676205 25608 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T22:10:47.389925+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-07T21:00:00+00:00 PythonOperator 2021-05-07T22:10:47.646458+00:00 2021-05-07T22:10:51.061565+00:00 0:00:03.415107 25607 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T22:10:45.386849+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-07T21:00:00+00:00 PythonOperator 2021-05-07T22:10:27.600871+00:00 2021-05-07T22:10:31.043223+00:00 0:00:03.442352 25606 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T22:10:25.323300+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-07T21:00:00+00:00 TriggerDagRunOperator 2021-05-07T22:10:21.616787+00:00 2021-05-07T22:10:22.151061+00:00 0:00:00.534274 25605 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T22:10:19.319113+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-07T21:00:00+00:00 TriggerDagRunOperator 2021-05-07T22:10:21.487594+00:00 2021-05-07T22:10:21.900538+00:00 0:00:00.412944 25604 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T22:10:19.319144+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-07T21:05:00+00:00 EmrJobFlowSensor 2021-05-07T22:06:15.244821+00:00 2021-05-07T22:15:18.013771+00:00 0:09:02.768950 25603 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T22:06:12.897907+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-07T21:05:00+00:00 EmrCreateJobFlowOperator 2021-05-07T22:05:53.093865+00:00 2021-05-07T22:05:54.806660+00:00 0:00:01.712795 25602 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T22:05:50.852678+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-07T21:05:00+00:00 PythonOperator 2021-05-07T22:05:18.930998+00:00 2021-05-07T22:05:21.983465+00:00 0:00:03.052467 25601 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T22:05:16.794997+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-07T21:00:00+00:00 EmrJobFlowSensor 2021-05-07T22:01:02.535642+00:00 2021-05-07T22:10:05.292164+00:00 0:09:02.756522 25600 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T22:01:00.318009+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-07T21:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T22:00:40.648925+00:00 2021-05-07T22:00:42.444411+00:00 0:00:01.795486 25599 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-07T22:00:38.285176+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-07T21:00:00+00:00 PythonOperator 2021-05-07T22:00:18.904850+00:00 2021-05-07T22:00:21.990623+00:00 0:00:03.085773 25598 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-07T22:00:16.204637+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-07T20:00:00+00:00 EmrJobFlowSensor 2021-05-07T21:12:12.332991+00:00 2021-05-07T21:20:14.975577+00:00 0:08:02.642586 25596 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T21:12:10.115294+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-07T20:00:00+00:00 EmrJobFlowSensor 2021-05-07T21:12:06.472141+00:00 2021-05-07T21:22:09.330273+00:00 0:10:02.858132 25595 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T21:12:04.173403+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-07T20:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T21:11:50.318595+00:00 2021-05-07T21:11:51.973880+00:00 0:00:01.655285 25594 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T21:11:48.093079+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-07T20:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T21:11:46.439449+00:00 2021-05-07T21:11:48.288933+00:00 0:00:01.849484 25593 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T21:11:44.168016+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-07T20:00:00+00:00 PythonOperator 2021-05-07T21:11:30.324655+00:00 2021-05-07T21:11:33.405646+00:00 0:00:03.080991 25592 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T21:11:28.060061+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-07T20:00:00+00:00 PythonOperator 2021-05-07T21:11:24.508989+00:00 2021-05-07T21:11:27.834761+00:00 0:00:03.325772 25591 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T21:11:22.029409+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-07T20:00:00+00:00 TriggerDagRunOperator 2021-05-07T21:11:18.360756+00:00 2021-05-07T21:11:18.973235+00:00 0:00:00.612479 25590 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T21:11:16.024703+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-07T20:00:00+00:00 TriggerDagRunOperator 2021-05-07T21:11:18.174746+00:00 2021-05-07T21:11:18.625774+00:00 0:00:00.451028 25589 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T21:11:16.024673+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-07T20:05:00+00:00 EmrJobFlowSensor 2021-05-07T21:05:47.489832+00:00 2021-05-07T21:14:50.209295+00:00 0:09:02.719463 25588 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T21:05:45.224994+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-07T20:05:00+00:00 EmrCreateJobFlowOperator 2021-05-07T21:05:27.508903+00:00 2021-05-07T21:05:29.264251+00:00 0:00:01.755348 25587 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T21:05:25.215174+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-07T20:05:00+00:00 PythonOperator 2021-05-07T21:05:05.399734+00:00 2021-05-07T21:05:08.428533+00:00 0:00:03.028799 25586 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T21:05:03.188168+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-07T20:00:00+00:00 EmrJobFlowSensor 2021-05-07T21:00:56.701887+00:00 2021-05-07T21:10:59.491738+00:00 0:10:02.789851 25585 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T21:00:54.508725+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-07T20:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T21:00:36.791536+00:00 2021-05-07T21:00:38.463184+00:00 0:00:01.671648 25584 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-07T21:00:34.490737+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-07T20:00:00+00:00 PythonOperator 2021-05-07T21:00:15.457898+00:00 2021-05-07T21:00:18.537665+00:00 0:00:03.079767 25583 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-07T21:00:12.227129+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-07T19:00:00+00:00 EmrJobFlowSensor 2021-05-07T20:10:23.973123+00:00 2021-05-07T20:20:26.738035+00:00 0:10:02.764912 25581 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T20:10:21.416224+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-07T19:00:00+00:00 EmrJobFlowSensor 2021-05-07T20:10:21.485801+00:00 2021-05-07T20:19:24.663258+00:00 0:09:03.177457 25580 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T20:10:19.416047+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-07T19:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T20:10:01.674157+00:00 2021-05-07T20:10:03.538768+00:00 0:00:01.864611 25579 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T20:09:59.396721+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-07T19:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T20:09:59.777466+00:00 2021-05-07T20:10:01.566981+00:00 0:00:01.789515 25578 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T20:09:57.481103+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-07T19:00:00+00:00 PythonOperator 2021-05-07T20:09:39.699910+00:00 2021-05-07T20:09:43.074994+00:00 0:00:03.375084 25577 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T20:09:37.345753+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-07T19:00:00+00:00 PythonOperator 2021-05-07T20:09:39.716078+00:00 2021-05-07T20:09:42.887192+00:00 0:00:03.171114 25576 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T20:09:37.345783+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-07T19:00:00+00:00 TriggerDagRunOperator 2021-05-07T20:09:29.937677+00:00 2021-05-07T20:09:30.477566+00:00 0:00:00.539889 25575 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T20:09:27.337441+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-07T19:00:00+00:00 TriggerDagRunOperator 2021-05-07T20:09:29.763613+00:00 2021-05-07T20:09:30.184662+00:00 0:00:00.421049 25574 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T20:09:27.337473+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-07T19:05:00+00:00 EmrJobFlowSensor 2021-05-07T20:06:11.206169+00:00 2021-05-07T20:14:13.787995+00:00 0:08:02.581826 25573 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T20:06:08.983084+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-07T19:05:00+00:00 EmrCreateJobFlowOperator 2021-05-07T20:05:37.153668+00:00 2021-05-07T20:05:38.781972+00:00 0:00:01.628304 25572 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T20:05:34.979801+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-07T19:05:00+00:00 PythonOperator 2021-05-07T20:05:17.232530+00:00 2021-05-07T20:05:20.273681+00:00 0:00:03.041151 25571 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T20:05:14.933417+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-07T19:00:00+00:00 EmrJobFlowSensor 2021-05-07T20:00:56.792676+00:00 2021-05-07T20:08:59.251543+00:00 0:08:02.458867 25570 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T20:00:54.557673+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-07T19:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T20:00:36.847468+00:00 2021-05-07T20:00:38.716755+00:00 0:00:01.869287 25569 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-07T20:00:34.547158+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-07T19:00:00+00:00 PythonOperator 2021-05-07T20:00:15.110025+00:00 2021-05-07T20:00:18.185757+00:00 0:00:03.075732 25568 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-07T20:00:12.430152+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-07T18:00:00+00:00 EmrJobFlowSensor 2021-05-07T19:12:21.376409+00:00 2021-05-07T19:22:24.223843+00:00 0:10:02.847434 25566 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T19:12:19.105250+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-07T18:00:00+00:00 EmrJobFlowSensor 2021-05-07T19:12:15.323522+00:00 2021-05-07T19:22:18.247642+00:00 0:10:02.924120 25565 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T19:12:13.095364+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-07T18:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T19:11:59.921115+00:00 2021-05-07T19:12:01.822229+00:00 0:00:01.901114 25564 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T19:11:57.158164+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-07T18:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T19:11:53.347114+00:00 2021-05-07T19:11:55.159746+00:00 0:00:01.812632 25563 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T19:11:51.032919+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-07T18:00:00+00:00 PythonOperator 2021-05-07T19:11:39.464511+00:00 2021-05-07T19:11:42.788556+00:00 0:00:03.324045 25562 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T19:11:37.043998+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-07T18:00:00+00:00 PythonOperator 2021-05-07T19:11:33.072050+00:00 2021-05-07T19:11:36.133373+00:00 0:00:03.061323 25561 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T19:11:30.985651+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-07T18:00:00+00:00 TriggerDagRunOperator 2021-05-07T19:11:21.362233+00:00 2021-05-07T19:11:21.764489+00:00 0:00:00.402256 25560 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T19:11:18.928607+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-07T18:00:00+00:00 TriggerDagRunOperator 2021-05-07T19:11:21.193863+00:00 2021-05-07T19:11:21.796430+00:00 0:00:00.602567 25559 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T19:11:18.928577+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-07T18:05:00+00:00 EmrJobFlowSensor 2021-05-07T19:05:54.615531+00:00 2021-05-07T19:14:57.101390+00:00 0:09:02.485859 25558 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T19:05:52.357479+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-07T18:05:00+00:00 EmrCreateJobFlowOperator 2021-05-07T19:05:32.511197+00:00 2021-05-07T19:05:34.281952+00:00 0:00:01.770755 25557 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T19:05:30.315038+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-07T18:05:00+00:00 PythonOperator 2021-05-07T19:05:10.444726+00:00 2021-05-07T19:05:13.514673+00:00 0:00:03.069947 25556 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T19:05:08.295413+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-07T18:00:00+00:00 EmrJobFlowSensor 2021-05-07T19:01:11.984733+00:00 2021-05-07T19:11:14.826334+00:00 0:10:02.841601 25555 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T19:01:09.896699+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-07T18:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T19:00:52.046491+00:00 2021-05-07T19:00:53.732164+00:00 0:00:01.685673 25554 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-07T19:00:49.832651+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-07T18:00:00+00:00 PythonOperator 2021-05-07T19:00:30.320919+00:00 2021-05-07T19:00:33.369743+00:00 0:00:03.048824 25553 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-07T19:00:27.344850+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-07T17:00:00+00:00 EmrJobFlowSensor 2021-05-07T18:12:19.743505+00:00 2021-05-07T18:21:22.453248+00:00 0:09:02.709743 25551 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T18:12:17.278906+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-07T17:00:00+00:00 EmrJobFlowSensor 2021-05-07T18:12:13.365745+00:00 2021-05-07T18:21:16.006135+00:00 0:09:02.640390 25550 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T18:12:11.205556+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-07T17:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T18:12:00.063894+00:00 2021-05-07T18:12:01.830915+00:00 0:00:01.767021 25549 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T18:11:57.253497+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-07T17:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T18:11:51.504248+00:00 2021-05-07T18:11:53.235960+00:00 0:00:01.731712 25548 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T18:11:49.261965+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-07T17:00:00+00:00 PythonOperator 2021-05-07T18:11:37.507153+00:00 2021-05-07T18:11:40.778260+00:00 0:00:03.271107 25547 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T18:11:35.248677+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-07T17:00:00+00:00 PythonOperator 2021-05-07T18:11:31.594255+00:00 2021-05-07T18:11:34.688334+00:00 0:00:03.094079 25546 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T18:11:29.259579+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-07T17:00:00+00:00 TriggerDagRunOperator 2021-05-07T18:11:15.608491+00:00 2021-05-07T18:11:16.113756+00:00 0:00:00.505265 25545 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T18:11:13.089656+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-07T17:00:00+00:00 TriggerDagRunOperator 2021-05-07T18:11:15.294147+00:00 2021-05-07T18:11:15.710694+00:00 0:00:00.416547 25544 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T18:11:13.089618+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-07T17:05:00+00:00 EmrJobFlowSensor 2021-05-07T18:05:56.738263+00:00 2021-05-07T18:14:59.387374+00:00 0:09:02.649111 25543 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T18:05:54.460118+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-07T17:05:00+00:00 EmrCreateJobFlowOperator 2021-05-07T18:05:34.474679+00:00 2021-05-07T18:05:36.111778+00:00 0:00:01.637099 25542 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T18:05:32.351626+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-07T17:05:00+00:00 PythonOperator 2021-05-07T18:05:12.439350+00:00 2021-05-07T18:05:15.479476+00:00 0:00:03.040126 25541 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T18:05:10.220645+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-07T17:00:00+00:00 EmrJobFlowSensor 2021-05-07T18:00:50.229135+00:00 2021-05-07T18:10:53.127448+00:00 0:10:02.898313 25540 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T18:00:47.733545+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-07T17:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T18:00:27.798791+00:00 2021-05-07T18:00:29.472956+00:00 0:00:01.674165 25539 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-07T18:00:25.717302+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-07T17:00:00+00:00 PythonOperator 2021-05-07T18:00:06.285561+00:00 2021-05-07T18:00:09.412197+00:00 0:00:03.126636 25538 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-07T18:00:03.763350+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-07T16:00:00+00:00 EmrJobFlowSensor 2021-05-07T17:12:18.510435+00:00 2021-05-07T17:21:21.228451+00:00 0:09:02.718016 25536 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T17:12:16.113417+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-07T16:00:00+00:00 EmrJobFlowSensor 2021-05-07T17:12:18.255316+00:00 2021-05-07T17:22:21.118548+00:00 0:10:02.863232 25535 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T17:12:16.113385+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-07T16:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T17:11:56.797896+00:00 2021-05-07T17:11:58.665739+00:00 0:00:01.867843 25534 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T17:11:54.161930+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-07T16:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T17:11:56.651498+00:00 2021-05-07T17:11:58.365024+00:00 0:00:01.713526 25533 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T17:11:54.161884+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-07T16:00:00+00:00 PythonOperator 2021-05-07T17:11:36.532524+00:00 2021-05-07T17:11:39.636400+00:00 0:00:03.103876 25532 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T17:11:34.071223+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-07T16:00:00+00:00 PythonOperator 2021-05-07T17:11:36.445603+00:00 2021-05-07T17:11:39.756976+00:00 0:00:03.311373 25531 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T17:11:34.071256+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-07T16:00:00+00:00 TriggerDagRunOperator 2021-05-07T17:11:12.302752+00:00 2021-05-07T17:11:12.861135+00:00 0:00:00.558383 25530 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T17:11:09.994261+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-07T16:00:00+00:00 TriggerDagRunOperator 2021-05-07T17:11:12.206688+00:00 2021-05-07T17:11:12.624059+00:00 0:00:00.417371 25529 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T17:11:09.994293+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-07T16:05:00+00:00 EmrJobFlowSensor 2021-05-07T17:05:45.856859+00:00 2021-05-07T17:13:48.369576+00:00 0:08:02.512717 25528 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T17:05:43.653295+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-07T16:05:00+00:00 EmrCreateJobFlowOperator 2021-05-07T17:05:25.662464+00:00 2021-05-07T17:05:27.284496+00:00 0:00:01.622032 25527 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T17:05:23.526592+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-07T16:05:00+00:00 PythonOperator 2021-05-07T17:05:03.762415+00:00 2021-05-07T17:05:06.835016+00:00 0:00:03.072601 25526 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T17:05:01.508196+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-07T16:00:00+00:00 EmrJobFlowSensor 2021-05-07T17:01:05.480802+00:00 2021-05-07T17:11:08.261112+00:00 0:10:02.780310 25525 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T17:01:03.149694+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-07T16:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T17:00:43.183189+00:00 2021-05-07T17:00:44.936102+00:00 0:00:01.752913 25524 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-07T17:00:41.087024+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-07T16:00:00+00:00 PythonOperator 2021-05-07T17:00:21.312641+00:00 2021-05-07T17:00:24.373792+00:00 0:00:03.061151 25523 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-07T17:00:19.074849+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-07T15:00:00+00:00 EmrJobFlowSensor 2021-05-07T16:12:23.174048+00:00 2021-05-07T16:23:26.298879+00:00 0:11:03.124831 25521 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T16:12:20.757274+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-07T15:00:00+00:00 EmrJobFlowSensor 2021-05-07T16:12:10.783800+00:00 2021-05-07T16:22:13.686049+00:00 0:10:02.902249 25520 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T16:12:08.632155+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-07T15:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T16:12:01.308993+00:00 2021-05-07T16:12:03.031427+00:00 0:00:01.722434 25519 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T16:11:58.754846+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-07T15:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T16:11:48.923439+00:00 2021-05-07T16:11:50.706404+00:00 0:00:01.782965 25518 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T16:11:46.612603+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-07T15:00:00+00:00 PythonOperator 2021-05-07T16:11:40.719115+00:00 2021-05-07T16:11:43.965060+00:00 0:00:03.245945 25517 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T16:11:38.598688+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-07T15:00:00+00:00 PythonOperator 2021-05-07T16:11:28.664553+00:00 2021-05-07T16:11:31.745641+00:00 0:00:03.081088 25516 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T16:11:26.538452+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-07T15:00:00+00:00 TriggerDagRunOperator 2021-05-07T16:11:17.075270+00:00 2021-05-07T16:11:17.511559+00:00 0:00:00.436289 25515 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T16:11:14.521879+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-07T15:00:00+00:00 TriggerDagRunOperator 2021-05-07T16:11:16.809940+00:00 2021-05-07T16:11:17.407380+00:00 0:00:00.597440 25514 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T16:11:14.521909+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-07T15:05:00+00:00 EmrJobFlowSensor 2021-05-07T16:06:00.081324+00:00 2021-05-07T16:15:02.671540+00:00 0:09:02.590216 25513 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T16:05:57.868490+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-07T15:05:00+00:00 EmrCreateJobFlowOperator 2021-05-07T16:05:38.394106+00:00 2021-05-07T16:05:40.087250+00:00 0:00:01.693144 25512 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T16:05:35.844699+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-07T15:05:00+00:00 PythonOperator 2021-05-07T16:05:14.127280+00:00 2021-05-07T16:05:17.229786+00:00 0:00:03.102506 25511 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T16:05:11.855754+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-07T15:00:00+00:00 EmrJobFlowSensor 2021-05-07T16:01:05.513358+00:00 2021-05-07T16:11:08.230993+00:00 0:10:02.717635 25510 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T16:01:03.190579+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-07T15:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T16:00:43.388064+00:00 2021-05-07T16:00:45.108903+00:00 0:00:01.720839 25509 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-07T16:00:41.110640+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-07T15:00:00+00:00 PythonOperator 2021-05-07T16:00:21.437088+00:00 2021-05-07T16:00:24.518393+00:00 0:00:03.081305 25508 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-07T16:00:19.094566+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-07T14:00:00+00:00 EmrJobFlowSensor 2021-05-07T15:11:18.676058+00:00 2021-05-07T15:20:21.321525+00:00 0:09:02.645467 25506 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T15:11:16.577618+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-07T14:00:00+00:00 EmrJobFlowSensor 2021-05-07T15:11:10.744486+00:00 2021-05-07T15:21:13.802909+00:00 0:10:03.058423 25505 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T15:11:08.527910+00:00 2 default_pool