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 vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-11T18:05:00+00:00 EmrCreateJobFlowOperator 2021-04-11T19:05:34.486626+00:00 2021-04-11T19:05:36.216128+00:00 0:00:01.729502 16100 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T19:05:32.187360+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-11T18:05:00+00:00 PythonOperator 2021-04-11T19:05:12.263273+00:00 2021-04-11T19:05:15.702044+00:00 0:00:03.438771 16099 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T19:05:10.137111+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-11T18:00:00+00:00 EmrJobFlowSensor 2021-04-11T19:01:06.084310+00:00 2021-04-11T19:20:10.052611+00:00 0:19:03.968301 16098 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T19:01:03.840873+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-11T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T19:00:45.881780+00:00 2021-04-11T19:00:47.543931+00:00 0:00:01.662151 16097 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-11T19:00:43.713828+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-11T18:00:00+00:00 PythonOperator 2021-04-11T19:00:24.620193+00:00 2021-04-11T19:00:27.563136+00:00 0:00:02.942943 16096 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-11T19:00:21.751293+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-11T17:00:00+00:00 EmrJobFlowSensor 2021-04-11T18:10:35.460924+00:00 2021-04-11T18:19:38.082373+00:00 0:09:02.621449 16094 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T18:10:33.266474+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-11T17:00:00+00:00 EmrJobFlowSensor 2021-04-11T18:10:33.671731+00:00 2021-04-11T18:20:36.402042+00:00 0:10:02.730311 16093 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T18:10:31.349679+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-11T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T18:10:15.649625+00:00 2021-04-11T18:10:17.461137+00:00 0:00:01.811512 16092 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T18:10:13.195416+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-11T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T18:10:11.502222+00:00 2021-04-11T18:10:13.207559+00:00 0:00:01.705337 16091 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T18:10:09.273213+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-11T17:00:00+00:00 PythonOperator 2021-04-11T18:09:53.761661+00:00 2021-04-11T18:09:56.556734+00:00 0:00:02.795073 16090 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T18:09:51.146176+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-11T17:00:00+00:00 PythonOperator 2021-04-11T18:09:51.338639+00:00 2021-04-11T18:09:54.652475+00:00 0:00:03.313836 16089 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T18:09:49.153272+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-11T17:00:00+00:00 TriggerDagRunOperator 2021-04-11T18:09:35.691585+00:00 2021-04-11T18:09:36.207051+00:00 0:00:00.515466 16088 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T18:09:33.169341+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-11T17:00:00+00:00 TriggerDagRunOperator 2021-04-11T18:09:35.558341+00:00 2021-04-11T18:09:35.957059+00:00 0:00:00.398718 16087 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T18:09:33.169302+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-11T17:05:00+00:00 EmrJobFlowSensor 2021-04-11T18:05:47.186781+00:00 2021-04-11T18:14:49.853272+00:00 0:09:02.666491 16086 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T18:05:44.852801+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-11T17:05:00+00:00 EmrCreateJobFlowOperator 2021-04-11T18:05:25.094070+00:00 2021-04-11T18:05:26.749780+00:00 0:00:01.655710 16085 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T18:05:22.730594+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-11T17:05:00+00:00 PythonOperator 2021-04-11T18:05:04.851137+00:00 2021-04-11T18:05:07.516707+00:00 0:00:02.665570 16084 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T18:05:02.712370+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-11T17:00:00+00:00 EmrJobFlowSensor 2021-04-11T18:01:20.666914+00:00 2021-04-11T18:09:23.275602+00:00 0:08:02.608688 16083 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T18:01:18.417846+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-11T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T18:00:44.621916+00:00 2021-04-11T18:00:46.297419+00:00 0:00:01.675503 16082 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-11T18:00:42.410706+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-11T17:00:00+00:00 PythonOperator 2021-04-11T18:00:25.109351+00:00 2021-04-11T18:00:28.033426+00:00 0:00:02.924075 16081 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-11T18:00:22.344073+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-11T16:00:00+00:00 EmrJobFlowSensor 2021-04-11T17:11:24.662666+00:00 2021-04-11T17:21:27.516388+00:00 0:10:02.853722 16079 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T17:11:22.175141+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-11T16:00:00+00:00 EmrJobFlowSensor 2021-04-11T17:11:12.856374+00:00 2021-04-11T17:20:16.243600+00:00 0:09:03.387226 16078 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T17:11:10.109870+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-11T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T17:11:02.523041+00:00 2021-04-11T17:11:04.337095+00:00 0:00:01.814054 16077 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T17:11:00.160590+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-11T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T17:10:50.336002+00:00 2021-04-11T17:10:52.016473+00:00 0:00:01.680471 16076 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T17:10:48.083414+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-11T16:00:00+00:00 PythonOperator 2021-04-11T17:10:40.295228+00:00 2021-04-11T17:10:43.358963+00:00 0:00:03.063735 16075 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T17:10:38.037098+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-11T16:00:00+00:00 PythonOperator 2021-04-11T17:10:30.325051+00:00 2021-04-11T17:10:33.059740+00:00 0:00:02.734689 16074 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T17:10:28.043324+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-11T16:00:00+00:00 TriggerDagRunOperator 2021-04-11T17:10:20.391272+00:00 2021-04-11T17:10:20.927413+00:00 0:00:00.536141 16073 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T17:10:18.017897+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-11T16:00:00+00:00 TriggerDagRunOperator 2021-04-11T17:10:20.260404+00:00 2021-04-11T17:10:20.669691+00:00 0:00:00.409287 16072 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T17:10:18.017870+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-11T16:05:00+00:00 EmrJobFlowSensor 2021-04-11T17:05:49.656080+00:00 2021-04-11T17:14:52.260646+00:00 0:09:02.604566 16071 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T17:05:47.352542+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-11T16:05:00+00:00 EmrCreateJobFlowOperator 2021-04-11T17:05:29.654867+00:00 2021-04-11T17:05:31.408115+00:00 0:00:01.753248 16070 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T17:05:27.333736+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-11T16:05:00+00:00 PythonOperator 2021-04-11T17:05:07.647849+00:00 2021-04-11T17:05:10.416044+00:00 0:00:02.768195 16069 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T17:05:05.317324+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-11T16:00:00+00:00 EmrJobFlowSensor 2021-04-11T17:01:09.240876+00:00 2021-04-11T17:10:11.891300+00:00 0:09:02.650424 16068 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T17:01:06.988111+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-11T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T17:00:45.202017+00:00 2021-04-11T17:00:46.919137+00:00 0:00:01.717120 16067 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-11T17:00:42.888753+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-11T16:00:00+00:00 PythonOperator 2021-04-11T17:00:25.307314+00:00 2021-04-11T17:00:28.000069+00:00 0:00:02.692755 16066 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-11T17:00:22.830877+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-11T15:00:00+00:00 EmrJobFlowSensor 2021-04-11T16:12:26.093892+00:00 2021-04-11T16:21:28.696598+00:00 0:09:02.602706 16064 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T16:12:23.948243+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-11T15:00:00+00:00 EmrJobFlowSensor 2021-04-11T16:12:22.088255+00:00 2021-04-11T16:22:24.873669+00:00 0:10:02.785414 16063 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T16:12:19.932499+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-11T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T16:12:04.088600+00:00 2021-04-11T16:12:05.793628+00:00 0:00:01.705028 16062 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T16:12:01.912259+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-11T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T16:12:00.299714+00:00 2021-04-11T16:12:02.187218+00:00 0:00:01.887504 16061 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T16:11:57.910816+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-11T15:00:00+00:00 PythonOperator 2021-04-11T16:11:42.390941+00:00 2021-04-11T16:11:45.196388+00:00 0:00:02.805447 16060 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T16:11:39.896897+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-11T15:00:00+00:00 PythonOperator 2021-04-11T16:11:38.143641+00:00 2021-04-11T16:11:41.526373+00:00 0:00:03.382732 16059 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T16:11:35.892719+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-11T15:00:00+00:00 TriggerDagRunOperator 2021-04-11T16:11:22.320610+00:00 2021-04-11T16:11:22.914122+00:00 0:00:00.593512 16058 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T16:11:19.873411+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-11T15:00:00+00:00 TriggerDagRunOperator 2021-04-11T16:11:22.228933+00:00 2021-04-11T16:11:22.656454+00:00 0:00:00.427521 16057 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T16:11:19.873379+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-11T15:05:00+00:00 EmrJobFlowSensor 2021-04-11T16:06:01.659824+00:00 2021-04-11T16:15:04.425148+00:00 0:09:02.765324 16056 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T16:05:59.434550+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-11T15:05:00+00:00 EmrCreateJobFlowOperator 2021-04-11T16:05:37.721364+00:00 2021-04-11T16:05:39.508626+00:00 0:00:01.787262 16055 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T16:05:35.417334+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-11T15:05:00+00:00 PythonOperator 2021-04-11T16:05:15.589325+00:00 2021-04-11T16:05:18.266588+00:00 0:00:02.677263 16054 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T16:05:13.396464+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-11T15:00:00+00:00 EmrJobFlowSensor 2021-04-11T16:01:08.107286+00:00 2021-04-11T16:11:10.955308+00:00 0:10:02.848022 16053 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T16:01:05.067362+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-11T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T16:00:45.395002+00:00 2021-04-11T16:00:47.226181+00:00 0:00:01.831179 16052 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-11T16:00:43.046566+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-11T15:00:00+00:00 PythonOperator 2021-04-11T16:00:23.744721+00:00 2021-04-11T16:00:26.638285+00:00 0:00:02.893564 16051 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-11T16:00:20.930706+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-11T14:00:00+00:00 EmrJobFlowSensor 2021-04-11T15:11:08.113111+00:00 2021-04-11T15:21:10.861954+00:00 0:10:02.748843 16049 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T15:11:05.790841+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-11T14:00:00+00:00 EmrJobFlowSensor 2021-04-11T15:11:04.151579+00:00 2021-04-11T15:20:06.839227+00:00 0:09:02.687648 16048 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T15:11:01.784551+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-11T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T15:10:46.130620+00:00 2021-04-11T15:10:47.963162+00:00 0:00:01.832542 16047 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T15:10:43.763698+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-11T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T15:10:42.133401+00:00 2021-04-11T15:10:43.864789+00:00 0:00:01.731388 16046 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T15:10:39.758726+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-11T14:00:00+00:00 PythonOperator 2021-04-11T15:10:26.411705+00:00 2021-04-11T15:10:29.154231+00:00 0:00:02.742526 16045 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T15:10:23.775607+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-11T14:00:00+00:00 PythonOperator 2021-04-11T15:10:20.129331+00:00 2021-04-11T15:10:23.140498+00:00 0:00:03.011167 16044 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T15:10:17.751659+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-11T14:00:00+00:00 TriggerDagRunOperator 2021-04-11T15:10:04.095080+00:00 2021-04-11T15:10:04.679509+00:00 0:00:00.584429 16043 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T15:10:01.650375+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-11T14:00:00+00:00 TriggerDagRunOperator 2021-04-11T15:10:03.848506+00:00 2021-04-11T15:10:04.273373+00:00 0:00:00.424867 16042 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T15:10:01.650404+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-11T14:05:00+00:00 EmrJobFlowSensor 2021-04-11T15:05:47.618160+00:00 2021-04-11T15:14:50.285234+00:00 0:09:02.667074 16041 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T15:05:45.242358+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-11T14:05:00+00:00 EmrCreateJobFlowOperator 2021-04-11T15:05:25.499613+00:00 2021-04-11T15:05:27.237975+00:00 0:00:01.738362 16040 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T15:05:23.226772+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-11T14:05:00+00:00 PythonOperator 2021-04-11T15:05:05.482163+00:00 2021-04-11T15:05:08.189490+00:00 0:00:02.707327 16039 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T15:05:03.206957+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-11T14:00:00+00:00 EmrJobFlowSensor 2021-04-11T15:00:55.156389+00:00 2021-04-11T15:09:58.157313+00:00 0:09:03.000924 16038 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T15:00:52.748129+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-11T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T15:00:32.907338+00:00 2021-04-11T15:00:34.576999+00:00 0:00:01.669661 16037 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-11T15:00:30.726258+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-11T14:00:00+00:00 PythonOperator 2021-04-11T15:00:11.340192+00:00 2021-04-11T15:00:14.092447+00:00 0:00:02.752255 16036 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-11T15:00:08.706166+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-11T13:00:00+00:00 EmrJobFlowSensor 2021-04-11T14:12:04.529900+00:00 2021-04-11T14:22:07.406098+00:00 0:10:02.876198 16034 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T14:12:01.797573+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-11T13:00:00+00:00 EmrJobFlowSensor 2021-04-11T14:12:04.240467+00:00 2021-04-11T14:20:06.789662+00:00 0:08:02.549195 16033 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T14:12:01.797625+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-11T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T14:11:42.251321+00:00 2021-04-11T14:11:43.943528+00:00 0:00:01.692207 16032 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T14:11:39.844434+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-11T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T14:11:42.277486+00:00 2021-04-11T14:11:44.153818+00:00 0:00:01.876332 16031 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T14:11:39.844401+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-11T13:00:00+00:00 PythonOperator 2021-04-11T14:11:22.244074+00:00 2021-04-11T14:11:25.279948+00:00 0:00:03.035874 16030 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T14:11:19.669329+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-11T13:00:00+00:00 PythonOperator 2021-04-11T14:11:22.286188+00:00 2021-04-11T14:11:25.164795+00:00 0:00:02.878607 16029 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T14:11:19.669366+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-11T13:00:00+00:00 TriggerDagRunOperator 2021-04-11T14:11:10.457145+00:00 2021-04-11T14:11:10.974969+00:00 0:00:00.517824 16028 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T14:11:07.660834+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-11T13:00:00+00:00 TriggerDagRunOperator 2021-04-11T14:11:09.982631+00:00 2021-04-11T14:11:10.525937+00:00 0:00:00.543306 16027 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T14:11:07.660796+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-11T13:05:00+00:00 EmrJobFlowSensor 2021-04-11T14:06:04.101346+00:00 2021-04-11T14:15:06.771166+00:00 0:09:02.669820 16026 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T14:06:01.181232+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-11T13:05:00+00:00 EmrCreateJobFlowOperator 2021-04-11T14:05:41.435173+00:00 2021-04-11T14:05:43.063088+00:00 0:00:01.627915 16025 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T14:05:39.240885+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-11T13:05:00+00:00 PythonOperator 2021-04-11T14:05:21.360209+00:00 2021-04-11T14:05:24.066006+00:00 0:00:02.705797 16024 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T14:05:19.102293+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-11T13:00:00+00:00 EmrJobFlowSensor 2021-04-11T14:01:01.131075+00:00 2021-04-11T14:11:04.070736+00:00 0:10:02.939661 16023 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T14:00:58.844400+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-11T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T14:00:39.299998+00:00 2021-04-11T14:00:41.112682+00:00 0:00:01.812684 16022 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-11T14:00:36.769807+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-11T13:00:00+00:00 PythonOperator 2021-04-11T14:00:17.025625+00:00 2021-04-11T14:00:20.141864+00:00 0:00:03.116239 16021 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-11T14:00:14.684223+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-11T12:00:00+00:00 EmrJobFlowSensor 2021-04-11T13:11:20.576835+00:00 2021-04-11T13:21:23.608282+00:00 0:10:03.031447 16019 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T13:11:17.413456+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-11T12:00:00+00:00 EmrJobFlowSensor 2021-04-11T13:11:20.505306+00:00 2021-04-11T13:19:23.060998+00:00 0:08:02.555692 16018 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T13:11:17.413487+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-11T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T13:10:57.735557+00:00 2021-04-11T13:10:59.556330+00:00 0:00:01.820773 16017 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T13:10:55.357855+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-11T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T13:10:57.631531+00:00 2021-04-11T13:10:59.346921+00:00 0:00:01.715390 16016 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T13:10:55.357890+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-11T12:00:00+00:00 PythonOperator 2021-04-11T13:10:37.679837+00:00 2021-04-11T13:10:40.967115+00:00 0:00:03.287278 16015 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T13:10:35.338721+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-11T12:00:00+00:00 PythonOperator 2021-04-11T13:10:37.632961+00:00 2021-04-11T13:10:40.649241+00:00 0:00:03.016280 16014 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T13:10:35.338752+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-11T12:00:00+00:00 TriggerDagRunOperator 2021-04-11T13:10:12.481459+00:00 2021-04-11T13:10:13.058126+00:00 0:00:00.576667 16013 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T13:10:09.365283+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-11T12:00:00+00:00 TriggerDagRunOperator 2021-04-11T13:10:12.448023+00:00 2021-04-11T13:10:12.918131+00:00 0:00:00.470108 16012 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T13:10:09.365232+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-11T12:05:00+00:00 EmrJobFlowSensor 2021-04-11T13:05:59.031743+00:00 2021-04-11T13:15:01.640018+00:00 0:09:02.608275 16011 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T13:05:56.840080+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-11T12:05:00+00:00 EmrCreateJobFlowOperator 2021-04-11T13:05:37.070259+00:00 2021-04-11T13:05:38.711576+00:00 0:00:01.641317 16010 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T13:05:34.788271+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-11T12:05:00+00:00 PythonOperator 2021-04-11T13:05:15.181039+00:00 2021-04-11T13:05:17.895296+00:00 0:00:02.714257 16009 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T13:05:12.700029+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-11T12:00:00+00:00 EmrJobFlowSensor 2021-04-11T13:00:58.503638+00:00 2021-04-11T13:10:01.403434+00:00 0:09:02.899796 16008 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T13:00:56.304505+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-11T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T13:00:36.518003+00:00 2021-04-11T13:00:38.253690+00:00 0:00:01.735687 16007 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-11T13:00:34.283134+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-11T12:00:00+00:00 PythonOperator 2021-04-11T13:00:16.796178+00:00 2021-04-11T13:00:19.536885+00:00 0:00:02.740707 16006 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-11T13:00:14.232103+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-11T11:00:00+00:00 EmrJobFlowSensor 2021-04-11T12:11:23.996618+00:00 2021-04-11T12:20:26.752587+00:00 0:09:02.755969 16004 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T12:11:21.687218+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-11T11:00:00+00:00 EmrJobFlowSensor 2021-04-11T12:11:22.165534+00:00 2021-04-11T12:20:24.919793+00:00 0:09:02.754259 16003 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T12:11:19.753980+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-11T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T12:11:02.031339+00:00 2021-04-11T12:11:03.724598+00:00 0:00:01.693259 16002 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T12:10:59.740804+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-11T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T12:11:00.277367+00:00 2021-04-11T12:11:02.202026+00:00 0:00:01.924659 16001 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T12:10:57.647034+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-11T11:00:00+00:00 PythonOperator 2021-04-11T12:10:40.081937+00:00 2021-04-11T12:10:42.969392+00:00 0:00:02.887455 16000 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T12:10:37.612171+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-11T11:00:00+00:00 PythonOperator 2021-04-11T12:10:38.036946+00:00 2021-04-11T12:10:40.962265+00:00 0:00:02.925319 15999 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T12:10:35.672282+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-11T11:00:00+00:00 TriggerDagRunOperator 2021-04-11T12:10:34.429665+00:00 2021-04-11T12:10:34.879080+00:00 0:00:00.449415 15998 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T12:10:31.664045+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-11T11:00:00+00:00 TriggerDagRunOperator 2021-04-11T12:10:34.277231+00:00 2021-04-11T12:10:34.847052+00:00 0:00:00.569821 15997 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T12:10:31.664075+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-11T11:05:00+00:00 EmrJobFlowSensor 2021-04-11T12:05:49.425498+00:00 2021-04-11T12:14:52.053239+00:00 0:09:02.627741 15996 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T12:05:47.124790+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-11T11:05:00+00:00 EmrCreateJobFlowOperator 2021-04-11T12:05:27.796916+00:00 2021-04-11T12:05:29.471797+00:00 0:00:01.674881 15995 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T12:05:25.167847+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-11T11:05:00+00:00 PythonOperator 2021-04-11T12:05:07.396065+00:00 2021-04-11T12:05:10.110654+00:00 0:00:02.714589 15994 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T12:05:05.152944+00:00 2 default_pool