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_cluster_and_add_emr_steps 2021-04-06T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T10:12:21.294203+00:00 2021-04-06T10:12:23.114505+00:00 0:00:01.820302 14173 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T10:12:19.000105+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-06T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T10:12:15.405363+00:00 2021-04-06T10:12:17.178110+00:00 0:00:01.772747 14172 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T10:12:13.062617+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-06T09:00:00+00:00 PythonOperator 2021-04-06T10:11:59.396298+00:00 2021-04-06T10:12:02.225716+00:00 0:00:02.829418 14171 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T10:11:56.964898+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-06T09:00:00+00:00 PythonOperator 2021-04-06T10:11:55.137764+00:00 2021-04-06T10:11:58.081131+00:00 0:00:02.943367 14170 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T10:11:52.908637+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-06T09:00:00+00:00 TriggerDagRunOperator 2021-04-06T10:11:35.246121+00:00 2021-04-06T10:11:35.767321+00:00 0:00:00.521200 14169 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T10:11:32.889712+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-06T09:00:00+00:00 TriggerDagRunOperator 2021-04-06T10:11:35.127424+00:00 2021-04-06T10:11:35.569186+00:00 0:00:00.441762 14168 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T10:11:32.889745+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-06T09:05:00+00:00 EmrJobFlowSensor 2021-04-06T10:05:56.501317+00:00 2021-04-06T10:14:59.099472+00:00 0:09:02.598155 14167 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T10:05:54.302435+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-06T09:05:00+00:00 EmrCreateJobFlowOperator 2021-04-06T10:05:34.542329+00:00 2021-04-06T10:05:36.272255+00:00 0:00:01.729926 14166 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T10:05:32.288684+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-06T09:05:00+00:00 PythonOperator 2021-04-06T10:05:12.388740+00:00 2021-04-06T10:05:15.107529+00:00 0:00:02.718789 14165 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T10:05:10.194690+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-06T09:00:00+00:00 EmrJobFlowSensor 2021-04-06T10:01:06.339987+00:00 2021-04-06T10:11:09.270902+00:00 0:10:02.930915 14164 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T10:01:03.785518+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-06T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T10:00:44.278503+00:00 2021-04-06T10:00:46.063086+00:00 0:00:01.784583 14163 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-06T10:00:41.718736+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-06T09:00:00+00:00 PythonOperator 2021-04-06T10:00:22.128996+00:00 2021-04-06T10:00:24.975565+00:00 0:00:02.846569 14162 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-06T10:00:19.702303+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-06T08:00:00+00:00 EmrJobFlowSensor 2021-04-06T09:12:33.279606+00:00 2021-04-06T09:21:35.906214+00:00 0:09:02.626608 14160 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T09:12:30.760272+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-06T08:00:00+00:00 EmrJobFlowSensor 2021-04-06T09:12:29.034221+00:00 2021-04-06T09:22:31.663914+00:00 0:10:02.629693 14159 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T09:12:26.705759+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-06T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T09:12:11.058762+00:00 2021-04-06T09:12:12.962723+00:00 0:00:01.903961 14158 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T09:12:08.751086+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-06T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T09:12:09.035932+00:00 2021-04-06T09:12:10.748342+00:00 0:00:01.712410 14157 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T09:12:06.759830+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-06T08:00:00+00:00 PythonOperator 2021-04-06T09:11:50.842101+00:00 2021-04-06T09:11:53.753880+00:00 0:00:02.911779 14156 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T09:11:48.630662+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-06T08:00:00+00:00 PythonOperator 2021-04-06T09:11:46.839829+00:00 2021-04-06T09:11:49.644227+00:00 0:00:02.804398 14155 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T09:11:44.627272+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-06T08:00:00+00:00 TriggerDagRunOperator 2021-04-06T09:11:29.133206+00:00 2021-04-06T09:11:29.661735+00:00 0:00:00.528529 14154 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T09:11:26.611608+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-06T08:00:00+00:00 TriggerDagRunOperator 2021-04-06T09:11:28.951356+00:00 2021-04-06T09:11:29.353544+00:00 0:00:00.402188 14153 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T09:11:26.611640+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-06T08:05:00+00:00 EmrJobFlowSensor 2021-04-06T09:05:50.195655+00:00 2021-04-06T09:14:52.840207+00:00 0:09:02.644552 14152 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T09:05:48.005793+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-06T08:05:00+00:00 EmrCreateJobFlowOperator 2021-04-06T09:05:28.427112+00:00 2021-04-06T09:05:30.102472+00:00 0:00:01.675360 14151 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T09:05:26.059741+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-06T08:05:00+00:00 PythonOperator 2021-04-06T09:05:06.286795+00:00 2021-04-06T09:05:08.986640+00:00 0:00:02.699845 14150 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T09:05:03.971949+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-06T08:00:00+00:00 EmrJobFlowSensor 2021-04-06T09:01:02.152687+00:00 2021-04-06T09:11:05.047568+00:00 0:10:02.894881 14149 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T09:00:59.669830+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-06T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T09:00:39.718753+00:00 2021-04-06T09:00:41.383931+00:00 0:00:01.665178 14148 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-06T09:00:37.525096+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-06T08:00:00+00:00 PythonOperator 2021-04-06T09:00:19.919745+00:00 2021-04-06T09:00:22.653021+00:00 0:00:02.733276 14147 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-06T09:00:17.519468+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-06T07:00:00+00:00 EmrJobFlowSensor 2021-04-06T08:15:12.936303+00:00 2021-04-06T08:24:15.650291+00:00 0:09:02.713988 14146 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T08:15:10.663648+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-06T07:00:00+00:00 EmrJobFlowSensor 2021-04-06T08:14:56.943139+00:00 2021-04-06T08:23:59.687549+00:00 0:09:02.744410 14145 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T08:14:54.651600+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-06T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T08:14:50.901356+00:00 2021-04-06T08:14:52.641790+00:00 0:00:01.740434 14144 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T08:14:48.642183+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-06T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T08:14:34.914963+00:00 2021-04-06T08:14:36.610569+00:00 0:00:01.695606 14143 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T08:14:32.628484+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-06T07:00:00+00:00 PythonOperator 2021-04-06T08:14:28.812784+00:00 2021-04-06T08:14:31.706374+00:00 0:00:02.893590 14142 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T08:14:26.623617+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-06T07:00:00+00:00 PythonOperator 2021-04-06T08:14:15.015858+00:00 2021-04-06T08:14:17.726182+00:00 0:00:02.710324 14141 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T08:14:12.618463+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-06T07:00:00+00:00 TriggerDagRunOperator 2021-04-06T08:14:07.426252+00:00 2021-04-06T08:14:07.865979+00:00 0:00:00.439727 14140 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T08:14:04.478028+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-06T07:00:00+00:00 TriggerDagRunOperator 2021-04-06T08:14:07.415076+00:00 2021-04-06T08:14:08.023331+00:00 0:00:00.608255 14139 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T08:14:04.478059+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-06T07:05:00+00:00 EmrJobFlowSensor 2021-04-06T08:05:59.521651+00:00 2021-04-06T08:15:02.169115+00:00 0:09:02.647464 14137 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T08:05:57.116073+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-06T07:05:00+00:00 EmrCreateJobFlowOperator 2021-04-06T08:05:37.516978+00:00 2021-04-06T08:05:39.266668+00:00 0:00:01.749690 14136 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T08:05:35.146539+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-06T07:05:00+00:00 PythonOperator 2021-04-06T08:05:15.356884+00:00 2021-04-06T08:05:18.096747+00:00 0:00:02.739863 14135 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T08:05:12.995128+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-06T07:00:00+00:00 EmrJobFlowSensor 2021-04-06T08:01:01.221326+00:00 2021-04-06T08:10:04.075077+00:00 0:09:02.853751 14134 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T08:00:58.562558+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-06T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T08:00:38.827690+00:00 2021-04-06T08:00:40.518117+00:00 0:00:01.690427 14133 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-06T08:00:36.478358+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-06T07:00:00+00:00 PythonOperator 2021-04-06T08:00:18.623042+00:00 2021-04-06T08:00:21.397385+00:00 0:00:02.774343 14132 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-06T08:00:16.384557+00:00 2 default_pool
success Custom-EMR-cluster_v001 create_cluster_n_add_steps 2021-04-06T07:49:41.390893+00:00 PythonOperator 2021-04-06T07:56:16.201997+00:00 2021-04-06T07:56:18.988106+00:00 0:00:02.786109 14131 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T07:56:13.997041+00:00 4 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-06T06:00:00+00:00 EmrJobFlowSensor 2021-04-06T07:12:21.818497+00:00 2021-04-06T07:20:24.371258+00:00 0:08:02.552761 14128 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T07:12:19.614900+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-06T06:00:00+00:00 EmrJobFlowSensor 2021-04-06T07:12:16.088089+00:00 2021-04-06T07:22:18.843994+00:00 0:10:02.755905 14127 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T07:12:13.671568+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-06T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T07:12:00.305870+00:00 2021-04-06T07:12:02.178286+00:00 0:00:01.872416 14126 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T07:11:57.653461+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-06T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T07:11:54.185960+00:00 2021-04-06T07:11:56.092168+00:00 0:00:01.906208 14125 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T07:11:51.566480+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-06T06:00:00+00:00 PythonOperator 2021-04-06T07:11:38.207424+00:00 2021-04-06T07:11:41.195041+00:00 0:00:02.987617 14124 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T07:11:35.543561+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-06T06:00:00+00:00 PythonOperator 2021-04-06T07:11:33.817167+00:00 2021-04-06T07:11:37.007650+00:00 0:00:03.190483 14123 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T07:11:31.467974+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-06T06:00:00+00:00 TriggerDagRunOperator 2021-04-06T07:11:14.028229+00:00 2021-04-06T07:11:14.590339+00:00 0:00:00.562110 14122 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T07:11:11.389479+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-06T06:00:00+00:00 TriggerDagRunOperator 2021-04-06T07:11:13.914082+00:00 2021-04-06T07:11:14.360403+00:00 0:00:00.446321 14121 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T07:11:11.389450+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-06T06:05:00+00:00 EmrJobFlowSensor 2021-04-06T07:06:07.935874+00:00 2021-04-06T07:14:10.291310+00:00 0:08:02.355436 14119 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T07:06:05.765129+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-06T06:05:00+00:00 EmrCreateJobFlowOperator 2021-04-06T07:05:41.908481+00:00 2021-04-06T07:05:43.592923+00:00 0:00:01.684442 14118 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T07:05:39.744010+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-06T06:05:00+00:00 PythonOperator 2021-04-06T07:05:20.114315+00:00 2021-04-06T07:05:22.816543+00:00 0:00:02.702228 14117 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T07:05:17.688234+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-06T06:00:00+00:00 EmrJobFlowSensor 2021-04-06T07:01:05.694292+00:00 2021-04-06T07:11:08.377350+00:00 0:10:02.683058 14116 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T07:01:03.354177+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-06T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T07:00:43.651895+00:00 2021-04-06T07:00:45.349538+00:00 0:00:01.697643 14115 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-06T07:00:41.258329+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-06T06:00:00+00:00 PythonOperator 2021-04-06T07:00:23.427189+00:00 2021-04-06T07:00:26.416101+00:00 0:00:02.988912 14114 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-06T07:00:21.241621+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-06T05:00:00+00:00 EmrJobFlowSensor 2021-04-06T06:11:24.380052+00:00 2021-04-06T06:20:27.157875+00:00 0:09:02.777823 14113 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T06:11:22.027257+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-06T05:00:00+00:00 EmrJobFlowSensor 2021-04-06T06:11:22.269293+00:00 2021-04-06T06:21:25.077775+00:00 0:10:02.808482 14112 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T06:11:20.032739+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-06T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T06:11:04.265147+00:00 2021-04-06T06:11:06.101480+00:00 0:00:01.836333 14111 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T06:11:02.011229+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-06T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T06:11:00.473425+00:00 2021-04-06T06:11:02.279240+00:00 0:00:01.805815 14110 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T06:10:58.076015+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-06T05:00:00+00:00 PythonOperator 2021-04-06T06:10:36.372364+00:00 2021-04-06T06:10:39.178692+00:00 0:00:02.806328 14109 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T06:10:34.054191+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-06T05:00:00+00:00 PythonOperator 2021-04-06T06:10:34.357716+00:00 2021-04-06T06:10:37.325940+00:00 0:00:02.968224 14108 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T06:10:32.057972+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-06T05:00:00+00:00 TriggerDagRunOperator 2021-04-06T06:10:14.480968+00:00 2021-04-06T06:10:14.913886+00:00 0:00:00.432918 14107 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T06:10:11.903065+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-06T05:00:00+00:00 TriggerDagRunOperator 2021-04-06T06:10:14.484765+00:00 2021-04-06T06:10:15.038243+00:00 0:00:00.553478 14106 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T06:10:11.903039+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-06T05:05:00+00:00 EmrJobFlowSensor 2021-04-06T06:07:36.002633+00:00 2021-04-06T06:15:38.550385+00:00 0:08:02.547752 14105 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T06:07:33.721825+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-06T05:05:00+00:00 EmrCreateJobFlowOperator 2021-04-06T06:07:09.956061+00:00 2021-04-06T06:07:11.706721+00:00 0:00:01.750660 14104 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T06:07:07.690007+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-06T05:05:00+00:00 PythonOperator 2021-04-06T06:06:47.974540+00:00 2021-04-06T06:06:50.739268+00:00 0:00:02.764728 14103 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T06:06:45.666960+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-06T05:00:00+00:00 EmrJobFlowSensor 2021-04-06T06:01:03.910774+00:00 2021-04-06T06:10:06.717021+00:00 0:09:02.806247 14101 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T06:01:01.685900+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-06T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T06:00:41.808968+00:00 2021-04-06T06:00:43.530205+00:00 0:00:01.721237 14100 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-06T06:00:39.644665+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-06T05:00:00+00:00 PythonOperator 2021-04-06T06:00:21.826256+00:00 2021-04-06T06:00:24.542992+00:00 0:00:02.716736 14099 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-06T06:00:19.622545+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-06T04:00:00+00:00 EmrJobFlowSensor 2021-04-06T05:12:10.785790+00:00 2021-04-06T05:21:13.467479+00:00 0:09:02.681689 14098 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T05:12:08.583456+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-06T04:00:00+00:00 EmrJobFlowSensor 2021-04-06T05:12:04.879853+00:00 2021-04-06T05:21:07.581634+00:00 0:09:02.701781 14097 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T05:12:02.547655+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-06T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T05:11:48.908851+00:00 2021-04-06T05:11:50.589161+00:00 0:00:01.680310 14096 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T05:11:46.530593+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-06T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T05:11:44.736629+00:00 2021-04-06T05:11:46.512025+00:00 0:00:01.775396 14095 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T05:11:42.530609+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-06T04:00:00+00:00 PythonOperator 2021-04-06T05:11:26.710775+00:00 2021-04-06T05:11:29.638334+00:00 0:00:02.927559 14094 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T05:11:24.512388+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-06T04:00:00+00:00 PythonOperator 2021-04-06T05:11:23.106560+00:00 2021-04-06T05:11:26.193712+00:00 0:00:03.087152 14093 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T05:11:20.564030+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-06T04:00:00+00:00 TriggerDagRunOperator 2021-04-06T05:11:05.356995+00:00 2021-04-06T05:11:05.872251+00:00 0:00:00.515256 14092 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T05:11:02.567336+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-06T04:00:00+00:00 TriggerDagRunOperator 2021-04-06T05:11:04.987948+00:00 2021-04-06T05:11:05.396040+00:00 0:00:00.408092 14091 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T05:11:02.567289+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-06T04:05:00+00:00 EmrJobFlowSensor 2021-04-06T05:05:54.404462+00:00 2021-04-06T05:14:57.054530+00:00 0:09:02.650068 14090 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T05:05:52.059347+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-06T04:05:00+00:00 EmrCreateJobFlowOperator 2021-04-06T05:05:32.301972+00:00 2021-04-06T05:05:34.068342+00:00 0:00:01.766370 14089 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T05:05:30.050824+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-06T04:05:00+00:00 PythonOperator 2021-04-06T05:05:12.433267+00:00 2021-04-06T05:05:15.159747+00:00 0:00:02.726480 14088 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T05:05:10.046855+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-06T04:00:00+00:00 EmrJobFlowSensor 2021-04-06T05:00:54.710096+00:00 2021-04-06T05:10:57.682394+00:00 0:10:02.972298 14086 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T05:00:52.140509+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-06T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T05:00:32.614004+00:00 2021-04-06T05:00:34.298636+00:00 0:00:01.684632 14085 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-06T05:00:30.153071+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-06T04:00:00+00:00 PythonOperator 2021-04-06T05:00:10.524677+00:00 2021-04-06T05:00:13.269362+00:00 0:00:02.744685 14084 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-06T05:00:08.072536+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-06T03:00:00+00:00 EmrJobFlowSensor 2021-04-06T04:14:30.230123+00:00 2021-04-06T04:23:32.853632+00:00 0:09:02.623509 14083 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T04:14:27.609859+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-06T03:00:00+00:00 EmrJobFlowSensor 2021-04-06T04:14:27.828453+00:00 2021-04-06T04:24:30.884089+00:00 0:10:03.055636 14082 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T04:14:25.599338+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-06T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T04:14:07.950165+00:00 2021-04-06T04:14:09.636750+00:00 0:00:01.686585 14081 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T04:14:05.646702+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-06T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T04:14:06.027246+00:00 2021-04-06T04:14:07.905806+00:00 0:00:01.878560 14080 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T04:14:03.578827+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-06T03:00:00+00:00 PythonOperator 2021-04-06T04:13:45.837250+00:00 2021-04-06T04:13:48.652749+00:00 0:00:02.815499 14079 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T04:13:43.523516+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-06T03:00:00+00:00 PythonOperator 2021-04-06T04:13:43.862083+00:00 2021-04-06T04:13:46.813138+00:00 0:00:02.951055 14078 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T04:13:41.573148+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-06T03:00:00+00:00 TriggerDagRunOperator 2021-04-06T04:13:21.812544+00:00 2021-04-06T04:13:22.361319+00:00 0:00:00.548775 14077 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T04:13:19.503442+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-06T03:00:00+00:00 TriggerDagRunOperator 2021-04-06T04:13:21.714307+00:00 2021-04-06T04:13:22.143018+00:00 0:00:00.428711 14076 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T04:13:19.503398+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-06T03:05:00+00:00 EmrJobFlowSensor 2021-04-06T04:05:56.668510+00:00 2021-04-06T04:14:59.195264+00:00 0:09:02.526754 14075 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T04:05:54.546756+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-06T03:05:00+00:00 EmrCreateJobFlowOperator 2021-04-06T04:05:36.676845+00:00 2021-04-06T04:05:38.335494+00:00 0:00:01.658649 14074 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T04:05:34.524798+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-06T03:05:00+00:00 PythonOperator 2021-04-06T04:05:14.681427+00:00 2021-04-06T04:05:17.332729+00:00 0:00:02.651302 14073 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T04:05:12.506050+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-06T03:00:00+00:00 EmrJobFlowSensor 2021-04-06T04:03:04.835692+00:00 2021-04-06T04:13:07.690181+00:00 0:10:02.854489 14072 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-06T04:03:02.352995+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-06T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T04:02:42.517269+00:00 2021-04-06T04:02:44.255885+00:00 0:00:01.738616 14071 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-06T04:02:40.256084+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-06T03:00:00+00:00 PythonOperator 2021-04-06T04:02:10.667191+00:00 2021-04-06T04:02:13.531373+00:00 0:00:02.864182 14070 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-06T04:02:08.220983+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-06T02:00:00+00:00 EmrJobFlowSensor 2021-04-06T03:11:28.200765+00:00 2021-04-06T03:20:30.834594+00:00 0:09:02.633829 14068 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T03:11:26.067618+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-06T02:00:00+00:00 EmrJobFlowSensor 2021-04-06T03:11:26.350452+00:00 2021-04-06T03:20:29.075371+00:00 0:09:02.724919 14067 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-06T03:11:24.076804+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-06T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-06T03:10:58.228032+00:00 2021-04-06T03:10:59.938259+00:00 0:00:01.710227 14066 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-06T03:10:56.044340+00:00 2 default_pool