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 create_emr_steps 2021-04-23T00:00:00+00:00 PythonOperator 2021-04-23T01:11:26.062201+00:00 2021-04-23T01:11:29.024501+00:00 0:00:02.962300 20209 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T01:11:23.492680+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-23T00:00:00+00:00 TriggerDagRunOperator 2021-04-23T01:11:19.826174+00:00 2021-04-23T01:11:20.346210+00:00 0:00:00.520036 20208 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T01:11:17.496818+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-23T00:00:00+00:00 TriggerDagRunOperator 2021-04-23T01:11:19.784576+00:00 2021-04-23T01:11:20.193515+00:00 0:00:00.408939 20207 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T01:11:17.496864+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-23T00:05:00+00:00 EmrJobFlowSensor 2021-04-23T01:05:50.572470+00:00 2021-04-23T01:14:53.122575+00:00 0:09:02.550105 20206 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T01:05:48.414739+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-23T00:05:00+00:00 EmrCreateJobFlowOperator 2021-04-23T01:05:28.686389+00:00 2021-04-23T01:05:30.340235+00:00 0:00:01.653846 20205 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-23T01:05:26.359733+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-23T00:05:00+00:00 PythonOperator 2021-04-23T01:05:06.649415+00:00 2021-04-23T01:05:09.555175+00:00 0:00:02.905760 20204 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T01:05:04.355261+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-23T00:00:00+00:00 EmrJobFlowSensor 2021-04-23T01:01:00.438999+00:00 2021-04-23T01:11:03.380673+00:00 0:10:02.941674 20203 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T01:00:57.760329+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-23T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-23T01:00:37.914531+00:00 2021-04-23T01:00:39.593073+00:00 0:00:01.678542 20202 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-23T01:00:35.563803+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-23T00:00:00+00:00 PythonOperator 2021-04-23T01:00:17.770431+00:00 2021-04-23T01:00:21.005131+00:00 0:00:03.234700 20201 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-23T01:00:15.434514+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-22T23:00:00+00:00 EmrJobFlowSensor 2021-04-23T00:13:16.536446+00:00 2021-04-23T00:22:19.324973+00:00 0:09:02.788527 20199 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T00:13:14.195011+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-22T23:00:00+00:00 EmrJobFlowSensor 2021-04-23T00:13:12.606077+00:00 2021-04-23T00:22:15.287115+00:00 0:09:02.681038 20198 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T00:13:10.196602+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-22T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-23T00:12:54.528633+00:00 2021-04-23T00:12:56.252862+00:00 0:00:01.724229 20197 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-23T00:12:52.187577+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-22T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-23T00:12:50.330420+00:00 2021-04-23T00:12:52.108996+00:00 0:00:01.778576 20196 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-23T00:12:48.137053+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-22T23:00:00+00:00 PythonOperator 2021-04-23T00:12:34.342087+00:00 2021-04-23T00:12:37.554379+00:00 0:00:03.212292 20195 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T00:12:32.124196+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-22T23:00:00+00:00 PythonOperator 2021-04-23T00:12:30.483263+00:00 2021-04-23T00:12:33.444215+00:00 0:00:02.960952 20194 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T00:12:28.170914+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-22T23:00:00+00:00 TriggerDagRunOperator 2021-04-23T00:12:10.924641+00:00 2021-04-23T00:12:11.332111+00:00 0:00:00.407470 20193 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T00:12:08.102735+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-22T23:00:00+00:00 TriggerDagRunOperator 2021-04-23T00:12:10.386710+00:00 2021-04-23T00:12:10.919276+00:00 0:00:00.532566 20192 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T00:12:08.102766+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-22T23:05:00+00:00 EmrJobFlowSensor 2021-04-23T00:06:05.730368+00:00 2021-04-23T00:15:08.256789+00:00 0:09:02.526421 20191 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T00:06:03.452605+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-22T23:05:00+00:00 EmrCreateJobFlowOperator 2021-04-23T00:05:43.734576+00:00 2021-04-23T00:05:45.523512+00:00 0:00:01.788936 20190 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-23T00:05:41.403473+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-22T23:05:00+00:00 PythonOperator 2021-04-23T00:05:21.777528+00:00 2021-04-23T00:05:24.739662+00:00 0:00:02.962134 20189 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T00:05:19.330377+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-22T23:00:00+00:00 EmrJobFlowSensor 2021-04-23T00:01:01.273023+00:00 2021-04-23T00:12:04.259855+00:00 0:11:02.986832 20188 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T00:00:58.668100+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-22T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-23T00:00:38.935337+00:00 2021-04-23T00:00:40.835595+00:00 0:00:01.900258 20187 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-23T00:00:36.462225+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-22T23:00:00+00:00 PythonOperator 2021-04-23T00:00:17.119268+00:00 2021-04-23T00:00:20.588016+00:00 0:00:03.468748 20186 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-23T00:00:14.281639+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-22T22:00:00+00:00 EmrJobFlowSensor 2021-04-22T23:12:23.308928+00:00 2021-04-22T23:22:26.159656+00:00 0:10:02.850728 20184 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T23:12:21.125130+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-22T22:00:00+00:00 EmrJobFlowSensor 2021-04-22T23:12:07.384279+00:00 2021-04-22T23:22:10.149954+00:00 0:10:02.765675 20183 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T23:12:05.168076+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-22T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T23:11:55.871548+00:00 2021-04-22T23:11:57.606068+00:00 0:00:01.734520 20182 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-22T23:11:53.096164+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-22T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T23:11:47.328265+00:00 2021-04-22T23:11:49.019127+00:00 0:00:01.690862 20181 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-22T23:11:45.101977+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-22T22:00:00+00:00 PythonOperator 2021-04-22T23:11:34.110463+00:00 2021-04-22T23:11:37.907429+00:00 0:00:03.796966 20180 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T23:11:31.067014+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-22T22:00:00+00:00 PythonOperator 2021-04-22T23:11:25.713945+00:00 2021-04-22T23:11:28.895733+00:00 0:00:03.181788 20179 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T23:11:22.932171+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-22T22:00:00+00:00 TriggerDagRunOperator 2021-04-22T23:11:17.227493+00:00 2021-04-22T23:11:17.737495+00:00 0:00:00.510002 20178 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T23:11:14.920271+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-22T22:00:00+00:00 TriggerDagRunOperator 2021-04-22T23:11:17.089082+00:00 2021-04-22T23:11:17.477416+00:00 0:00:00.388334 20177 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T23:11:14.920234+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-22T22:05:00+00:00 EmrJobFlowSensor 2021-04-22T23:05:46.691732+00:00 2021-04-22T23:14:49.217845+00:00 0:09:02.526113 20176 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T23:05:44.365267+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-22T22:05:00+00:00 EmrCreateJobFlowOperator 2021-04-22T23:05:26.374955+00:00 2021-04-22T23:05:28.021890+00:00 0:00:01.646935 20175 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-22T23:05:24.241644+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-22T22:05:00+00:00 PythonOperator 2021-04-22T23:05:05.318592+00:00 2021-04-22T23:05:08.298856+00:00 0:00:02.980264 20174 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T23:05:02.223248+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-22T22:00:00+00:00 EmrJobFlowSensor 2021-04-22T23:01:06.260401+00:00 2021-04-22T23:11:09.180779+00:00 0:10:02.920378 20173 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T23:01:03.845425+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-04-21T23:00:00+00:00 EmrJobFlowSensor 2021-04-22T23:00:55.950335+00:00 2021-04-22T23:09:58.453649+00:00 0:09:02.503314 20172 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T23:00:53.750576+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-22T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T23:00:44.683585+00:00 2021-04-22T23:00:46.485839+00:00 0:00:01.802254 20171 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-22T23:00:41.731839+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-04-21T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T23:00:36.261888+00:00 2021-04-22T23:00:37.986739+00:00 0:00:01.724851 20170 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-22T23:00:33.885532+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-22T22:00:00+00:00 PythonOperator 2021-04-22T23:00:24.155604+00:00 2021-04-22T23:00:27.114183+00:00 0:00:02.958579 20169 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-22T23:00:21.712577+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-04-21T23:00:00+00:00 PythonOperator 2021-04-22T23:00:14.131646+00:00 2021-04-22T23:00:17.380638+00:00 0:00:03.248992 20168 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T23:00:11.702960+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-22T21:00:00+00:00 EmrJobFlowSensor 2021-04-22T22:11:26.335179+00:00 2021-04-22T22:20:29.107634+00:00 0:09:02.772455 20166 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T22:11:24.065803+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-22T21:00:00+00:00 EmrJobFlowSensor 2021-04-22T22:11:24.590882+00:00 2021-04-22T22:20:27.185748+00:00 0:09:02.594866 20165 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T22:11:22.045447+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-22T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T22:11:04.836555+00:00 2021-04-22T22:11:06.669294+00:00 0:00:01.832739 20164 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-22T22:11:02.021516+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-22T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T22:11:02.075545+00:00 2021-04-22T22:11:04.356657+00:00 0:00:02.281112 20163 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-22T22:10:59.760335+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-22T21:00:00+00:00 PythonOperator 2021-04-22T22:10:41.931513+00:00 2021-04-22T22:10:44.888494+00:00 0:00:02.956981 20162 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T22:10:39.654289+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-22T21:00:00+00:00 PythonOperator 2021-04-22T22:10:39.997847+00:00 2021-04-22T22:10:43.248575+00:00 0:00:03.250728 20161 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T22:10:37.591314+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-22T21:00:00+00:00 TriggerDagRunOperator 2021-04-22T22:10:15.920950+00:00 2021-04-22T22:10:16.340185+00:00 0:00:00.419235 20160 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T22:10:13.519869+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-22T21:00:00+00:00 TriggerDagRunOperator 2021-04-22T22:10:15.906869+00:00 2021-04-22T22:10:16.457580+00:00 0:00:00.550711 20159 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T22:10:13.519915+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-22T21:05:00+00:00 EmrJobFlowSensor 2021-04-22T22:06:01.482658+00:00 2021-04-22T22:14:04.054593+00:00 0:08:02.571935 20158 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T22:05:59.149608+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-22T21:05:00+00:00 EmrCreateJobFlowOperator 2021-04-22T22:05:39.420067+00:00 2021-04-22T22:05:41.084469+00:00 0:00:01.664402 20157 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-22T22:05:36.967656+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-22T21:05:00+00:00 PythonOperator 2021-04-22T22:05:19.149695+00:00 2021-04-22T22:05:22.110275+00:00 0:00:02.960580 20156 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T22:05:16.881889+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-22T21:00:00+00:00 EmrJobFlowSensor 2021-04-22T22:01:00.770497+00:00 2021-04-22T22:10:03.565311+00:00 0:09:02.794814 20155 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T22:00:58.244331+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-22T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T22:00:38.340889+00:00 2021-04-22T22:00:40.105780+00:00 0:00:01.764891 20154 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-22T22:00:36.112356+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-22T21:00:00+00:00 PythonOperator 2021-04-22T22:00:16.403013+00:00 2021-04-22T22:00:19.545487+00:00 0:00:03.142474 20153 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-22T22:00:14.094138+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-22T20:00:00+00:00 EmrJobFlowSensor 2021-04-22T21:12:21.213743+00:00 2021-04-22T21:22:24.031244+00:00 0:10:02.817501 20151 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T21:12:18.944932+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-22T20:00:00+00:00 EmrJobFlowSensor 2021-04-22T21:12:17.245815+00:00 2021-04-22T21:21:20.035099+00:00 0:09:02.789284 20150 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T21:12:14.944152+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-22T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T21:11:59.055977+00:00 2021-04-22T21:12:00.739155+00:00 0:00:01.683178 20149 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-22T21:11:56.866506+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-22T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T21:11:55.768724+00:00 2021-04-22T21:11:57.593043+00:00 0:00:01.824319 20148 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-22T21:11:52.849147+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-22T20:00:00+00:00 PythonOperator 2021-04-22T21:11:39.587439+00:00 2021-04-22T21:11:43.344053+00:00 0:00:03.756614 20147 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T21:11:36.791273+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-22T20:00:00+00:00 PythonOperator 2021-04-22T21:11:35.365026+00:00 2021-04-22T21:11:39.332244+00:00 0:00:03.967218 20146 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T21:11:32.862844+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-22T20:00:00+00:00 TriggerDagRunOperator 2021-04-22T21:11:21.034617+00:00 2021-04-22T21:11:21.537026+00:00 0:00:00.502409 20145 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T21:11:18.708885+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-22T20:00:00+00:00 TriggerDagRunOperator 2021-04-22T21:11:20.917719+00:00 2021-04-22T21:11:21.347573+00:00 0:00:00.429854 20144 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T21:11:18.708933+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-22T20:05:00+00:00 EmrJobFlowSensor 2021-04-22T21:06:04.117593+00:00 2021-04-22T21:15:06.776655+00:00 0:09:02.659062 20143 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T21:06:01.805661+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-22T20:05:00+00:00 EmrCreateJobFlowOperator 2021-04-22T21:05:42.031579+00:00 2021-04-22T21:05:43.701719+00:00 0:00:01.670140 20142 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-22T21:05:39.749897+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-22T20:05:00+00:00 PythonOperator 2021-04-22T21:05:21.701589+00:00 2021-04-22T21:05:24.668678+00:00 0:00:02.967089 20141 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T21:05:19.576401+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-22T20:00:00+00:00 EmrJobFlowSensor 2021-04-22T21:00:55.059205+00:00 2021-04-22T21:10:58.008795+00:00 0:10:02.949590 20140 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T21:00:52.802763+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-22T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T21:00:35.248437+00:00 2021-04-22T21:00:37.067190+00:00 0:00:01.818753 20139 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-22T21:00:32.786101+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-22T20:00:00+00:00 PythonOperator 2021-04-22T21:00:11.014894+00:00 2021-04-22T21:00:14.042985+00:00 0:00:03.028091 20138 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-22T21:00:08.729845+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-22T19:00:00+00:00 EmrJobFlowSensor 2021-04-22T20:13:16.869992+00:00 2021-04-22T20:23:19.719960+00:00 0:10:02.849968 20136 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T20:13:14.428674+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-22T19:00:00+00:00 EmrJobFlowSensor 2021-04-22T20:13:03.223648+00:00 2021-04-22T20:23:06.003965+00:00 0:10:02.780317 20135 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T20:13:00.472636+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-22T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T20:12:54.907242+00:00 2021-04-22T20:12:56.636261+00:00 0:00:01.729019 20134 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-22T20:12:52.466464+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-22T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T20:12:41.206439+00:00 2021-04-22T20:12:43.039779+00:00 0:00:01.833340 20133 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-22T20:12:38.337229+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-22T19:00:00+00:00 PythonOperator 2021-04-22T20:12:32.710480+00:00 2021-04-22T20:12:36.009636+00:00 0:00:03.299156 20132 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T20:12:30.389419+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-22T19:00:00+00:00 PythonOperator 2021-04-22T20:12:21.259406+00:00 2021-04-22T20:12:24.257245+00:00 0:00:02.997839 20131 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T20:12:18.326326+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-22T19:00:00+00:00 TriggerDagRunOperator 2021-04-22T20:12:12.625918+00:00 2021-04-22T20:12:13.222940+00:00 0:00:00.597022 20130 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T20:12:10.314804+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-22T19:00:00+00:00 TriggerDagRunOperator 2021-04-22T20:12:12.530873+00:00 2021-04-22T20:12:12.973593+00:00 0:00:00.442720 20129 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T20:12:10.314832+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-22T19:05:00+00:00 EmrJobFlowSensor 2021-04-22T20:05:51.943005+00:00 2021-04-22T20:13:54.495511+00:00 0:08:02.552506 20128 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T20:05:49.700568+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-22T19:05:00+00:00 EmrCreateJobFlowOperator 2021-04-22T20:05:30.083437+00:00 2021-04-22T20:05:31.718730+00:00 0:00:01.635293 20127 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-22T20:05:27.761306+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-22T19:05:00+00:00 PythonOperator 2021-04-22T20:05:09.952929+00:00 2021-04-22T20:05:12.892585+00:00 0:00:02.939656 20126 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T20:05:07.619702+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-22T19:00:00+00:00 EmrJobFlowSensor 2021-04-22T20:00:51.277880+00:00 2021-04-22T20:11:54.221721+00:00 0:11:02.943841 20125 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T20:00:49.061711+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-22T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T20:00:29.370921+00:00 2021-04-22T20:00:31.110894+00:00 0:00:01.739973 20124 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-22T20:00:27.016387+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-22T19:00:00+00:00 PythonOperator 2021-04-22T20:00:09.414902+00:00 2021-04-22T20:00:12.399795+00:00 0:00:02.984893 20123 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-22T20:00:07.003700+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-22T18:00:00+00:00 EmrJobFlowSensor 2021-04-22T19:12:59.860926+00:00 2021-04-22T19:25:03.005248+00:00 0:12:03.144322 20121 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T19:12:57.555040+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-22T18:00:00+00:00 EmrJobFlowSensor 2021-04-22T19:12:45.967666+00:00 2021-04-22T19:22:48.704220+00:00 0:10:02.736554 20120 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T19:12:43.568030+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-22T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T19:12:37.739714+00:00 2021-04-22T19:12:39.696839+00:00 0:00:01.957125 20119 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-22T19:12:35.491203+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-22T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T19:12:25.819770+00:00 2021-04-22T19:12:27.488792+00:00 0:00:01.669022 20118 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-22T19:12:23.432257+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-22T18:00:00+00:00 PythonOperator 2021-04-22T19:12:15.713470+00:00 2021-04-22T19:12:18.689743+00:00 0:00:02.976273 20117 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T19:12:13.468596+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-22T18:00:00+00:00 PythonOperator 2021-04-22T19:12:04.007299+00:00 2021-04-22T19:12:07.248047+00:00 0:00:03.240748 20116 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T19:12:01.414689+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-22T18:00:00+00:00 TriggerDagRunOperator 2021-04-22T19:11:55.863533+00:00 2021-04-22T19:11:56.404850+00:00 0:00:00.541317 20115 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T19:11:53.408873+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-22T18:00:00+00:00 TriggerDagRunOperator 2021-04-22T19:11:55.647929+00:00 2021-04-22T19:11:56.068456+00:00 0:00:00.420527 20114 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T19:11:53.408845+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-22T18:05:00+00:00 EmrJobFlowSensor 2021-04-22T19:06:06.998658+00:00 2021-04-22T19:15:09.545270+00:00 0:09:02.546612 20113 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T19:06:04.740214+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-22T18:05:00+00:00 EmrCreateJobFlowOperator 2021-04-22T19:05:45.217405+00:00 2021-04-22T19:05:46.834922+00:00 0:00:01.617517 20112 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-22T19:05:42.774524+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-22T18:05:00+00:00 PythonOperator 2021-04-22T19:05:25.052373+00:00 2021-04-22T19:05:28.088852+00:00 0:00:03.036479 20111 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T19:05:22.656450+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-22T18:00:00+00:00 EmrJobFlowSensor 2021-04-22T19:00:48.571993+00:00 2021-04-22T19:11:51.667625+00:00 0:11:03.095632 20110 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T19:00:46.096199+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-22T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T19:00:26.283595+00:00 2021-04-22T19:00:28.098577+00:00 0:00:01.814982 20109 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-22T19:00:24.077173+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-22T18:00:00+00:00 PythonOperator 2021-04-22T19:00:04.483542+00:00 2021-04-22T19:00:07.762813+00:00 0:00:03.279271 20108 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-22T19:00:02.062966+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-22T17:00:00+00:00 EmrJobFlowSensor 2021-04-22T18:16:58.936920+00:00 2021-04-22T18:27:01.699453+00:00 0:10:02.762533 20107 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T18:16:56.370669+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-22T17:00:00+00:00 EmrJobFlowSensor 2021-04-22T18:16:46.903677+00:00 2021-04-22T18:25:49.587196+00:00 0:09:02.683519 20106 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T18:16:44.369932+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-22T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T18:16:36.827108+00:00 2021-04-22T18:16:38.490110+00:00 0:00:01.663002 20105 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-22T18:16:34.349898+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-22T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T18:16:26.563902+00:00 2021-04-22T18:16:28.375992+00:00 0:00:01.812090 20104 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-22T18:16:24.229613+00:00 2 default_pool