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-04-13T15:00:00+00:00 EmrJobFlowSensor 2021-04-13T16:19:27.228919+00:00 2021-04-13T16:27:29.741659+00:00 0:08:02.512740 16792 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T16:19:24.646980+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-13T15:00:00+00:00 EmrJobFlowSensor 2021-04-13T16:19:27.001080+00:00 2021-04-13T16:30:29.946555+00:00 0:11:02.945475 16791 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T16:19:24.647007+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-13T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T16:19:07.482396+00:00 2021-04-13T16:19:09.176408+00:00 0:00:01.694012 16790 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T16:19:04.752341+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-13T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T16:19:05.006766+00:00 2021-04-13T16:19:07.114610+00:00 0:00:02.107844 16789 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T16:19:02.588898+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-13T15:00:00+00:00 PythonOperator 2021-04-13T16:18:44.990974+00:00 2021-04-13T16:18:48.527624+00:00 0:00:03.536650 16788 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T16:18:42.551658+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-13T15:00:00+00:00 PythonOperator 2021-04-13T16:18:44.850837+00:00 2021-04-13T16:18:47.784557+00:00 0:00:02.933720 16787 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T16:18:42.551623+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-13T15:00:00+00:00 TriggerDagRunOperator 2021-04-13T16:18:28.980873+00:00 2021-04-13T16:18:29.468751+00:00 0:00:00.487878 16786 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T16:18:26.533003+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-13T15:00:00+00:00 TriggerDagRunOperator 2021-04-13T16:18:28.788043+00:00 2021-04-13T16:18:29.181649+00:00 0:00:00.393606 16785 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T16:18:26.533040+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-13T15:00:00+00:00 EmrJobFlowSensor 2021-04-13T16:09:01.924468+00:00 2021-04-13T16:18:04.739745+00:00 0:09:02.815277 16784 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T16:08:59.716252+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-13T15:05:00+00:00 EmrJobFlowSensor 2021-04-13T16:08:53.985099+00:00 2021-04-13T16:18:56.703028+00:00 0:10:02.717929 16783 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T16:08:51.695941+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-13T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T16:08:40.124560+00:00 2021-04-13T16:08:42.338608+00:00 0:00:02.214048 16782 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-13T16:08:37.743675+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-13T15:05:00+00:00 EmrCreateJobFlowOperator 2021-04-13T16:08:31.854630+00:00 2021-04-13T16:08:33.575214+00:00 0:00:01.720584 16781 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T16:08:29.646143+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-13T15:00:00+00:00 PythonOperator 2021-04-13T16:08:20.012917+00:00 2021-04-13T16:08:22.925882+00:00 0:00:02.912965 16780 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-13T16:08:17.635541+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-13T15:05:00+00:00 PythonOperator 2021-04-13T16:08:12.149972+00:00 2021-04-13T16:08:15.097783+00:00 0:00:02.947811 16779 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T16:08:09.680021+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-13T14:00:00+00:00 EmrJobFlowSensor 2021-04-13T15:11:09.516844+00:00 2021-04-13T15:21:12.235390+00:00 0:10:02.718546 16777 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T15:11:07.053265+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-13T14:00:00+00:00 EmrJobFlowSensor 2021-04-13T15:11:05.358463+00:00 2021-04-13T15:22:08.278502+00:00 0:11:02.920039 16776 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T15:11:02.987400+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-13T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T15:10:49.322585+00:00 2021-04-13T15:10:51.077935+00:00 0:00:01.755350 16775 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T15:10:46.971794+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-13T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T15:10:45.285953+00:00 2021-04-13T15:10:46.986255+00:00 0:00:01.700302 16774 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T15:10:42.844022+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-13T14:00:00+00:00 PythonOperator 2021-04-13T15:10:27.773305+00:00 2021-04-13T15:10:30.768335+00:00 0:00:02.995030 16773 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T15:10:24.767649+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-13T14:00:00+00:00 PythonOperator 2021-04-13T15:10:23.182610+00:00 2021-04-13T15:10:27.045996+00:00 0:00:03.863386 16772 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T15:10:20.759000+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-13T14:00:00+00:00 TriggerDagRunOperator 2021-04-13T15:10:05.323050+00:00 2021-04-13T15:10:05.864247+00:00 0:00:00.541197 16771 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T15:10:02.691503+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-13T14:00:00+00:00 TriggerDagRunOperator 2021-04-13T15:10:05.043524+00:00 2021-04-13T15:10:05.613019+00:00 0:00:00.569495 16770 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T15:10:02.691536+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-13T14:05:00+00:00 EmrJobFlowSensor 2021-04-13T15:05:54.681700+00:00 2021-04-13T15:14:57.215843+00:00 0:09:02.534143 16769 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T15:05:52.266513+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-13T14:05:00+00:00 EmrCreateJobFlowOperator 2021-04-13T15:05:32.580557+00:00 2021-04-13T15:05:34.254197+00:00 0:00:01.673640 16768 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T15:05:30.187158+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-13T14:05:00+00:00 PythonOperator 2021-04-13T15:05:10.388970+00:00 2021-04-13T15:05:13.245495+00:00 0:00:02.856525 16767 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T15:05:08.143326+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-13T14:00:00+00:00 EmrJobFlowSensor 2021-04-13T15:00:56.117771+00:00 2021-04-13T15:09:58.692298+00:00 0:09:02.574527 16766 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T15:00:53.887363+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-13T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T15:00:34.193774+00:00 2021-04-13T15:00:35.897894+00:00 0:00:01.704120 16765 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-13T15:00:31.847157+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-13T14:00:00+00:00 PythonOperator 2021-04-13T15:00:12.298305+00:00 2021-04-13T15:00:15.284801+00:00 0:00:02.986496 16764 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-13T15:00:09.830735+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-13T13:00:00+00:00 EmrJobFlowSensor 2021-04-13T14:12:15.775417+00:00 2021-04-13T14:21:18.443757+00:00 0:09:02.668340 16762 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T14:12:13.490922+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-13T13:00:00+00:00 EmrJobFlowSensor 2021-04-13T14:12:13.852655+00:00 2021-04-13T14:22:16.678474+00:00 0:10:02.825819 16761 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T14:12:11.490967+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-13T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T14:11:53.601394+00:00 2021-04-13T14:11:55.381088+00:00 0:00:01.779694 16760 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T14:11:51.398941+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-13T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T14:11:51.625558+00:00 2021-04-13T14:11:53.481127+00:00 0:00:01.855569 16759 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T14:11:49.398057+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-13T13:00:00+00:00 PythonOperator 2021-04-13T14:11:33.591033+00:00 2021-04-13T14:11:36.832259+00:00 0:00:03.241226 16758 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T14:11:31.384354+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-13T13:00:00+00:00 PythonOperator 2021-04-13T14:11:31.665667+00:00 2021-04-13T14:11:35.155729+00:00 0:00:03.490062 16757 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T14:11:29.384027+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-13T13:00:00+00:00 TriggerDagRunOperator 2021-04-13T14:11:21.593916+00:00 2021-04-13T14:11:22.080932+00:00 0:00:00.487016 16756 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T14:11:19.372672+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-13T13:00:00+00:00 TriggerDagRunOperator 2021-04-13T14:11:21.627741+00:00 2021-04-13T14:11:22.220665+00:00 0:00:00.592924 16755 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T14:11:19.372708+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-13T13:05:00+00:00 EmrJobFlowSensor 2021-04-13T14:05:55.154157+00:00 2021-04-13T14:14:57.758499+00:00 0:09:02.604342 16754 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T14:05:52.904009+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-13T13:05:00+00:00 EmrCreateJobFlowOperator 2021-04-13T14:05:35.307040+00:00 2021-04-13T14:05:37.488735+00:00 0:00:02.181695 16753 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T14:05:32.943713+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-13T13:05:00+00:00 PythonOperator 2021-04-13T14:05:13.091729+00:00 2021-04-13T14:05:15.945353+00:00 0:00:02.853624 16752 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T14:05:10.867942+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-13T13:00:00+00:00 EmrJobFlowSensor 2021-04-13T14:01:08.711726+00:00 2021-04-13T14:11:11.463267+00:00 0:10:02.751541 16751 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T14:01:06.489439+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-13T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T14:00:38.733456+00:00 2021-04-13T14:00:40.546004+00:00 0:00:01.812548 16750 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-13T14:00:36.418369+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-13T13:00:00+00:00 PythonOperator 2021-04-13T14:00:11.002038+00:00 2021-04-13T14:00:13.982608+00:00 0:00:02.980570 16749 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-13T14:00:08.402061+00:00 2 default_pool
success primary-audience-global-ind_v003 create_cluster 2021-04-13T13:39:16.290631+00:00 PythonOperator 2021-04-13T13:39:48.803496+00:00 2021-04-13T13:39:52.537285+00:00 0:00:03.733789 16747 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T13:39:46.380788+00:00 2 default_pool
success primary-audience-global-ind_v003 validation 2021-04-13T13:39:16.290631+00:00 PythonOperator 2021-04-13T13:39:26.819777+00:00 2021-04-13T13:39:27.197299+00:00 0:00:00.377522 16746 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T13:39:24.375060+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-13T12:00:00+00:00 EmrJobFlowSensor 2021-04-13T13:11:33.595128+00:00 2021-04-13T13:21:36.291164+00:00 0:10:02.696036 16745 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T13:11:31.427018+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-13T12:00:00+00:00 EmrJobFlowSensor 2021-04-13T13:11:30.144673+00:00 2021-04-13T13:20:32.816406+00:00 0:09:02.671733 16744 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T13:11:27.429168+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-13T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T13:11:09.771149+00:00 2021-04-13T13:11:11.513963+00:00 0:00:01.742814 16743 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T13:11:07.497655+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-13T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T13:11:08.001327+00:00 2021-04-13T13:11:09.871496+00:00 0:00:01.870169 16742 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T13:11:05.467855+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-13T12:00:00+00:00 PythonOperator 2021-04-13T13:10:49.777483+00:00 2021-04-13T13:10:52.956588+00:00 0:00:03.179105 16741 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T13:10:47.392444+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-13T12:00:00+00:00 PythonOperator 2021-04-13T13:10:47.814869+00:00 2021-04-13T13:10:50.809130+00:00 0:00:02.994261 16740 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T13:10:45.388790+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-13T12:00:00+00:00 TriggerDagRunOperator 2021-04-13T13:10:25.738440+00:00 2021-04-13T13:10:26.281599+00:00 0:00:00.543159 16739 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T13:10:23.351531+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-13T12:00:00+00:00 TriggerDagRunOperator 2021-04-13T13:10:25.580305+00:00 2021-04-13T13:10:26.007867+00:00 0:00:00.427562 16738 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T13:10:23.351558+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-13T12:05:00+00:00 EmrJobFlowSensor 2021-04-13T13:05:55.333979+00:00 2021-04-13T13:14:57.864918+00:00 0:09:02.530939 16737 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T13:05:52.983884+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-13T12:05:00+00:00 EmrCreateJobFlowOperator 2021-04-13T13:05:33.376394+00:00 2021-04-13T13:05:35.147754+00:00 0:00:01.771360 16736 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T13:05:30.939030+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-13T12:05:00+00:00 PythonOperator 2021-04-13T13:05:11.280437+00:00 2021-04-13T13:05:14.189192+00:00 0:00:02.908755 16735 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T13:05:08.960087+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-13T12:00:00+00:00 EmrJobFlowSensor 2021-04-13T13:01:02.921373+00:00 2021-04-13T13:10:05.786012+00:00 0:09:02.864639 16734 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T13:01:00.384836+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-13T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T13:00:40.528233+00:00 2021-04-13T13:00:42.236766+00:00 0:00:01.708533 16733 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-13T13:00:38.298606+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-13T12:00:00+00:00 PythonOperator 2021-04-13T13:00:18.609347+00:00 2021-04-13T13:00:21.486889+00:00 0:00:02.877542 16732 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-13T13:00:16.262871+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-13T11:00:00+00:00 EmrJobFlowSensor 2021-04-13T12:12:55.112978+00:00 2021-04-13T12:21:57.715025+00:00 0:09:02.602047 16730 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T12:12:52.760770+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-13T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T12:12:33.165192+00:00 2021-04-13T12:12:34.993532+00:00 0:00:01.828340 16729 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T12:12:30.747829+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-13T11:00:00+00:00 EmrJobFlowSensor 2021-04-13T12:12:15.120483+00:00 2021-04-13T12:21:17.720389+00:00 0:09:02.599906 16728 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T12:12:12.743410+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-13T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T12:11:44.969077+00:00 2021-04-13T12:11:46.722383+00:00 0:00:01.753306 16727 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T12:11:42.646855+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-13T11:00:00+00:00 PythonOperator 2021-04-13T12:11:19.013545+00:00 2021-04-13T12:11:22.091393+00:00 0:00:03.077848 16726 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T12:11:16.627172+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-13T11:00:00+00:00 PythonOperator 2021-04-13T12:11:15.039243+00:00 2021-04-13T12:11:17.981996+00:00 0:00:02.942753 16725 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T12:11:12.621721+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-13T11:00:00+00:00 TriggerDagRunOperator 2021-04-13T12:11:09.243590+00:00 2021-04-13T12:11:09.754778+00:00 0:00:00.511188 16724 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T12:11:06.617761+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-13T11:00:00+00:00 TriggerDagRunOperator 2021-04-13T12:11:08.998657+00:00 2021-04-13T12:11:09.417557+00:00 0:00:00.418900 16723 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T12:11:06.617792+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-13T11:05:00+00:00 EmrJobFlowSensor 2021-04-13T12:06:00.187961+00:00 2021-04-13T12:15:02.842717+00:00 0:09:02.654756 16722 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T12:05:57.919366+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-13T11:05:00+00:00 EmrCreateJobFlowOperator 2021-04-13T12:05:30.570800+00:00 2021-04-13T12:05:32.216486+00:00 0:00:01.645686 16721 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T12:05:28.044810+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-13T11:05:00+00:00 PythonOperator 2021-04-13T12:05:10.081805+00:00 2021-04-13T12:05:12.976139+00:00 0:00:02.894334 16720 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T12:05:07.829144+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-13T11:00:00+00:00 EmrJobFlowSensor 2021-04-13T12:01:02.005525+00:00 2021-04-13T12:11:04.766695+00:00 0:10:02.761170 16719 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T12:00:59.553781+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-13T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T12:00:39.510193+00:00 2021-04-13T12:00:41.245595+00:00 0:00:01.735402 16718 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-13T12:00:37.352472+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-13T11:00:00+00:00 PythonOperator 2021-04-13T12:00:19.607812+00:00 2021-04-13T12:00:22.563236+00:00 0:00:02.955424 16717 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-13T12:00:17.336072+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-13T10:00:00+00:00 EmrJobFlowSensor 2021-04-13T11:12:14.801136+00:00 2021-04-13T11:23:17.554853+00:00 0:11:02.753717 16715 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T11:12:12.596841+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-13T10:00:00+00:00 EmrJobFlowSensor 2021-04-13T11:12:10.909724+00:00 2021-04-13T11:20:13.531815+00:00 0:08:02.622091 16714 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T11:12:08.665657+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-13T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T11:11:53.109121+00:00 2021-04-13T11:11:54.899662+00:00 0:00:01.790541 16713 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T11:11:50.560215+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-13T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T11:11:48.863182+00:00 2021-04-13T11:11:50.688451+00:00 0:00:01.825269 16712 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T11:11:46.552217+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-13T10:00:00+00:00 PythonOperator 2021-04-13T11:11:33.199931+00:00 2021-04-13T11:11:36.437430+00:00 0:00:03.237499 16711 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T11:11:30.471230+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-13T10:00:00+00:00 PythonOperator 2021-04-13T11:11:28.746812+00:00 2021-04-13T11:11:32.083329+00:00 0:00:03.336517 16710 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T11:11:26.451152+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-13T10:00:00+00:00 TriggerDagRunOperator 2021-04-13T11:11:12.799827+00:00 2021-04-13T11:11:13.233524+00:00 0:00:00.433697 16709 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T11:11:10.462103+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-13T10:00:00+00:00 TriggerDagRunOperator 2021-04-13T11:11:12.759892+00:00 2021-04-13T11:11:13.355510+00:00 0:00:00.595618 16708 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T11:11:10.462073+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-13T10:05:00+00:00 EmrJobFlowSensor 2021-04-13T11:05:54.488384+00:00 2021-04-13T11:13:56.918507+00:00 0:08:02.430123 16707 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T11:05:51.964161+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-13T10:05:00+00:00 EmrCreateJobFlowOperator 2021-04-13T11:05:34.114408+00:00 2021-04-13T11:05:35.728766+00:00 0:00:01.614358 16706 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T11:05:31.788295+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-13T10:05:00+00:00 PythonOperator 2021-04-13T11:05:12.017737+00:00 2021-04-13T11:05:14.910201+00:00 0:00:02.892464 16705 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T11:05:09.765887+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-13T10:00:00+00:00 EmrJobFlowSensor 2021-04-13T11:01:03.870633+00:00 2021-04-13T11:11:06.880627+00:00 0:10:03.009994 16704 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T11:01:01.360287+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-13T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T11:00:41.520946+00:00 2021-04-13T11:00:43.254261+00:00 0:00:01.733315 16703 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-13T11:00:39.201653+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-13T10:00:00+00:00 PythonOperator 2021-04-13T11:00:21.578219+00:00 2021-04-13T11:00:24.546974+00:00 0:00:02.968755 16702 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-13T11:00:19.189343+00:00 2 default_pool
success primary-audience-global-ind_v003 create_cluster 2021-04-13T10:20:25.508179+00:00 PythonOperator 2021-04-13T10:21:10.412237+00:00 2021-04-13T10:21:13.534862+00:00 0:00:03.122625 16700 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T10:21:08.219844+00:00 2 default_pool
success primary-audience-global-ind_v003 validation 2021-04-13T10:20:25.508179+00:00 PythonOperator 2021-04-13T10:20:48.595873+00:00 2021-04-13T10:20:48.958776+00:00 0:00:00.362903 16699 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T10:20:46.272188+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-13T09:00:00+00:00 EmrJobFlowSensor 2021-04-13T10:12:23.741443+00:00 2021-04-13T10:24:26.776302+00:00 0:12:03.034859 16698 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T10:12:21.406240+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-13T09:00:00+00:00 EmrJobFlowSensor 2021-04-13T10:12:21.532982+00:00 2021-04-13T10:22:24.442325+00:00 0:10:02.909343 16697 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T10:12:19.404845+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-13T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T10:12:02.167383+00:00 2021-04-13T10:12:04.168476+00:00 0:00:02.001093 16696 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T10:11:59.051631+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-13T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T10:12:02.091100+00:00 2021-04-13T10:12:03.839532+00:00 0:00:01.748432 16695 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T10:11:59.051583+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-13T09:00:00+00:00 PythonOperator 2021-04-13T10:11:41.136925+00:00 2021-04-13T10:11:44.198063+00:00 0:00:03.061138 16694 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T10:11:38.877439+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-13T09:00:00+00:00 PythonOperator 2021-04-13T10:11:39.434787+00:00 2021-04-13T10:11:42.155701+00:00 0:00:02.720914 16693 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T10:11:36.902446+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-13T09:00:00+00:00 TriggerDagRunOperator 2021-04-13T10:11:19.499452+00:00 2021-04-13T10:11:20.031735+00:00 0:00:00.532283 16692 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T10:11:16.875367+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-13T09:00:00+00:00 TriggerDagRunOperator 2021-04-13T10:11:19.245682+00:00 2021-04-13T10:11:19.670873+00:00 0:00:00.425191 16691 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T10:11:16.875397+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-13T09:05:00+00:00 EmrJobFlowSensor 2021-04-13T10:05:54.592679+00:00 2021-04-13T10:13:57.140942+00:00 0:08:02.548263 16690 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T10:05:52.294667+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-13T09:05:00+00:00 EmrCreateJobFlowOperator 2021-04-13T10:05:34.595877+00:00 2021-04-13T10:05:36.367600+00:00 0:00:01.771723 16689 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T10:05:32.280857+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-13T09:05:00+00:00 PythonOperator 2021-04-13T10:05:12.568458+00:00 2021-04-13T10:05:15.340103+00:00 0:00:02.771645 16688 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T10:05:10.267720+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-13T09:00:00+00:00 EmrJobFlowSensor 2021-04-13T10:01:00.286433+00:00 2021-04-13T10:11:03.117944+00:00 0:10:02.831511 16687 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T10:00:57.958791+00:00 2 default_pool