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 booking-processing-job_v002 create_emr_steps 2021-04-09T03:00:00+00:00 PythonOperator 2021-04-09T04:11:35.419585+00:00 2021-04-09T04:11:38.426899+00:00 0:00:03.007314 15159 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T04:11:33.262007+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-09T03:00:00+00:00 TriggerDagRunOperator 2021-04-09T04:11:19.698583+00:00 2021-04-09T04:11:20.125730+00:00 0:00:00.427147 15158 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T04:11:17.250341+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-09T03:00:00+00:00 TriggerDagRunOperator 2021-04-09T04:11:19.681283+00:00 2021-04-09T04:11:20.250171+00:00 0:00:00.568888 15157 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T04:11:17.250372+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-09T03:05:00+00:00 EmrJobFlowSensor 2021-04-09T04:05:46.910819+00:00 2021-04-09T04:14:49.593693+00:00 0:09:02.682874 15156 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T04:05:44.695981+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-09T03:05:00+00:00 EmrCreateJobFlowOperator 2021-04-09T04:05:26.863251+00:00 2021-04-09T04:05:28.620165+00:00 0:00:01.756914 15155 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T04:05:24.632511+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-09T03:05:00+00:00 PythonOperator 2021-04-09T04:05:04.991728+00:00 2021-04-09T04:05:07.654227+00:00 0:00:02.662499 15154 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T04:05:02.670965+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-09T03:00:00+00:00 EmrJobFlowSensor 2021-04-09T04:01:06.451758+00:00 2021-04-09T04:11:09.548992+00:00 0:10:03.097234 15153 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T04:01:04.173961+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-09T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T04:00:44.415167+00:00 2021-04-09T04:00:46.234023+00:00 0:00:01.818856 15152 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-09T04:00:42.091940+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-09T03:00:00+00:00 PythonOperator 2021-04-09T04:00:24.622604+00:00 2021-04-09T04:00:27.503346+00:00 0:00:02.880742 15151 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-09T04:00:22.026690+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-09T02:00:00+00:00 EmrJobFlowSensor 2021-04-09T03:11:28.967800+00:00 2021-04-09T03:23:31.976213+00:00 0:12:03.008413 15149 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T03:11:26.732535+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-09T02:00:00+00:00 EmrJobFlowSensor 2021-04-09T03:11:13.065081+00:00 2021-04-09T03:20:15.872970+00:00 0:09:02.807889 15148 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T03:11:10.726244+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-09T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T03:11:07.101151+00:00 2021-04-09T03:11:08.955325+00:00 0:00:01.854174 15147 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T03:11:04.729776+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-09T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T03:10:51.114966+00:00 2021-04-09T03:10:52.845133+00:00 0:00:01.730167 15146 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T03:10:48.772137+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-09T02:00:00+00:00 PythonOperator 2021-04-09T03:10:45.182684+00:00 2021-04-09T03:10:48.144845+00:00 0:00:02.962161 15145 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T03:10:42.754555+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-09T02:00:00+00:00 PythonOperator 2021-04-09T03:10:31.337335+00:00 2021-04-09T03:10:34.085319+00:00 0:00:02.747984 15144 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T03:10:28.848937+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-09T02:00:00+00:00 TriggerDagRunOperator 2021-04-09T03:10:25.055829+00:00 2021-04-09T03:10:25.530826+00:00 0:00:00.474997 15143 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T03:10:22.655076+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-09T02:00:00+00:00 TriggerDagRunOperator 2021-04-09T03:10:25.021872+00:00 2021-04-09T03:10:25.604240+00:00 0:00:00.582368 15142 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T03:10:22.655039+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-09T02:05:00+00:00 EmrJobFlowSensor 2021-04-09T03:05:58.270507+00:00 2021-04-09T03:16:00.969153+00:00 0:10:02.698646 15141 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T03:05:56.166905+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-09T02:05:00+00:00 EmrCreateJobFlowOperator 2021-04-09T03:05:38.396852+00:00 2021-04-09T03:05:40.151964+00:00 0:00:01.755112 15140 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T03:05:36.142513+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-09T02:05:00+00:00 PythonOperator 2021-04-09T03:05:16.296945+00:00 2021-04-09T03:05:18.970319+00:00 0:00:02.673374 15139 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T03:05:14.124028+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-09T02:00:00+00:00 EmrJobFlowSensor 2021-04-09T03:01:07.985293+00:00 2021-04-09T03:10:10.597446+00:00 0:09:02.612153 15138 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T03:01:05.725717+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-09T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T03:00:46.209521+00:00 2021-04-09T03:00:48.052264+00:00 0:00:01.842743 15137 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-09T03:00:43.750094+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-09T02:00:00+00:00 PythonOperator 2021-04-09T03:00:24.266614+00:00 2021-04-09T03:00:26.947937+00:00 0:00:02.681323 15136 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-09T03:00:21.743750+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-09T01:00:00+00:00 EmrJobFlowSensor 2021-04-09T02:10:09.518938+00:00 2021-04-09T02:20:12.230708+00:00 0:10:02.711770 15134 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T02:10:07.337874+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-09T01:00:00+00:00 EmrJobFlowSensor 2021-04-09T02:09:59.734515+00:00 2021-04-09T02:19:02.565715+00:00 0:09:02.831200 15133 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T02:09:57.326222+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-09T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T02:09:47.837818+00:00 2021-04-09T02:09:49.610441+00:00 0:00:01.772623 15132 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T02:09:45.364268+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-09T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T02:09:37.501933+00:00 2021-04-09T02:09:39.152086+00:00 0:00:01.650153 15131 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T02:09:35.313920+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-09T01:00:00+00:00 PythonOperator 2021-04-09T02:09:27.743824+00:00 2021-04-09T02:09:30.783671+00:00 0:00:03.039847 15130 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T02:09:25.371037+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-09T01:00:00+00:00 PythonOperator 2021-04-09T02:09:17.558789+00:00 2021-04-09T02:09:20.304949+00:00 0:00:02.746160 15129 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T02:09:15.292254+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-09T01:00:00+00:00 TriggerDagRunOperator 2021-04-09T02:09:03.890452+00:00 2021-04-09T02:09:04.414033+00:00 0:00:00.523581 15128 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T02:09:01.274230+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-09T01:00:00+00:00 TriggerDagRunOperator 2021-04-09T02:09:03.500958+00:00 2021-04-09T02:09:03.911948+00:00 0:00:00.410990 15127 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T02:09:01.274265+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-09T01:05:00+00:00 EmrJobFlowSensor 2021-04-09T02:06:01.233532+00:00 2021-04-09T02:15:03.891589+00:00 0:09:02.658057 15126 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T02:05:58.986929+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-09T01:05:00+00:00 EmrCreateJobFlowOperator 2021-04-09T02:05:39.041692+00:00 2021-04-09T02:05:40.717574+00:00 0:00:01.675882 15125 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T02:05:36.888672+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-09T01:05:00+00:00 PythonOperator 2021-04-09T02:05:19.139051+00:00 2021-04-09T02:05:21.946627+00:00 0:00:02.807576 15124 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T02:05:16.855316+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-09T01:00:00+00:00 EmrJobFlowSensor 2021-04-09T02:00:55.022812+00:00 2021-04-09T02:08:57.621203+00:00 0:08:02.598391 15123 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T02:00:52.458160+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-09T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T02:00:34.858194+00:00 2021-04-09T02:00:36.552874+00:00 0:00:01.694680 15122 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-09T02:00:32.442721+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-09T01:00:00+00:00 PythonOperator 2021-04-09T02:00:13.033930+00:00 2021-04-09T02:00:15.872045+00:00 0:00:02.838115 15121 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-09T02:00:10.263626+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-09T00:00:00+00:00 EmrJobFlowSensor 2021-04-09T01:12:09.887669+00:00 2021-04-09T01:22:12.828811+00:00 0:10:02.941142 15119 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T01:12:07.281531+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-09T00:00:00+00:00 EmrJobFlowSensor 2021-04-09T01:12:01.624461+00:00 2021-04-09T01:21:04.277466+00:00 0:09:02.653005 15118 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T01:11:59.246460+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-09T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T01:11:47.645882+00:00 2021-04-09T01:11:49.522081+00:00 0:00:01.876199 15117 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T01:11:45.186817+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-09T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T01:11:39.412067+00:00 2021-04-09T01:11:41.121881+00:00 0:00:01.709814 15116 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T01:11:37.128037+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-09T00:00:00+00:00 PythonOperator 2021-04-09T01:11:27.406992+00:00 2021-04-09T01:11:30.284201+00:00 0:00:02.877209 15115 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T01:11:25.081889+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-09T00:00:00+00:00 PythonOperator 2021-04-09T01:11:19.275767+00:00 2021-04-09T01:11:22.159585+00:00 0:00:02.883818 15114 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T01:11:17.049702+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-09T00:00:00+00:00 TriggerDagRunOperator 2021-04-09T01:11:13.589050+00:00 2021-04-09T01:11:14.049202+00:00 0:00:00.460152 15113 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T01:11:11.050618+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-09T00:00:00+00:00 TriggerDagRunOperator 2021-04-09T01:11:13.514524+00:00 2021-04-09T01:11:14.162968+00:00 0:00:00.648444 15112 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T01:11:11.050591+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-09T00:05:00+00:00 EmrJobFlowSensor 2021-04-09T01:05:56.712019+00:00 2021-04-09T01:14:59.415316+00:00 0:09:02.703297 15111 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T01:05:54.506745+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-09T00:05:00+00:00 EmrCreateJobFlowOperator 2021-04-09T01:05:34.807505+00:00 2021-04-09T01:05:36.450691+00:00 0:00:01.643186 15110 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T01:05:32.547123+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-09T00:05:00+00:00 PythonOperator 2021-04-09T01:05:14.581991+00:00 2021-04-09T01:05:17.273954+00:00 0:00:02.691963 15109 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T01:05:12.334772+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-09T00:00:00+00:00 EmrJobFlowSensor 2021-04-09T01:00:58.166523+00:00 2021-04-09T01:11:01.032259+00:00 0:10:02.865736 15108 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T01:00:55.910840+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-09T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T01:00:36.144249+00:00 2021-04-09T01:00:37.928153+00:00 0:00:01.783904 15107 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-09T01:00:33.888765+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-09T00:00:00+00:00 PythonOperator 2021-04-09T01:00:16.820113+00:00 2021-04-09T01:00:19.522336+00:00 0:00:02.702223 15106 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-09T01:00:13.762819+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-08T23:00:00+00:00 EmrJobFlowSensor 2021-04-09T00:10:10.008098+00:00 2021-04-09T00:20:12.794282+00:00 0:10:02.786184 15104 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T00:10:07.736436+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-08T23:00:00+00:00 EmrJobFlowSensor 2021-04-09T00:09:56.134760+00:00 2021-04-09T00:17:58.604496+00:00 0:08:02.469736 15103 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T00:09:53.855075+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-08T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T00:09:48.132329+00:00 2021-04-09T00:09:49.853986+00:00 0:00:01.721657 15102 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T00:09:45.779234+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-08T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T00:09:33.953129+00:00 2021-04-09T00:09:35.631614+00:00 0:00:01.678485 15101 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T00:09:31.704883+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-08T23:00:00+00:00 PythonOperator 2021-04-09T00:09:28.121628+00:00 2021-04-09T00:09:31.036077+00:00 0:00:02.914449 15100 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T00:09:25.713161+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-08T23:00:00+00:00 PythonOperator 2021-04-09T00:09:11.923246+00:00 2021-04-09T00:09:14.687707+00:00 0:00:02.764461 15099 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T00:09:09.687631+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-08T23:00:00+00:00 TriggerDagRunOperator 2021-04-09T00:09:06.106899+00:00 2021-04-09T00:09:06.545387+00:00 0:00:00.438488 15098 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T00:09:03.678749+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-08T23:00:00+00:00 TriggerDagRunOperator 2021-04-09T00:09:05.976528+00:00 2021-04-09T00:09:06.614499+00:00 0:00:00.637971 15097 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T00:09:03.678782+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-08T23:05:00+00:00 EmrJobFlowSensor 2021-04-09T00:05:49.897909+00:00 2021-04-09T00:14:52.472016+00:00 0:09:02.574107 15096 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T00:05:47.366368+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-08T23:05:00+00:00 EmrCreateJobFlowOperator 2021-04-09T00:05:29.857806+00:00 2021-04-09T00:05:31.521946+00:00 0:00:01.664140 15095 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T00:05:27.369361+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-08T23:05:00+00:00 PythonOperator 2021-04-09T00:05:05.665826+00:00 2021-04-09T00:05:08.344013+00:00 0:00:02.678187 15094 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T00:05:03.284559+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-08T23:00:00+00:00 EmrJobFlowSensor 2021-04-09T00:00:47.081544+00:00 2021-04-09T00:08:49.701051+00:00 0:08:02.619507 15093 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T00:00:44.799181+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-08T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T00:00:24.879056+00:00 2021-04-09T00:00:26.561157+00:00 0:00:01.682101 15092 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-09T00:00:22.708498+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-08T23:00:00+00:00 PythonOperator 2021-04-09T00:00:05.328628+00:00 2021-04-09T00:00:08.207131+00:00 0:00:02.878503 15091 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-09T00:00:02.698983+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-08T22:00:00+00:00 EmrJobFlowSensor 2021-04-08T23:11:11.604549+00:00 2021-04-08T23:21:14.460458+00:00 0:10:02.855909 15089 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T23:11:09.043623+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-08T22:00:00+00:00 EmrJobFlowSensor 2021-04-08T23:11:11.538856+00:00 2021-04-08T23:21:14.527469+00:00 0:10:02.988613 15088 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T23:11:09.043658+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-08T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T23:10:51.586114+00:00 2021-04-08T23:10:53.278482+00:00 0:00:01.692368 15087 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T23:10:48.924528+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-08T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T23:10:49.350401+00:00 2021-04-08T23:10:51.333028+00:00 0:00:01.982627 15086 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T23:10:46.975089+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-08T22:00:00+00:00 PythonOperator 2021-04-08T23:10:29.482769+00:00 2021-04-08T23:10:32.693512+00:00 0:00:03.210743 15085 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T23:10:26.913510+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-08T22:00:00+00:00 PythonOperator 2021-04-08T23:10:29.199720+00:00 2021-04-08T23:10:32.042566+00:00 0:00:02.842846 15084 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T23:10:26.913554+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-08T22:00:00+00:00 TriggerDagRunOperator 2021-04-08T23:10:21.225197+00:00 2021-04-08T23:10:21.771423+00:00 0:00:00.546226 15083 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T23:10:18.901110+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-08T22:00:00+00:00 TriggerDagRunOperator 2021-04-08T23:10:21.101956+00:00 2021-04-08T23:10:21.576649+00:00 0:00:00.474693 15082 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T23:10:18.901186+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-08T22:05:00+00:00 EmrJobFlowSensor 2021-04-08T23:05:56.684489+00:00 2021-04-08T23:13:59.063259+00:00 0:08:02.378770 15081 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T23:05:54.468606+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-08T22:05:00+00:00 EmrCreateJobFlowOperator 2021-04-08T23:05:34.641366+00:00 2021-04-08T23:05:36.411274+00:00 0:00:01.769908 15080 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T23:05:32.392381+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-08T22:05:00+00:00 PythonOperator 2021-04-08T23:05:12.567457+00:00 2021-04-08T23:05:15.332098+00:00 0:00:02.764641 15079 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T23:05:10.361903+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-08T22:00:00+00:00 EmrJobFlowSensor 2021-04-08T23:01:04.433438+00:00 2021-04-08T23:10:07.213894+00:00 0:09:02.780456 15078 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T23:01:02.050524+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-08T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T23:00:42.241972+00:00 2021-04-08T23:00:44.206201+00:00 0:00:01.964229 15077 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-08T23:00:39.962505+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-08T22:00:00+00:00 PythonOperator 2021-04-08T23:00:20.611094+00:00 2021-04-08T23:00:23.341029+00:00 0:00:02.729935 15076 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-08T23:00:17.942323+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-08T21:00:00+00:00 EmrJobFlowSensor 2021-04-08T22:11:34.569763+00:00 2021-04-08T22:21:37.359237+00:00 0:10:02.789474 15074 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T22:11:32.277793+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-08T21:00:00+00:00 EmrJobFlowSensor 2021-04-08T22:11:22.415613+00:00 2021-04-08T22:21:25.230729+00:00 0:10:02.815116 15073 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T22:11:20.208502+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-08T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T22:11:12.951108+00:00 2021-04-08T22:11:14.810807+00:00 0:00:01.859699 15072 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T22:11:10.199994+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-08T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T22:11:00.696258+00:00 2021-04-08T22:11:02.588801+00:00 0:00:01.892543 15071 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T22:10:58.248225+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-08T21:00:00+00:00 PythonOperator 2021-04-08T22:10:50.911213+00:00 2021-04-08T22:10:53.903538+00:00 0:00:02.992325 15070 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T22:10:48.253934+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-08T21:00:00+00:00 PythonOperator 2021-04-08T22:10:38.527706+00:00 2021-04-08T22:10:41.355277+00:00 0:00:02.827571 15069 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T22:10:36.166155+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-08T21:00:00+00:00 TriggerDagRunOperator 2021-04-08T22:10:30.860219+00:00 2021-04-08T22:10:31.383983+00:00 0:00:00.523764 15068 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T22:10:28.169756+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-08T21:00:00+00:00 TriggerDagRunOperator 2021-04-08T22:10:30.762486+00:00 2021-04-08T22:10:31.178177+00:00 0:00:00.415691 15067 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T22:10:28.169791+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-08T21:05:00+00:00 EmrJobFlowSensor 2021-04-08T22:05:49.876358+00:00 2021-04-08T22:14:52.490790+00:00 0:09:02.614432 15066 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T22:05:47.696560+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-08T21:05:00+00:00 EmrCreateJobFlowOperator 2021-04-08T22:05:30.063133+00:00 2021-04-08T22:05:31.801680+00:00 0:00:01.738547 15065 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T22:05:27.666328+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-08T21:05:00+00:00 PythonOperator 2021-04-08T22:05:07.769733+00:00 2021-04-08T22:05:10.466130+00:00 0:00:02.696397 15064 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T22:05:05.607052+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-08T21:00:00+00:00 EmrJobFlowSensor 2021-04-08T22:01:05.439674+00:00 2021-04-08T22:10:08.238098+00:00 0:09:02.798424 15063 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T22:01:03.081785+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-08T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T22:00:43.329319+00:00 2021-04-08T22:00:45.114754+00:00 0:00:01.785435 15062 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-08T22:00:41.016586+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-08T21:00:00+00:00 PythonOperator 2021-04-08T22:00:23.817906+00:00 2021-04-08T22:00:26.638237+00:00 0:00:02.820331 15061 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-08T22:00:21.003863+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-08T20:00:00+00:00 EmrJobFlowSensor 2021-04-08T21:12:11.809100+00:00 2021-04-08T21:21:14.575017+00:00 0:09:02.765917 15059 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T21:12:09.618641+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-08T20:00:00+00:00 EmrJobFlowSensor 2021-04-08T21:11:53.758172+00:00 2021-04-08T21:21:56.547697+00:00 0:10:02.789525 15058 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T21:11:51.602254+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-08T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T21:11:50.130057+00:00 2021-04-08T21:11:51.971894+00:00 0:00:01.841837 15057 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T21:11:47.599392+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-08T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T21:11:32.209190+00:00 2021-04-08T21:11:34.056984+00:00 0:00:01.847794 15056 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T21:11:29.644312+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-08T20:00:00+00:00 PythonOperator 2021-04-08T21:11:27.915041+00:00 2021-04-08T21:11:30.756546+00:00 0:00:02.841505 15055 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T21:11:25.558857+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-08T20:00:00+00:00 PythonOperator 2021-04-08T21:11:09.820616+00:00 2021-04-08T21:11:12.764748+00:00 0:00:02.944132 15054 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T21:11:07.523740+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-08T20:00:00+00:00 TriggerDagRunOperator 2021-04-08T21:11:03.869524+00:00 2021-04-08T21:11:04.413205+00:00 0:00:00.543681 15053 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T21:11:01.510754+00:00 2 default_pool