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-05-02T17:00:00+00:00 TriggerDagRunOperator 2021-05-02T18:10:28.999033+00:00 2021-05-02T18:10:29.399006+00:00 0:00:00.399973 23729 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T18:10:26.620655+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-02T17:05:00+00:00 EmrJobFlowSensor 2021-05-02T18:06:06.522429+00:00 2021-05-02T18:15:09.184568+00:00 0:09:02.662139 23728 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T18:06:04.313046+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-02T17:05:00+00:00 EmrCreateJobFlowOperator 2021-05-02T18:05:46.382439+00:00 2021-05-02T18:05:48.050614+00:00 0:00:01.668175 23727 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-02T18:05:44.295850+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-02T17:05:00+00:00 PythonOperator 2021-05-02T18:05:24.390006+00:00 2021-05-02T18:05:27.411712+00:00 0:00:03.021706 23726 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T18:05:22.255907+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-02T17:00:00+00:00 EmrJobFlowSensor 2021-05-02T18:01:00.433236+00:00 2021-05-02T18:10:03.157474+00:00 0:09:02.724238 23725 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T18:00:57.944639+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-02T17:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T18:00:38.278948+00:00 2021-05-02T18:00:40.146294+00:00 0:00:01.867346 23724 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-02T18:00:35.775354+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-02T17:00:00+00:00 PythonOperator 2021-05-02T18:00:18.222957+00:00 2021-05-02T18:00:21.284497+00:00 0:00:03.061540 23723 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-02T18:00:15.758701+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-02T16:00:00+00:00 EmrJobFlowSensor 2021-05-02T17:12:49.242099+00:00 2021-05-02T17:20:51.944457+00:00 0:08:02.702358 23721 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T17:12:46.688780+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-02T16:00:00+00:00 EmrJobFlowSensor 2021-05-02T17:12:36.816757+00:00 2021-05-02T17:21:39.393288+00:00 0:09:02.576531 23720 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T17:12:34.673837+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-02T16:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T17:12:26.868756+00:00 2021-05-02T17:12:28.556663+00:00 0:00:01.687907 23719 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-02T17:12:24.663361+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-02T16:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T17:12:14.946595+00:00 2021-05-02T17:12:16.805501+00:00 0:00:01.858906 23718 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-02T17:12:12.595936+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-02T16:00:00+00:00 PythonOperator 2021-05-02T17:12:06.978500+00:00 2021-05-02T17:12:10.014893+00:00 0:00:03.036393 23717 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T17:12:04.742921+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-02T16:00:00+00:00 PythonOperator 2021-05-02T17:11:54.730194+00:00 2021-05-02T17:11:58.020783+00:00 0:00:03.290589 23716 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T17:11:52.511852+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-02T16:00:00+00:00 TriggerDagRunOperator 2021-05-02T17:11:42.840690+00:00 2021-05-02T17:11:43.379213+00:00 0:00:00.538523 23715 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T17:11:40.498325+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-02T16:00:00+00:00 TriggerDagRunOperator 2021-05-02T17:11:42.799786+00:00 2021-05-02T17:11:43.330876+00:00 0:00:00.531090 23714 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T17:11:40.498298+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-02T16:05:00+00:00 EmrJobFlowSensor 2021-05-02T17:06:00.475824+00:00 2021-05-02T17:14:02.997587+00:00 0:08:02.521763 23713 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T17:05:58.066051+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-02T16:05:00+00:00 EmrCreateJobFlowOperator 2021-05-02T17:05:28.054659+00:00 2021-05-02T17:05:29.704901+00:00 0:00:01.650242 23712 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-02T17:05:25.942344+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-02T16:05:00+00:00 PythonOperator 2021-05-02T17:05:04.219805+00:00 2021-05-02T17:05:07.215141+00:00 0:00:02.995336 23711 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T17:05:01.953718+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-02T16:00:00+00:00 EmrJobFlowSensor 2021-05-02T17:01:15.822292+00:00 2021-05-02T17:11:18.757773+00:00 0:10:02.935481 23710 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T17:01:13.392796+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-02T16:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T17:00:53.849116+00:00 2021-05-02T17:00:55.672259+00:00 0:00:01.823143 23709 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-02T17:00:51.307964+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-02T16:00:00+00:00 PythonOperator 2021-05-02T17:00:23.554511+00:00 2021-05-02T17:00:26.641607+00:00 0:00:03.087096 23708 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-02T17:00:21.280558+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-02T15:00:00+00:00 EmrJobFlowSensor 2021-05-02T16:12:26.610109+00:00 2021-05-02T16:21:29.237748+00:00 0:09:02.627639 23706 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T16:12:24.309524+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-02T15:00:00+00:00 EmrJobFlowSensor 2021-05-02T16:12:20.481955+00:00 2021-05-02T16:22:23.313130+00:00 0:10:02.831175 23705 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T16:12:18.309876+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-02T15:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T16:12:07.062904+00:00 2021-05-02T16:12:08.773290+00:00 0:00:01.710386 23704 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-02T16:12:04.292745+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-02T15:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T16:11:58.732494+00:00 2021-05-02T16:12:00.432591+00:00 0:00:01.700097 23703 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-02T16:11:56.356348+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-02T15:00:00+00:00 PythonOperator 2021-05-02T16:11:42.441913+00:00 2021-05-02T16:11:45.458738+00:00 0:00:03.016825 23702 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T16:11:40.232478+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-02T15:00:00+00:00 PythonOperator 2021-05-02T16:11:38.518874+00:00 2021-05-02T16:11:41.798746+00:00 0:00:03.279872 23701 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T16:11:36.231208+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-02T15:00:00+00:00 TriggerDagRunOperator 2021-05-02T16:11:22.464146+00:00 2021-05-02T16:11:22.999018+00:00 0:00:00.534872 23700 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T16:11:20.217439+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-02T15:00:00+00:00 TriggerDagRunOperator 2021-05-02T16:11:22.420190+00:00 2021-05-02T16:11:22.845980+00:00 0:00:00.425790 23699 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T16:11:20.217472+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-02T15:05:00+00:00 EmrJobFlowSensor 2021-05-02T16:05:53.901867+00:00 2021-05-02T16:13:56.475395+00:00 0:08:02.573528 23698 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T16:05:51.704903+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-02T15:05:00+00:00 EmrCreateJobFlowOperator 2021-05-02T16:05:32.329317+00:00 2021-05-02T16:05:34.101628+00:00 0:00:01.772311 23697 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-02T16:05:29.761694+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-02T15:05:00+00:00 PythonOperator 2021-05-02T16:05:09.815491+00:00 2021-05-02T16:05:12.858017+00:00 0:00:03.042526 23696 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T16:05:07.585352+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-02T15:00:00+00:00 EmrJobFlowSensor 2021-05-02T16:01:01.290376+00:00 2021-05-02T16:11:04.199804+00:00 0:10:02.909428 23695 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T16:00:59.086349+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-02T15:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T16:00:39.305003+00:00 2021-05-02T16:00:41.012517+00:00 0:00:01.707514 23694 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-02T16:00:37.059566+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-02T15:00:00+00:00 PythonOperator 2021-05-02T16:00:19.338605+00:00 2021-05-02T16:00:22.391114+00:00 0:00:03.052509 23693 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-02T16:00:17.016319+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-02T14:00:00+00:00 EmrJobFlowSensor 2021-05-02T15:10:33.090598+00:00 2021-05-02T15:19:35.705478+00:00 0:09:02.614880 23691 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T15:10:30.916555+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-02T14:00:00+00:00 EmrJobFlowSensor 2021-05-02T15:10:29.110247+00:00 2021-05-02T15:20:31.855098+00:00 0:10:02.744851 23690 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T15:10:26.914352+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-02T14:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T15:10:11.385841+00:00 2021-05-02T15:10:13.179248+00:00 0:00:01.793407 23689 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-02T15:10:08.900820+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-02T14:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T15:10:07.094941+00:00 2021-05-02T15:10:08.800593+00:00 0:00:01.705652 23688 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-02T15:10:04.897299+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-02T14:00:00+00:00 PythonOperator 2021-05-02T15:09:49.242213+00:00 2021-05-02T15:09:52.255846+00:00 0:00:03.013633 23687 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T15:09:46.880554+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-02T14:00:00+00:00 PythonOperator 2021-05-02T15:09:47.045900+00:00 2021-05-02T15:09:50.387501+00:00 0:00:03.341601 23686 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T15:09:44.858578+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-02T14:00:00+00:00 TriggerDagRunOperator 2021-05-02T15:09:25.220169+00:00 2021-05-02T15:09:25.779592+00:00 0:00:00.559423 23685 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T15:09:22.822294+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-02T14:00:00+00:00 TriggerDagRunOperator 2021-05-02T15:09:25.048913+00:00 2021-05-02T15:09:25.450220+00:00 0:00:00.401307 23684 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T15:09:22.822258+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-02T14:05:00+00:00 EmrJobFlowSensor 2021-05-02T15:05:58.714465+00:00 2021-05-02T15:15:01.301908+00:00 0:09:02.587443 23683 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T15:05:56.409472+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-02T14:05:00+00:00 EmrCreateJobFlowOperator 2021-05-02T15:05:36.604294+00:00 2021-05-02T15:05:38.254787+00:00 0:00:01.650493 23682 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-02T15:05:34.387335+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-02T14:05:00+00:00 PythonOperator 2021-05-02T15:05:16.610721+00:00 2021-05-02T15:05:19.590791+00:00 0:00:02.980070 23681 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T15:05:14.353352+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-02T14:00:00+00:00 EmrJobFlowSensor 2021-05-02T15:01:04.494764+00:00 2021-05-02T15:09:07.211169+00:00 0:08:02.716405 23680 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T15:01:01.869776+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-02T14:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T15:00:42.277889+00:00 2021-05-02T15:00:44.575406+00:00 0:00:02.297517 23679 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-02T15:00:39.879880+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-02T14:00:00+00:00 PythonOperator 2021-05-02T15:00:20.119704+00:00 2021-05-02T15:00:23.140153+00:00 0:00:03.020449 23678 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-02T15:00:17.797837+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-02T13:00:00+00:00 EmrJobFlowSensor 2021-05-02T14:12:15.060146+00:00 2021-05-02T14:20:17.535028+00:00 0:08:02.474882 23676 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T14:12:12.792611+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-02T13:00:00+00:00 EmrJobFlowSensor 2021-05-02T14:12:05.305044+00:00 2021-05-02T14:22:08.075360+00:00 0:10:02.770316 23675 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T14:12:02.851236+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-02T13:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T14:11:55.006270+00:00 2021-05-02T14:11:56.748814+00:00 0:00:01.742544 23674 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-02T14:11:52.700347+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-02T13:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T14:11:42.999484+00:00 2021-05-02T14:11:44.682536+00:00 0:00:01.683052 23673 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-02T14:11:40.684861+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-02T13:00:00+00:00 PythonOperator 2021-05-02T14:11:33.009464+00:00 2021-05-02T14:11:36.039930+00:00 0:00:03.030466 23672 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T14:11:30.677225+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-02T13:00:00+00:00 PythonOperator 2021-05-02T14:11:20.892682+00:00 2021-05-02T14:11:24.257255+00:00 0:00:03.364573 23671 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T14:11:18.649742+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-02T13:00:00+00:00 TriggerDagRunOperator 2021-05-02T14:11:09.234111+00:00 2021-05-02T14:11:09.766967+00:00 0:00:00.532856 23670 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T14:11:06.643372+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-02T13:00:00+00:00 TriggerDagRunOperator 2021-05-02T14:11:09.138591+00:00 2021-05-02T14:11:09.566267+00:00 0:00:00.427676 23669 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T14:11:06.643336+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-02T13:05:00+00:00 EmrJobFlowSensor 2021-05-02T14:06:04.319128+00:00 2021-05-02T14:15:07.151889+00:00 0:09:02.832761 23668 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T14:06:02.075641+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-02T13:05:00+00:00 EmrCreateJobFlowOperator 2021-05-02T14:05:42.224423+00:00 2021-05-02T14:05:43.863404+00:00 0:00:01.638981 23667 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-02T14:05:40.043246+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-02T13:05:00+00:00 PythonOperator 2021-05-02T14:05:20.404815+00:00 2021-05-02T14:05:23.464187+00:00 0:00:03.059372 23666 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T14:05:18.024099+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-02T13:00:00+00:00 EmrJobFlowSensor 2021-05-02T14:01:00.367491+00:00 2021-05-02T14:11:03.322102+00:00 0:10:02.954611 23665 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T14:00:57.766367+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-02T13:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T14:00:40.240632+00:00 2021-05-02T14:00:42.056441+00:00 0:00:01.815809 23664 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-02T14:00:37.657042+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-02T13:00:00+00:00 PythonOperator 2021-05-02T14:00:18.057630+00:00 2021-05-02T14:00:21.063670+00:00 0:00:03.006040 23663 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-02T14:00:15.588182+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-02T12:00:00+00:00 EmrJobFlowSensor 2021-05-02T13:12:27.174912+00:00 2021-05-02T13:22:30.013162+00:00 0:10:02.838250 23661 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T13:12:24.868998+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-02T12:00:00+00:00 EmrJobFlowSensor 2021-05-02T13:12:07.123464+00:00 2021-05-02T13:21:09.865535+00:00 0:09:02.742071 23660 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T13:12:04.788810+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-02T12:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T13:12:07.090640+00:00 2021-05-02T13:12:08.905512+00:00 0:00:01.814872 23659 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-02T13:12:04.788849+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-02T12:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T13:11:45.301655+00:00 2021-05-02T13:11:47.081251+00:00 0:00:01.779596 23658 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-02T13:11:42.751259+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-02T12:00:00+00:00 PythonOperator 2021-05-02T13:11:43.252497+00:00 2021-05-02T13:11:46.493911+00:00 0:00:03.241414 23657 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T13:11:40.780735+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-02T12:00:00+00:00 PythonOperator 2021-05-02T13:11:22.907545+00:00 2021-05-02T13:11:26.012602+00:00 0:00:03.105057 23656 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T13:11:20.634715+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-02T12:00:00+00:00 TriggerDagRunOperator 2021-05-02T13:11:19.367907+00:00 2021-05-02T13:11:19.889319+00:00 0:00:00.521412 23655 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T13:11:16.667741+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-02T12:00:00+00:00 TriggerDagRunOperator 2021-05-02T13:11:19.131891+00:00 2021-05-02T13:11:19.532779+00:00 0:00:00.400888 23654 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T13:11:16.667701+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-02T12:05:00+00:00 EmrJobFlowSensor 2021-05-02T13:05:54.651721+00:00 2021-05-02T13:14:57.314929+00:00 0:09:02.663208 23653 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T13:05:52.162945+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-02T12:05:00+00:00 EmrCreateJobFlowOperator 2021-05-02T13:05:32.481831+00:00 2021-05-02T13:05:34.188506+00:00 0:00:01.706675 23652 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-02T13:05:30.152259+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-02T12:05:00+00:00 PythonOperator 2021-05-02T13:05:10.268371+00:00 2021-05-02T13:05:13.266602+00:00 0:00:02.998231 23651 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T13:05:08.061689+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-02T12:00:00+00:00 EmrJobFlowSensor 2021-05-02T13:01:00.115225+00:00 2021-05-02T13:11:03.066997+00:00 0:10:02.951772 23650 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T13:00:57.757006+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-02T12:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T13:00:38.063706+00:00 2021-05-02T13:00:39.900269+00:00 0:00:01.836563 23649 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-02T13:00:35.740836+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-02T12:00:00+00:00 PythonOperator 2021-05-02T13:00:16.084956+00:00 2021-05-02T13:00:19.129720+00:00 0:00:03.044764 23648 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-02T13:00:13.700515+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-02T11:00:00+00:00 EmrJobFlowSensor 2021-05-02T12:11:26.521637+00:00 2021-05-02T12:21:29.284293+00:00 0:10:02.762656 23646 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T12:11:24.254811+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-02T11:00:00+00:00 EmrJobFlowSensor 2021-05-02T12:11:04.814348+00:00 2021-05-02T12:20:07.659585+00:00 0:09:02.845237 23645 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T12:11:02.210365+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-02T11:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T12:10:54.417907+00:00 2021-05-02T12:10:56.132156+00:00 0:00:01.714249 23644 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-02T12:10:52.198960+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-02T11:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T12:10:36.536314+00:00 2021-05-02T12:10:38.438403+00:00 0:00:01.902089 23643 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-02T12:10:34.243767+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-02T11:00:00+00:00 PythonOperator 2021-05-02T12:10:30.695275+00:00 2021-05-02T12:10:33.735384+00:00 0:00:03.040109 23642 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T12:10:28.253872+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-02T11:00:00+00:00 PythonOperator 2021-05-02T12:10:16.371552+00:00 2021-05-02T12:10:19.633787+00:00 0:00:03.262235 23641 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T12:10:14.127351+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-02T11:00:00+00:00 TriggerDagRunOperator 2021-05-02T12:10:10.503278+00:00 2021-05-02T12:10:10.919298+00:00 0:00:00.416020 23640 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T12:10:08.121801+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-02T11:00:00+00:00 TriggerDagRunOperator 2021-05-02T12:10:10.505953+00:00 2021-05-02T12:10:11.074453+00:00 0:00:00.568500 23639 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T12:10:08.121758+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-02T11:05:00+00:00 EmrJobFlowSensor 2021-05-02T12:05:50.114764+00:00 2021-05-02T12:14:52.810701+00:00 0:09:02.695937 23638 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T12:05:47.757728+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-02T11:05:00+00:00 EmrCreateJobFlowOperator 2021-05-02T12:05:28.127481+00:00 2021-05-02T12:05:29.752110+00:00 0:00:01.624629 23637 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-02T12:05:25.779833+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-02T11:05:00+00:00 PythonOperator 2021-05-02T12:05:07.885820+00:00 2021-05-02T12:05:10.920314+00:00 0:00:03.034494 23636 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T12:05:05.700628+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-02T11:00:00+00:00 EmrJobFlowSensor 2021-05-02T12:00:51.410910+00:00 2021-05-02T12:09:54.160703+00:00 0:09:02.749793 23635 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T12:00:49.261279+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-02T11:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T12:00:29.403177+00:00 2021-05-02T12:00:31.108723+00:00 0:00:01.705546 23634 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-02T12:00:27.241787+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-02T11:00:00+00:00 PythonOperator 2021-05-02T12:00:08.046886+00:00 2021-05-02T12:00:11.189363+00:00 0:00:03.142477 23633 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-02T12:00:05.264945+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-02T10:00:00+00:00 EmrJobFlowSensor 2021-05-02T11:10:02.326041+00:00 2021-05-02T11:19:05.054925+00:00 0:09:02.728884 23631 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T11:10:00.114778+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-02T10:00:00+00:00 EmrJobFlowSensor 2021-05-02T11:10:00.343537+00:00 2021-05-02T11:19:03.123962+00:00 0:09:02.780425 23630 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T11:09:58.048638+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-02T10:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T11:09:40.785350+00:00 2021-05-02T11:09:42.607501+00:00 0:00:01.822151 23629 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-02T11:09:38.007296+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-02T10:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T11:09:38.489274+00:00 2021-05-02T11:09:40.619971+00:00 0:00:02.130697 23628 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-02T11:09:36.006276+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-02T10:00:00+00:00 PythonOperator 2021-05-02T11:09:18.363831+00:00 2021-05-02T11:09:21.737112+00:00 0:00:03.373281 23627 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T11:09:15.987871+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-02T10:00:00+00:00 PythonOperator 2021-05-02T11:09:16.223094+00:00 2021-05-02T11:09:19.262578+00:00 0:00:03.039484 23626 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T11:09:13.986571+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-02T10:00:00+00:00 TriggerDagRunOperator 2021-05-02T11:09:12.462550+00:00 2021-05-02T11:09:12.997207+00:00 0:00:00.534657 23625 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T11:09:10.047329+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-02T10:00:00+00:00 TriggerDagRunOperator 2021-05-02T11:09:12.411772+00:00 2021-05-02T11:09:12.935302+00:00 0:00:00.523530 23624 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T11:09:10.047275+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-02T10:05:00+00:00 EmrJobFlowSensor 2021-05-02T11:06:12.069150+00:00 2021-05-02T11:15:14.626616+00:00 0:09:02.557466 23623 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T11:06:09.774634+00:00 2 default_pool