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-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
success campaign-flow-job_v002 check_cluster_status 2021-04-11T11:00:00+00:00 EmrJobFlowSensor 2021-04-11T12:01:12.799798+00:00 2021-04-11T12:10:15.459931+00:00 0:09:02.660133 15993 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T12:01:10.616993+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-11T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T12:00:42.867765+00:00 2021-04-11T12:00:44.668526+00:00 0:00:01.800761 15992 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-11T12:00:40.591062+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-11T11:00:00+00:00 PythonOperator 2021-04-11T12:00:12.915972+00:00 2021-04-11T12:00:15.629005+00:00 0:00:02.713033 15991 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-11T12:00:10.523795+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-11T10:00:00+00:00 EmrJobFlowSensor 2021-04-11T11:18:42.601507+00:00 2021-04-11T11:28:45.283992+00:00 0:10:02.682485 15989 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T11:18:40.390626+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-11T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T11:18:20.760434+00:00 2021-04-11T11:18:23.173314+00:00 0:00:02.412880 15988 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T11:18:18.354067+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-11T10:00:00+00:00 EmrJobFlowSensor 2021-04-11T11:18:14.407728+00:00 2021-04-11T11:28:17.038575+00:00 0:10:02.630847 15987 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T11:18:12.234863+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-11T10:00:00+00:00 PythonOperator 2021-04-11T11:18:00.838214+00:00 2021-04-11T11:18:03.915260+00:00 0:00:03.077046 15986 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T11:17:58.269632+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-11T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T11:17:54.453046+00:00 2021-04-11T11:17:56.154238+00:00 0:00:01.701192 15985 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T11:17:52.045434+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-11T10:00:00+00:00 PythonOperator 2021-04-11T11:17:32.747246+00:00 2021-04-11T11:17:35.788967+00:00 0:00:03.041721 15984 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T11:17:30.036139+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-11T10:00:00+00:00 TriggerDagRunOperator 2021-04-11T11:17:22.278684+00:00 2021-04-11T11:17:22.877366+00:00 0:00:00.598682 15983 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T11:17:20.025984+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-11T10:00:00+00:00 TriggerDagRunOperator 2021-04-11T11:17:22.195435+00:00 2021-04-11T11:17:22.683169+00:00 0:00:00.487734 15982 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T11:17:20.025953+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-11T10:05:00+00:00 EmrJobFlowSensor 2021-04-11T11:06:17.021306+00:00 2021-04-11T11:14:19.507438+00:00 0:08:02.486132 15981 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T11:06:14.774219+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-11T10:05:00+00:00 EmrCreateJobFlowOperator 2021-04-11T11:05:45.170534+00:00 2021-04-11T11:05:47.546841+00:00 0:00:02.376307 15980 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T11:05:42.751395+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-11T10:05:00+00:00 PythonOperator 2021-04-11T11:05:22.930696+00:00 2021-04-11T11:05:25.599915+00:00 0:00:02.669219 15979 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T11:05:20.688184+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-11T10:00:00+00:00 EmrJobFlowSensor 2021-04-11T11:01:04.554297+00:00 2021-04-11T11:17:08.573043+00:00 0:16:04.018746 15978 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T11:01:02.097528+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-11T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T11:00:40.573090+00:00 2021-04-11T11:00:42.384576+00:00 0:00:01.811486 15977 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-11T11:00:38.152813+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-11T10:00:00+00:00 PythonOperator 2021-04-11T11:00:18.276790+00:00 2021-04-11T11:00:21.022651+00:00 0:00:02.745861 15976 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-11T11:00:15.991974+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-11T09:00:00+00:00 EmrJobFlowSensor 2021-04-11T10:11:26.362891+00:00 2021-04-11T10:20:29.102445+00:00 0:09:02.739554 15974 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T10:11:24.026934+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-11T09:00:00+00:00 EmrJobFlowSensor 2021-04-11T10:11:26.232799+00:00 2021-04-11T10:20:28.851859+00:00 0:09:02.619060 15973 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T10:11:24.026968+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-11T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T10:11:04.458434+00:00 2021-04-11T10:11:06.280359+00:00 0:00:01.821925 15972 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T10:11:01.959845+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-11T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T10:11:04.236188+00:00 2021-04-11T10:11:05.963943+00:00 0:00:01.727755 15971 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T10:11:01.959875+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-11T09:00:00+00:00 PythonOperator 2021-04-11T10:10:44.821915+00:00 2021-04-11T10:10:47.840910+00:00 0:00:03.018995 15970 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T10:10:41.956520+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-11T09:00:00+00:00 PythonOperator 2021-04-11T10:10:44.813938+00:00 2021-04-11T10:10:47.739217+00:00 0:00:02.925279 15969 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T10:10:41.956487+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-11T09:00:00+00:00 TriggerDagRunOperator 2021-04-11T10:10:32.382485+00:00 2021-04-11T10:10:32.954589+00:00 0:00:00.572104 15968 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T10:10:29.893148+00:00 2 default_pool