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_campaign-history-job_v002 2021-05-03T08:00:00+00:00 TriggerDagRunOperator 2021-05-03T09:11:24.777051+00:00 2021-05-03T09:11:25.200375+00:00 0:00:00.423324 23960 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T09:11:22.186595+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-03T08:00:00+00:00 TriggerDagRunOperator 2021-05-03T09:11:24.776934+00:00 2021-05-03T09:11:25.310604+00:00 0:00:00.533670 23959 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T09:11:22.186641+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-03T08:05:00+00:00 EmrJobFlowSensor 2021-05-03T09:06:00.570807+00:00 2021-05-03T09:15:03.190675+00:00 0:09:02.619868 23957 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T09:05:58.150621+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-03T08:05:00+00:00 EmrCreateJobFlowOperator 2021-05-03T09:05:40.297611+00:00 2021-05-03T09:05:41.965177+00:00 0:00:01.667566 23956 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-03T09:05:37.988045+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-03T08:05:00+00:00 PythonOperator 2021-05-03T09:05:18.380049+00:00 2021-05-03T09:05:21.442047+00:00 0:00:03.061998 23955 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T09:05:15.945415+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-03T08:00:00+00:00 EmrJobFlowSensor 2021-05-03T09:01:05.999036+00:00 2021-05-03T09:11:08.907666+00:00 0:10:02.908630 23954 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T09:01:03.658405+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-03T08:00:00+00:00 EmrCreateJobFlowOperator 2021-05-03T09:00:41.811198+00:00 2021-05-03T09:00:43.513066+00:00 0:00:01.701868 23953 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-03T09:00:39.584482+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-03T08:00:00+00:00 PythonOperator 2021-05-03T09:00:21.742881+00:00 2021-05-03T09:00:24.865800+00:00 0:00:03.122919 23952 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-03T09:00:19.495816+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-03T07:00:00+00:00 EmrJobFlowSensor 2021-05-03T08:12:18.897426+00:00 2021-05-03T08:22:21.716361+00:00 0:10:02.818935 23951 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T08:12:16.726433+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-03T07:00:00+00:00 EmrJobFlowSensor 2021-05-03T08:12:06.903143+00:00 2021-05-03T08:21:09.681783+00:00 0:09:02.778640 23950 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T08:12:04.740858+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-03T07:00:00+00:00 EmrCreateJobFlowOperator 2021-05-03T08:11:57.226331+00:00 2021-05-03T08:11:59.075539+00:00 0:00:01.849208 23949 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-03T08:11:54.759354+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-03T07:00:00+00:00 EmrCreateJobFlowOperator 2021-05-03T08:11:44.896258+00:00 2021-05-03T08:11:46.696477+00:00 0:00:01.800219 23948 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-03T08:11:42.699678+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-03T07:00:00+00:00 PythonOperator 2021-05-03T08:11:37.015377+00:00 2021-05-03T08:11:40.241888+00:00 0:00:03.226511 23947 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T08:11:34.690662+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-03T07:00:00+00:00 PythonOperator 2021-05-03T08:11:25.140465+00:00 2021-05-03T08:11:28.156362+00:00 0:00:03.015897 23946 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T08:11:22.638258+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-03T07:00:00+00:00 TriggerDagRunOperator 2021-05-03T08:11:17.380300+00:00 2021-05-03T08:11:17.940128+00:00 0:00:00.559828 23945 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T08:11:14.560281+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-03T07:00:00+00:00 TriggerDagRunOperator 2021-05-03T08:11:17.336387+00:00 2021-05-03T08:11:17.771167+00:00 0:00:00.434780 23944 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T08:11:14.560237+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-03T07:05:00+00:00 EmrJobFlowSensor 2021-05-03T08:06:00.814390+00:00 2021-05-03T08:14:03.365487+00:00 0:08:02.551097 23942 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T08:05:58.460755+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-03T07:05:00+00:00 EmrCreateJobFlowOperator 2021-05-03T08:05:40.459824+00:00 2021-05-03T08:05:42.105927+00:00 0:00:01.646103 23941 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-03T08:05:38.207911+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-03T07:05:00+00:00 PythonOperator 2021-05-03T08:05:18.835681+00:00 2021-05-03T08:05:21.854619+00:00 0:00:03.018938 23940 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T08:05:16.263836+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-03T07:00:00+00:00 EmrJobFlowSensor 2021-05-03T08:00:56.200221+00:00 2021-05-03T08:10:58.998178+00:00 0:10:02.797957 23939 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T08:00:53.790277+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-03T07:00:00+00:00 EmrCreateJobFlowOperator 2021-05-03T08:00:33.988847+00:00 2021-05-03T08:00:35.713696+00:00 0:00:01.724849 23938 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-03T08:00:31.670516+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-03T07:00:00+00:00 PythonOperator 2021-05-03T08:00:13.811622+00:00 2021-05-03T08:00:16.896241+00:00 0:00:03.084619 23937 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-03T08:00:11.652809+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-03T06:00:00+00:00 EmrJobFlowSensor 2021-05-03T07:11:12.562491+00:00 2021-05-03T07:21:15.351617+00:00 0:10:02.789126 23936 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T07:11:10.285787+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-03T06:00:00+00:00 EmrJobFlowSensor 2021-05-03T07:11:08.482675+00:00 2021-05-03T07:19:11.102584+00:00 0:08:02.619909 23935 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T07:11:06.289670+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-03T06:00:00+00:00 EmrCreateJobFlowOperator 2021-05-03T07:10:52.418379+00:00 2021-05-03T07:10:54.159500+00:00 0:00:01.741121 23934 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-03T07:10:50.209201+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-03T06:00:00+00:00 EmrCreateJobFlowOperator 2021-05-03T07:10:46.500042+00:00 2021-05-03T07:10:48.291774+00:00 0:00:01.791732 23933 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-03T07:10:44.212083+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-03T06:00:00+00:00 PythonOperator 2021-05-03T07:10:30.835518+00:00 2021-05-03T07:10:34.207403+00:00 0:00:03.371885 23932 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T07:10:28.253602+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-03T06:00:00+00:00 PythonOperator 2021-05-03T07:10:24.660148+00:00 2021-05-03T07:10:27.844797+00:00 0:00:03.184649 23931 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T07:10:22.147681+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-03T06:00:00+00:00 TriggerDagRunOperator 2021-05-03T07:10:10.408076+00:00 2021-05-03T07:10:10.928597+00:00 0:00:00.520521 23930 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T07:10:08.014257+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-03T06:00:00+00:00 TriggerDagRunOperator 2021-05-03T07:10:10.275396+00:00 2021-05-03T07:10:10.706551+00:00 0:00:00.431155 23929 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T07:10:08.014225+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-03T06:05:00+00:00 EmrJobFlowSensor 2021-05-03T07:07:40.300394+00:00 2021-05-03T07:16:42.942375+00:00 0:09:02.641981 23928 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T07:07:37.876904+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-03T06:05:00+00:00 EmrCreateJobFlowOperator 2021-05-03T07:07:18.033504+00:00 2021-05-03T07:07:19.672172+00:00 0:00:01.638668 23927 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-03T07:07:15.788430+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-03T06:05:00+00:00 PythonOperator 2021-05-03T07:06:58.008513+00:00 2021-05-03T07:07:01.175105+00:00 0:00:03.166592 23926 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T07:06:55.699384+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-03T06:00:00+00:00 EmrJobFlowSensor 2021-05-03T07:00:51.858238+00:00 2021-05-03T07:09:54.547496+00:00 0:09:02.689258 23924 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T07:00:49.471983+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-03T06:00:00+00:00 EmrCreateJobFlowOperator 2021-05-03T07:00:29.713007+00:00 2021-05-03T07:00:31.438663+00:00 0:00:01.725656 23923 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-03T07:00:27.421779+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-03T06:00:00+00:00 PythonOperator 2021-05-03T07:00:10.040827+00:00 2021-05-03T07:00:13.138097+00:00 0:00:03.097270 23922 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-03T07:00:07.397572+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-03T05:00:00+00:00 EmrJobFlowSensor 2021-05-03T06:23:00.195843+00:00 2021-05-03T06:23:01.813994+00:00 0:00:01.618151 23921 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T06:22:57.852423+00:00 3 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-03T05:00:00+00:00 EmrJobFlowSensor 2021-05-03T06:22:57.996530+00:00 2021-05-03T06:22:59.515639+00:00 0:00:01.519109 23920 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T06:22:55.844492+00:00 3 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-03T05:00:00+00:00 EmrCreateJobFlowOperator 2021-05-03T06:11:19.031917+00:00 2021-05-03T06:11:20.846462+00:00 0:00:01.814545 23917 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-03T06:11:16.448037+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-03T05:00:00+00:00 EmrCreateJobFlowOperator 2021-05-03T06:11:03.336356+00:00 2021-05-03T06:11:05.124230+00:00 0:00:01.787874 23916 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-03T06:11:00.421361+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-03T05:00:00+00:00 PythonOperator 2021-05-03T06:10:58.593589+00:00 2021-05-03T06:11:02.146586+00:00 0:00:03.552997 23915 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T06:10:56.379360+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-03T05:00:00+00:00 PythonOperator 2021-05-03T06:10:40.540423+00:00 2021-05-03T06:10:43.843816+00:00 0:00:03.303393 23914 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T06:10:38.260617+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-03T05:00:00+00:00 TriggerDagRunOperator 2021-05-03T06:10:34.875523+00:00 2021-05-03T06:10:35.488395+00:00 0:00:00.612872 23913 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T06:10:32.249367+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-03T05:00:00+00:00 TriggerDagRunOperator 2021-05-03T06:10:34.655164+00:00 2021-05-03T06:10:35.363709+00:00 0:00:00.708545 23912 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T06:10:32.249395+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-03T05:05:00+00:00 EmrJobFlowSensor 2021-05-03T06:05:47.910578+00:00 2021-05-03T06:14:50.496971+00:00 0:09:02.586393 23911 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T06:05:45.724471+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-03T05:05:00+00:00 EmrCreateJobFlowOperator 2021-05-03T06:05:25.968977+00:00 2021-05-03T06:05:27.698817+00:00 0:00:01.729840 23910 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-03T06:05:23.706137+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-03T05:05:00+00:00 PythonOperator 2021-05-03T06:05:04.205845+00:00 2021-05-03T06:05:07.385430+00:00 0:00:03.179585 23909 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T06:05:01.689350+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-03T05:00:00+00:00 EmrJobFlowSensor 2021-05-03T06:01:23.902695+00:00 2021-05-03T06:10:26.440853+00:00 0:09:02.538158 23908 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T06:01:21.384765+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-03T05:00:00+00:00 EmrCreateJobFlowOperator 2021-05-03T06:00:42.195687+00:00 2021-05-03T06:00:43.874104+00:00 0:00:01.678417 23906 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-03T06:00:39.857206+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-03T05:00:00+00:00 PythonOperator 2021-05-03T06:00:19.979813+00:00 2021-05-03T06:00:23.027908+00:00 0:00:03.048095 23905 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-03T06:00:17.746700+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-03T04:00:00+00:00 EmrJobFlowSensor 2021-05-03T05:13:00.287153+00:00 2021-05-03T05:23:03.341232+00:00 0:10:03.054079 23904 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T05:12:57.854815+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-03T04:00:00+00:00 EmrJobFlowSensor 2021-05-03T05:12:49.957681+00:00 2021-05-03T05:21:52.728147+00:00 0:09:02.770466 23903 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T05:12:47.728419+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-03T04:00:00+00:00 EmrCreateJobFlowOperator 2021-05-03T05:12:38.176663+00:00 2021-05-03T05:12:39.888734+00:00 0:00:01.712071 23902 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-03T05:12:35.717326+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-03T04:00:00+00:00 EmrCreateJobFlowOperator 2021-05-03T05:12:27.978669+00:00 2021-05-03T05:12:29.719708+00:00 0:00:01.741039 23901 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-03T05:12:25.716104+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-03T04:00:00+00:00 PythonOperator 2021-05-03T05:12:16.200442+00:00 2021-05-03T05:12:19.488861+00:00 0:00:03.288419 23900 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T05:12:13.781266+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-03T04:00:00+00:00 PythonOperator 2021-05-03T05:12:06.368020+00:00 2021-05-03T05:12:09.440384+00:00 0:00:03.072364 23899 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T05:12:03.704339+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-03T04:00:00+00:00 TriggerDagRunOperator 2021-05-03T05:11:58.397404+00:00 2021-05-03T05:11:58.881770+00:00 0:00:00.484366 23898 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T05:11:55.768368+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-03T04:00:00+00:00 TriggerDagRunOperator 2021-05-03T05:11:58.276378+00:00 2021-05-03T05:11:58.859149+00:00 0:00:00.582771 23897 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T05:11:55.768418+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-03T04:05:00+00:00 EmrJobFlowSensor 2021-05-03T05:06:01.064443+00:00 2021-05-03T05:15:03.752701+00:00 0:09:02.688258 23896 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T05:05:58.763338+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-03T04:05:00+00:00 EmrCreateJobFlowOperator 2021-05-03T05:05:38.999596+00:00 2021-05-03T05:05:40.726074+00:00 0:00:01.726478 23895 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-03T05:05:36.716553+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-03T04:05:00+00:00 PythonOperator 2021-05-03T05:05:15.126176+00:00 2021-05-03T05:05:18.209571+00:00 0:00:03.083395 23894 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T05:05:12.704238+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-03T04:00:00+00:00 EmrJobFlowSensor 2021-05-03T05:01:32.515174+00:00 2021-05-03T05:11:35.268736+00:00 0:10:02.753562 23893 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T05:01:30.253721+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-03T04:00:00+00:00 EmrCreateJobFlowOperator 2021-05-03T05:01:10.334253+00:00 2021-05-03T05:01:12.176746+00:00 0:00:01.842493 23892 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-03T05:01:08.117478+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-03T04:00:00+00:00 PythonOperator 2021-05-03T05:00:50.835409+00:00 2021-05-03T05:00:53.902191+00:00 0:00:03.066782 23891 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-03T05:00:48.016203+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-03T03:00:00+00:00 EmrJobFlowSensor 2021-05-03T04:10:08.154251+00:00 2021-05-03T04:18:10.611246+00:00 0:08:02.456995 23889 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T04:10:05.493488+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-03T03:00:00+00:00 EmrJobFlowSensor 2021-05-03T04:10:05.895490+00:00 2021-05-03T04:20:08.947596+00:00 0:10:03.052106 23888 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T04:10:03.501046+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-03T03:00:00+00:00 EmrCreateJobFlowOperator 2021-05-03T04:09:45.655088+00:00 2021-05-03T04:09:47.316885+00:00 0:00:01.661797 23887 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-03T04:09:43.446251+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-03T03:00:00+00:00 EmrCreateJobFlowOperator 2021-05-03T04:09:43.740910+00:00 2021-05-03T04:09:45.551588+00:00 0:00:01.810678 23886 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-03T04:09:41.450289+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-03T03:00:00+00:00 PythonOperator 2021-05-03T04:09:23.771439+00:00 2021-05-03T04:09:26.821745+00:00 0:00:03.050306 23885 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T04:09:21.434626+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-03T03:00:00+00:00 PythonOperator 2021-05-03T04:09:21.604740+00:00 2021-05-03T04:09:24.872356+00:00 0:00:03.267616 23884 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T04:09:19.433919+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-03T03:00:00+00:00 TriggerDagRunOperator 2021-05-03T04:09:08.129224+00:00 2021-05-03T04:09:08.690983+00:00 0:00:00.561759 23883 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T04:09:05.544373+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-03T03:00:00+00:00 TriggerDagRunOperator 2021-05-03T04:09:07.938592+00:00 2021-05-03T04:09:08.445195+00:00 0:00:00.506603 23882 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T04:09:05.544420+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-03T03:05:00+00:00 EmrJobFlowSensor 2021-05-03T04:06:05.393332+00:00 2021-05-03T04:15:08.119783+00:00 0:09:02.726451 23881 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T04:06:03.147769+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-03T03:05:00+00:00 EmrCreateJobFlowOperator 2021-05-03T04:05:41.309102+00:00 2021-05-03T04:05:43.099164+00:00 0:00:01.790062 23880 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-03T04:05:39.081575+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-03T03:05:00+00:00 PythonOperator 2021-05-03T04:05:19.354342+00:00 2021-05-03T04:05:22.397670+00:00 0:00:03.043328 23879 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T04:05:17.006429+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-03T03:00:00+00:00 EmrJobFlowSensor 2021-05-03T04:00:59.008839+00:00 2021-05-03T04:09:01.650627+00:00 0:08:02.641788 23878 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T04:00:56.540853+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-03T03:00:00+00:00 EmrCreateJobFlowOperator 2021-05-03T04:00:36.794078+00:00 2021-05-03T04:00:38.568155+00:00 0:00:01.774077 23877 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-03T04:00:34.461922+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-03T03:00:00+00:00 PythonOperator 2021-05-03T04:00:16.744996+00:00 2021-05-03T04:00:19.739164+00:00 0:00:02.994168 23876 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-03T04:00:14.335625+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-03T02:00:00+00:00 EmrJobFlowSensor 2021-05-03T03:11:36.081131+00:00 2021-05-03T03:20:38.649585+00:00 0:09:02.568454 23874 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T03:11:33.916664+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-03T02:00:00+00:00 EmrJobFlowSensor 2021-05-03T03:11:24.231141+00:00 2021-05-03T03:20:26.796600+00:00 0:09:02.565459 23873 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T03:11:21.901867+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-03T02:00:00+00:00 EmrCreateJobFlowOperator 2021-05-03T03:11:10.301508+00:00 2021-05-03T03:11:12.018838+00:00 0:00:01.717330 23872 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-03T03:11:07.977623+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-03T02:00:00+00:00 EmrCreateJobFlowOperator 2021-05-03T03:10:58.127062+00:00 2021-05-03T03:10:59.823878+00:00 0:00:01.696816 23871 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-03T03:10:55.842037+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-03T02:00:00+00:00 PythonOperator 2021-05-03T03:10:40.188480+00:00 2021-05-03T03:10:43.195401+00:00 0:00:03.006921 23870 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T03:10:37.826238+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-03T02:00:00+00:00 PythonOperator 2021-05-03T03:10:30.296603+00:00 2021-05-03T03:10:33.606630+00:00 0:00:03.310027 23869 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T03:10:27.873593+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-03T02:00:00+00:00 TriggerDagRunOperator 2021-05-03T03:10:20.560315+00:00 2021-05-03T03:10:20.985082+00:00 0:00:00.424767 23868 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T03:10:17.875303+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-03T02:00:00+00:00 TriggerDagRunOperator 2021-05-03T03:10:20.299673+00:00 2021-05-03T03:10:20.822111+00:00 0:00:00.522438 23867 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T03:10:17.875337+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-03T02:05:00+00:00 EmrJobFlowSensor 2021-05-03T03:05:47.385617+00:00 2021-05-03T03:13:49.769250+00:00 0:08:02.383633 23866 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T03:05:45.187818+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-03T02:05:00+00:00 EmrCreateJobFlowOperator 2021-05-03T03:05:25.346728+00:00 2021-05-03T03:05:27.080378+00:00 0:00:01.733650 23865 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-03T03:05:23.164012+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-03T02:05:00+00:00 PythonOperator 2021-05-03T03:05:05.382871+00:00 2021-05-03T03:05:08.559856+00:00 0:00:03.176985 23864 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T03:05:03.144385+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-03T02:00:00+00:00 EmrJobFlowSensor 2021-05-03T03:01:02.620243+00:00 2021-05-03T03:10:05.383760+00:00 0:09:02.763517 23863 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T03:01:00.400249+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-03T02:00:00+00:00 EmrCreateJobFlowOperator 2021-05-03T03:00:40.796385+00:00 2021-05-03T03:00:42.544458+00:00 0:00:01.748073 23862 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-03T03:00:38.372557+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-03T02:00:00+00:00 PythonOperator 2021-05-03T03:00:20.942948+00:00 2021-05-03T03:00:23.976662+00:00 0:00:03.033714 23861 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-03T03:00:18.369564+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-03T01:00:00+00:00 EmrJobFlowSensor 2021-05-03T02:10:13.158208+00:00 2021-05-03T02:18:15.687394+00:00 0:08:02.529186 23859 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T02:10:10.407166+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-03T01:00:00+00:00 EmrJobFlowSensor 2021-05-03T02:10:10.805225+00:00 2021-05-03T02:20:13.967517+00:00 0:10:03.162292 23858 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T02:10:08.417620+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-03T01:00:00+00:00 EmrCreateJobFlowOperator 2021-05-03T02:09:50.674538+00:00 2021-05-03T02:09:52.387425+00:00 0:00:01.712887 23857 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-03T02:09:48.382897+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-03T01:00:00+00:00 EmrCreateJobFlowOperator 2021-05-03T02:09:50.660825+00:00 2021-05-03T02:09:52.484755+00:00 0:00:01.823930 23856 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-03T02:09:48.382856+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-03T01:00:00+00:00 PythonOperator 2021-05-03T02:09:28.780982+00:00 2021-05-03T02:09:32.133112+00:00 0:00:03.352130 23855 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T02:09:26.361393+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-03T01:00:00+00:00 PythonOperator 2021-05-03T02:09:28.757023+00:00 2021-05-03T02:09:31.785817+00:00 0:00:03.028794 23854 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T02:09:26.361358+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-03T01:00:00+00:00 TriggerDagRunOperator 2021-05-03T02:09:18.846944+00:00 2021-05-03T02:09:19.378815+00:00 0:00:00.531871 23853 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T02:09:16.354115+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-03T01:00:00+00:00 TriggerDagRunOperator 2021-05-03T02:09:18.735301+00:00 2021-05-03T02:09:19.173786+00:00 0:00:00.438485 23852 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T02:09:16.354162+00:00 2 default_pool