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 trigger_dagrun_booking-processing-job_v002 2021-04-27T05:00:00+00:00 TriggerDagRunOperator 2021-04-27T06:09:12.060938+00:00 2021-04-27T06:09:12.481296+00:00 0:00:00.420358 21733 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T06:09:09.836496+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-27T05:05:00+00:00 EmrJobFlowSensor 2021-04-27T06:05:49.558879+00:00 2021-04-27T06:14:52.109521+00:00 0:09:02.550642 21732 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T06:05:47.400857+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-27T05:05:00+00:00 EmrCreateJobFlowOperator 2021-04-27T06:05:29.876248+00:00 2021-04-27T06:05:31.611331+00:00 0:00:01.735083 21731 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T06:05:27.386832+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-27T05:05:00+00:00 PythonOperator 2021-04-27T06:05:07.476670+00:00 2021-04-27T06:05:10.413516+00:00 0:00:02.936846 21730 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T06:05:05.362286+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-27T05:00:00+00:00 EmrJobFlowSensor 2021-04-27T06:00:57.198949+00:00 2021-04-27T06:08:59.790126+00:00 0:08:02.591177 21729 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T06:00:54.703168+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-27T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T06:00:35.233752+00:00 2021-04-27T06:00:36.938031+00:00 0:00:01.704279 21728 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-27T06:00:32.763970+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-27T05:00:00+00:00 PythonOperator 2021-04-27T06:00:06.794681+00:00 2021-04-27T06:00:09.766825+00:00 0:00:02.972144 21727 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-27T06:00:04.526572+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-27T04:00:00+00:00 EmrJobFlowSensor 2021-04-27T05:12:22.240766+00:00 2021-04-27T05:20:24.757650+00:00 0:08:02.516884 21725 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T05:12:19.865749+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-27T04:00:00+00:00 EmrJobFlowSensor 2021-04-27T05:12:18.211306+00:00 2021-04-27T05:22:20.968723+00:00 0:10:02.757417 21724 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T05:12:15.856021+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-27T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T05:12:02.358554+00:00 2021-04-27T05:12:04.135249+00:00 0:00:01.776695 21723 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T05:11:59.387219+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-27T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T05:11:57.731308+00:00 2021-04-27T05:11:59.573824+00:00 0:00:01.842516 21722 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T05:11:55.385797+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-27T04:00:00+00:00 PythonOperator 2021-04-27T05:11:39.853422+00:00 2021-04-27T05:11:42.962413+00:00 0:00:03.108991 21721 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T05:11:37.353587+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-27T04:00:00+00:00 PythonOperator 2021-04-27T05:11:35.786804+00:00 2021-04-27T05:11:38.989105+00:00 0:00:03.202301 21720 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T05:11:33.459297+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-27T04:00:00+00:00 TriggerDagRunOperator 2021-04-27T05:11:25.717794+00:00 2021-04-27T05:11:26.234077+00:00 0:00:00.516283 21719 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T05:11:23.291681+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-27T04:00:00+00:00 TriggerDagRunOperator 2021-04-27T05:11:25.483883+00:00 2021-04-27T05:11:25.892490+00:00 0:00:00.408607 21718 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T05:11:23.291728+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-27T04:05:00+00:00 EmrJobFlowSensor 2021-04-27T05:05:52.784980+00:00 2021-04-27T05:14:55.415549+00:00 0:09:02.630569 21717 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T05:05:50.524026+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-27T04:05:00+00:00 EmrCreateJobFlowOperator 2021-04-27T05:05:30.907770+00:00 2021-04-27T05:05:32.662785+00:00 0:00:01.755015 21716 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T05:05:28.507375+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-27T04:05:00+00:00 PythonOperator 2021-04-27T05:05:08.594761+00:00 2021-04-27T05:05:11.641408+00:00 0:00:03.046647 21715 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T05:05:06.454797+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-27T04:00:00+00:00 EmrJobFlowSensor 2021-04-27T05:01:04.188164+00:00 2021-04-27T05:11:07.291345+00:00 0:10:03.103181 21714 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T05:01:01.762293+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-27T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T05:00:42.106610+00:00 2021-04-27T05:00:44.085587+00:00 0:00:01.978977 21713 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-27T05:00:39.643703+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-27T04:00:00+00:00 PythonOperator 2021-04-27T05:00:21.839425+00:00 2021-04-27T05:00:24.828681+00:00 0:00:02.989256 21712 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-27T05:00:19.518572+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-27T03:00:00+00:00 EmrJobFlowSensor 2021-04-27T04:11:01.392492+00:00 2021-04-27T04:21:04.305078+00:00 0:10:02.912586 21710 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T04:10:59.100062+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-27T03:00:00+00:00 EmrJobFlowSensor 2021-04-27T04:10:55.630490+00:00 2021-04-27T04:20:58.559173+00:00 0:10:02.928683 21709 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T04:10:53.163592+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-27T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T04:10:39.348408+00:00 2021-04-27T04:10:41.042303+00:00 0:00:01.693895 21708 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T04:10:37.068218+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-27T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T04:10:35.410734+00:00 2021-04-27T04:10:37.139044+00:00 0:00:01.728310 21707 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T04:10:33.040742+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-27T03:00:00+00:00 PythonOperator 2021-04-27T04:10:19.367125+00:00 2021-04-27T04:10:22.387656+00:00 0:00:03.020531 21706 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T04:10:17.025527+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-27T03:00:00+00:00 PythonOperator 2021-04-27T04:10:13.708448+00:00 2021-04-27T04:10:16.955007+00:00 0:00:03.246559 21705 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T04:10:11.021689+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-27T03:00:00+00:00 TriggerDagRunOperator 2021-04-27T04:10:05.527268+00:00 2021-04-27T04:10:05.957998+00:00 0:00:00.430730 21704 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T04:10:03.012459+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-27T03:00:00+00:00 TriggerDagRunOperator 2021-04-27T04:10:05.373148+00:00 2021-04-27T04:10:05.920770+00:00 0:00:00.547622 21703 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T04:10:03.012495+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-27T03:05:00+00:00 EmrJobFlowSensor 2021-04-27T04:05:59.231077+00:00 2021-04-27T04:14:01.785358+00:00 0:08:02.554281 21702 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T04:05:56.652240+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-27T03:05:00+00:00 EmrCreateJobFlowOperator 2021-04-27T04:05:38.780906+00:00 2021-04-27T04:05:40.553229+00:00 0:00:01.772323 21701 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T04:05:36.541136+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-27T03:05:00+00:00 PythonOperator 2021-04-27T04:05:16.714180+00:00 2021-04-27T04:05:19.695364+00:00 0:00:02.981184 21700 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T04:05:14.474611+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-27T03:00:00+00:00 EmrJobFlowSensor 2021-04-27T04:00:56.100484+00:00 2021-04-27T04:09:58.700904+00:00 0:09:02.600420 21699 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T04:00:53.890504+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-27T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T04:00:34.175292+00:00 2021-04-27T04:00:35.886119+00:00 0:00:01.710827 21698 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-27T04:00:31.831335+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-27T03:00:00+00:00 PythonOperator 2021-04-27T04:00:12.112067+00:00 2021-04-27T04:00:15.208796+00:00 0:00:03.096729 21697 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-27T04:00:09.798279+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-27T02:00:00+00:00 EmrJobFlowSensor 2021-04-27T03:12:17.244594+00:00 2021-04-27T03:22:20.162721+00:00 0:10:02.918127 21695 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T03:12:15.058533+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-27T02:00:00+00:00 EmrJobFlowSensor 2021-04-27T03:12:09.332082+00:00 2021-04-27T03:20:11.921506+00:00 0:08:02.589424 21694 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T03:12:07.044901+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-27T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T03:11:57.671306+00:00 2021-04-27T03:11:59.343232+00:00 0:00:01.671926 21693 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T03:11:55.050204+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-27T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T03:11:49.402580+00:00 2021-04-27T03:11:51.108510+00:00 0:00:01.705930 21692 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T03:11:47.035324+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-27T02:00:00+00:00 PythonOperator 2021-04-27T03:11:35.373909+00:00 2021-04-27T03:11:38.705421+00:00 0:00:03.331512 21691 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T03:11:33.045878+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-27T02:00:00+00:00 PythonOperator 2021-04-27T03:11:21.206680+00:00 2021-04-27T03:11:24.232973+00:00 0:00:03.026293 21690 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T03:11:19.006984+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-27T02:00:00+00:00 TriggerDagRunOperator 2021-04-27T03:11:01.332011+00:00 2021-04-27T03:11:01.792449+00:00 0:00:00.460438 21689 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T03:10:58.984332+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-27T02:00:00+00:00 TriggerDagRunOperator 2021-04-27T03:11:01.238229+00:00 2021-04-27T03:11:01.809099+00:00 0:00:00.570870 21688 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T03:10:58.984359+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-27T02:05:00+00:00 EmrJobFlowSensor 2021-04-27T03:06:02.429594+00:00 2021-04-27T03:15:05.061505+00:00 0:09:02.631911 21687 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T03:06:00.229355+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-27T02:05:00+00:00 EmrCreateJobFlowOperator 2021-04-27T03:05:38.536444+00:00 2021-04-27T03:05:40.313073+00:00 0:00:01.776629 21686 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T03:05:36.190909+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-27T02:05:00+00:00 PythonOperator 2021-04-27T03:05:16.261354+00:00 2021-04-27T03:05:19.228602+00:00 0:00:02.967248 21685 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T03:05:14.171204+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-27T02:00:00+00:00 EmrJobFlowSensor 2021-04-27T03:00:51.641190+00:00 2021-04-27T03:10:54.433745+00:00 0:10:02.792555 21684 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T03:00:49.499235+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-27T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T03:00:29.798025+00:00 2021-04-27T03:00:31.503120+00:00 0:00:01.705095 21683 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-27T03:00:27.467775+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-27T02:00:00+00:00 PythonOperator 2021-04-27T03:00:10.037850+00:00 2021-04-27T03:00:13.065154+00:00 0:00:03.027304 21682 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-27T03:00:07.415898+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-27T01:00:00+00:00 EmrJobFlowSensor 2021-04-27T02:11:12.451101+00:00 2021-04-27T02:21:15.318194+00:00 0:10:02.867093 21680 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T02:11:10.190027+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-27T01:00:00+00:00 EmrJobFlowSensor 2021-04-27T02:11:00.790374+00:00 2021-04-27T02:20:03.460094+00:00 0:09:02.669720 21679 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T02:10:58.254130+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-27T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T02:10:52.355236+00:00 2021-04-27T02:10:54.250917+00:00 0:00:01.895681 21678 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T02:10:50.089564+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-27T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T02:10:38.722149+00:00 2021-04-27T02:10:40.566521+00:00 0:00:01.844372 21677 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T02:10:36.145768+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-27T01:00:00+00:00 PythonOperator 2021-04-27T02:10:30.300625+00:00 2021-04-27T02:10:33.485815+00:00 0:00:03.185190 21676 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T02:10:28.063105+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-27T01:00:00+00:00 PythonOperator 2021-04-27T02:10:16.184048+00:00 2021-04-27T02:10:19.141951+00:00 0:00:02.957903 21675 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T02:10:14.046378+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-27T01:00:00+00:00 TriggerDagRunOperator 2021-04-27T02:10:12.313710+00:00 2021-04-27T02:10:12.915033+00:00 0:00:00.601323 21674 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T02:10:10.052063+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-27T01:00:00+00:00 TriggerDagRunOperator 2021-04-27T02:10:12.293089+00:00 2021-04-27T02:10:12.780063+00:00 0:00:00.486974 21673 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T02:10:10.052104+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-27T01:05:00+00:00 EmrJobFlowSensor 2021-04-27T02:06:01.635433+00:00 2021-04-27T02:14:04.143155+00:00 0:08:02.507722 21672 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T02:05:59.271762+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-27T01:05:00+00:00 EmrCreateJobFlowOperator 2021-04-27T02:05:39.646768+00:00 2021-04-27T02:05:41.270084+00:00 0:00:01.623316 21671 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T02:05:37.280744+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-27T01:05:00+00:00 PythonOperator 2021-04-27T02:05:17.373637+00:00 2021-04-27T02:05:20.339884+00:00 0:00:02.966247 21670 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T02:05:15.157488+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-27T01:00:00+00:00 EmrJobFlowSensor 2021-04-27T02:00:54.743076+00:00 2021-04-27T02:09:57.427686+00:00 0:09:02.684610 21669 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T02:00:52.521890+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-27T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T02:00:34.715369+00:00 2021-04-27T02:00:36.463704+00:00 0:00:01.748335 21668 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-27T02:00:32.509162+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-27T01:00:00+00:00 PythonOperator 2021-04-27T02:00:11.282088+00:00 2021-04-27T02:00:14.302253+00:00 0:00:03.020165 21667 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-27T02:00:08.558806+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-27T00:00:00+00:00 EmrJobFlowSensor 2021-04-27T01:10:47.759988+00:00 2021-04-27T01:19:50.331672+00:00 0:09:02.571684 21665 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T01:10:45.503880+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-27T00:00:00+00:00 EmrJobFlowSensor 2021-04-27T01:10:32.050958+00:00 2021-04-27T01:20:34.777613+00:00 0:10:02.726655 21664 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T01:10:29.566983+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-27T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T01:10:25.983954+00:00 2021-04-27T01:10:27.769554+00:00 0:00:01.785600 21663 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T01:10:23.468507+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-27T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T01:10:11.969290+00:00 2021-04-27T01:10:13.768969+00:00 0:00:01.799679 21662 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T01:10:09.462569+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-27T00:00:00+00:00 PythonOperator 2021-04-27T01:10:05.816827+00:00 2021-04-27T01:10:08.805227+00:00 0:00:02.988400 21661 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T01:10:03.464254+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-27T00:00:00+00:00 PythonOperator 2021-04-27T01:09:49.579069+00:00 2021-04-27T01:09:52.791865+00:00 0:00:03.212796 21660 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T01:09:47.371597+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-27T00:00:00+00:00 TriggerDagRunOperator 2021-04-27T01:09:45.683030+00:00 2021-04-27T01:09:46.235070+00:00 0:00:00.552040 21659 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T01:09:43.299301+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-27T00:00:00+00:00 TriggerDagRunOperator 2021-04-27T01:09:45.657441+00:00 2021-04-27T01:09:46.165673+00:00 0:00:00.508232 21658 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T01:09:43.299333+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-27T00:05:00+00:00 EmrJobFlowSensor 2021-04-27T01:05:55.196001+00:00 2021-04-27T01:14:57.690423+00:00 0:09:02.494422 21657 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T01:05:52.971313+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-27T00:05:00+00:00 EmrCreateJobFlowOperator 2021-04-27T01:05:35.226061+00:00 2021-04-27T01:05:37.019795+00:00 0:00:01.793734 21656 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T01:05:32.879537+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-27T00:05:00+00:00 PythonOperator 2021-04-27T01:05:11.244754+00:00 2021-04-27T01:05:14.258739+00:00 0:00:03.013985 21655 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T01:05:08.859233+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-27T00:00:00+00:00 EmrJobFlowSensor 2021-04-27T01:01:18.489150+00:00 2021-04-27T01:09:21.105637+00:00 0:08:02.616487 21654 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T01:01:16.244620+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-27T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T01:00:58.671863+00:00 2021-04-27T01:01:00.525658+00:00 0:00:01.853795 21653 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-27T01:00:56.211000+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-27T00:00:00+00:00 PythonOperator 2021-04-27T01:00:36.573206+00:00 2021-04-27T01:00:39.653564+00:00 0:00:03.080358 21652 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-27T01:00:34.190729+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-26T23:00:00+00:00 EmrJobFlowSensor 2021-04-27T00:10:21.713941+00:00 2021-04-27T00:20:24.525205+00:00 0:10:02.811264 21650 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T00:10:19.520622+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-26T23:00:00+00:00 EmrJobFlowSensor 2021-04-27T00:10:15.887522+00:00 2021-04-27T00:23:19.138454+00:00 0:13:03.250932 21649 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T00:10:13.511379+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-26T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T00:10:02.231036+00:00 2021-04-27T00:10:04.000102+00:00 0:00:01.769066 21648 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T00:09:59.379386+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-26T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T00:09:53.706125+00:00 2021-04-27T00:09:55.480358+00:00 0:00:01.774233 21647 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T00:09:51.374158+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-26T23:00:00+00:00 PythonOperator 2021-04-27T00:09:39.946054+00:00 2021-04-27T00:09:43.029628+00:00 0:00:03.083574 21646 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T00:09:37.385438+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-26T23:00:00+00:00 PythonOperator 2021-04-27T00:09:32.289851+00:00 2021-04-27T00:09:35.721428+00:00 0:00:03.431577 21645 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T00:09:29.441701+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-26T23:00:00+00:00 TriggerDagRunOperator 2021-04-27T00:09:23.654259+00:00 2021-04-27T00:09:24.170660+00:00 0:00:00.516401 21644 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T00:09:21.293384+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-26T23:00:00+00:00 TriggerDagRunOperator 2021-04-27T00:09:23.498922+00:00 2021-04-27T00:09:23.916646+00:00 0:00:00.417724 21643 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T00:09:21.293420+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-26T23:05:00+00:00 EmrJobFlowSensor 2021-04-27T00:06:07.093449+00:00 2021-04-27T00:14:09.699478+00:00 0:08:02.606029 21642 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T00:06:04.943751+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-26T23:05:00+00:00 EmrCreateJobFlowOperator 2021-04-27T00:05:31.293074+00:00 2021-04-27T00:05:33.048957+00:00 0:00:01.755883 21641 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T00:05:28.960863+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-26T23:05:00+00:00 PythonOperator 2021-04-27T00:05:09.042014+00:00 2021-04-27T00:05:11.939119+00:00 0:00:02.897105 21640 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T00:05:06.897030+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-26T23:00:00+00:00 EmrJobFlowSensor 2021-04-27T00:00:58.561781+00:00 2021-04-27T00:09:01.091139+00:00 0:08:02.529358 21639 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T00:00:56.316726+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-26T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T00:00:36.845349+00:00 2021-04-27T00:00:38.528301+00:00 0:00:01.682952 21638 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-27T00:00:34.354933+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-26T23:00:00+00:00 PythonOperator 2021-04-27T00:00:16.500452+00:00 2021-04-27T00:00:19.630402+00:00 0:00:03.129950 21637 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-27T00:00:14.200335+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-26T22:00:00+00:00 EmrJobFlowSensor 2021-04-26T23:11:15.532809+00:00 2021-04-26T23:19:18.170246+00:00 0:08:02.637437 21635 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T23:11:13.041947+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-26T22:00:00+00:00 EmrJobFlowSensor 2021-04-26T23:11:15.287362+00:00 2021-04-26T23:21:18.147205+00:00 0:10:02.859843 21634 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T23:11:13.041902+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-26T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-26T23:10:41.774202+00:00 2021-04-26T23:10:43.456410+00:00 0:00:01.682208 21633 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-26T23:10:39.005978+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-26T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-26T23:10:39.450013+00:00 2021-04-26T23:10:41.459119+00:00 0:00:02.009106 21632 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-26T23:10:37.006106+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-26T22:00:00+00:00 PythonOperator 2021-04-26T23:10:20.237052+00:00 2021-04-26T23:10:23.467002+00:00 0:00:03.229950 21631 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T23:10:17.044415+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-26T22:00:00+00:00 PythonOperator 2021-04-26T23:10:17.313071+00:00 2021-04-26T23:10:21.037914+00:00 0:00:03.724843 21630 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-26T23:10:15.054758+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-26T22:00:00+00:00 TriggerDagRunOperator 2021-04-26T23:10:11.963076+00:00 2021-04-26T23:10:12.480632+00:00 0:00:00.517556 21629 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T23:10:09.044608+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-26T22:00:00+00:00 TriggerDagRunOperator 2021-04-26T23:10:11.393981+00:00 2021-04-26T23:10:11.847088+00:00 0:00:00.453107 21628 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T23:10:09.044562+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-26T22:05:00+00:00 EmrJobFlowSensor 2021-04-26T23:06:10.774006+00:00 2021-04-26T23:14:13.277622+00:00 0:08:02.503616 21627 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-26T23:06:08.652291+00:00 2 default_pool