Task Instances

  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success vc-asset-import_v002 create_emr_steps 2021-07-10T13:05:00+00:00 PythonOperator 2021-07-10T14:05:22.962927+00:00 2021-07-10T14:05:26.687889+00:00 0:00:03.724962 52248 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-10T14:05:20.799618+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-10T12:00:00+00:00 EmrJobFlowSensor 2021-07-10T13:11:08.000090+00:00 2021-07-10T13:21:10.737089+00:00 0:10:02.736999 52243 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-10T13:11:05.699840+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-10T12:00:00+00:00 EmrJobFlowSensor 2021-07-10T13:11:06.349096+00:00 2021-07-10T13:21:09.291768+00:00 0:10:02.942672 52242 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-10T13:11:03.751416+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-10T12:00:00+00:00 EmrCreateJobFlowOperator 2021-07-10T13:10:47.915056+00:00 2021-07-10T13:10:49.727762+00:00 0:00:01.812706 52241 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-10T13:10:45.676449+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-10T12:00:00+00:00 EmrCreateJobFlowOperator 2021-07-10T13:10:43.938265+00:00 2021-07-10T13:10:45.603640+00:00 0:00:01.665375 52240 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-10T13:10:41.755002+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-10T12:00:00+00:00 PythonOperator 2021-07-10T13:10:25.795486+00:00 2021-07-10T13:10:29.445100+00:00 0:00:03.649614 52239 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-10T13:10:23.660799+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-10T12:00:00+00:00 PythonOperator 2021-07-10T13:10:21.926972+00:00 2021-07-10T13:10:25.668025+00:00 0:00:03.741053 52238 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-10T13:10:19.659629+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-07-10T12:00:00+00:00 TriggerDagRunOperator 2021-07-10T13:10:12.266831+00:00 2021-07-10T13:10:12.704140+00:00 0:00:00.437309 52237 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-10T13:10:09.646832+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-07-10T12:00:00+00:00 TriggerDagRunOperator 2021-07-10T13:10:11.886972+00:00 2021-07-10T13:10:12.525464+00:00 0:00:00.638492 52236 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-10T13:10:09.646800+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-07-10T12:05:00+00:00 EmrJobFlowSensor 2021-07-10T13:05:55.544014+00:00 2021-07-10T13:13:58.175574+00:00 0:08:02.631560 52235 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-10T13:05:53.293952+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-07-10T12:05:00+00:00 EmrCreateJobFlowOperator 2021-07-10T13:05:33.511729+00:00 2021-07-10T13:05:35.280288+00:00 0:00:01.768559 52234 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-10T13:05:31.257711+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-07-10T12:05:00+00:00 PythonOperator 2021-07-10T13:05:11.418136+00:00 2021-07-10T13:05:15.209860+00:00 0:00:03.791724 52233 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-10T13:05:09.230506+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-07-10T12:00:00+00:00 EmrJobFlowSensor 2021-07-10T13:01:00.988826+00:00 2021-07-10T13:10:03.940312+00:00 0:09:02.951486 52232 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-10T13:00:58.809287+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-07-10T12:00:00+00:00 EmrCreateJobFlowOperator 2021-07-10T13:00:39.146458+00:00 2021-07-10T13:00:40.937635+00:00 0:00:01.791177 52231 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-07-10T13:00:36.793501+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-07-10T12:00:00+00:00 PythonOperator 2021-07-10T13:00:17.326889+00:00 2021-07-10T13:00:20.973323+00:00 0:00:03.646434 52230 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-07-10T13:00:14.733526+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-10T11:00:00+00:00 EmrJobFlowSensor 2021-07-10T12:12:29.435506+00:00 2021-07-10T12:21:32.255658+00:00 0:09:02.820152 52228 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-10T12:12:26.920614+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-10T11:00:00+00:00 EmrJobFlowSensor 2021-07-10T12:12:29.385106+00:00 2021-07-10T12:21:32.060531+00:00 0:09:02.675425 52227 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-10T12:12:26.920579+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-10T11:00:00+00:00 EmrCreateJobFlowOperator 2021-07-10T12:12:07.571930+00:00 2021-07-10T12:12:09.280945+00:00 0:00:01.709015 52226 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-10T12:12:04.951539+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-10T11:00:00+00:00 EmrCreateJobFlowOperator 2021-07-10T12:12:07.375387+00:00 2021-07-10T12:12:09.221453+00:00 0:00:01.846066 52225 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-10T12:12:04.951501+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-10T11:00:00+00:00 PythonOperator 2021-07-10T12:11:45.517850+00:00 2021-07-10T12:11:49.251245+00:00 0:00:03.733395 52224 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-10T12:11:42.940889+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-10T11:00:00+00:00 PythonOperator 2021-07-10T12:11:45.489671+00:00 2021-07-10T12:11:49.283309+00:00 0:00:03.793638 52223 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-10T12:11:42.940935+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-07-10T11:00:00+00:00 TriggerDagRunOperator 2021-07-10T12:11:29.370571+00:00 2021-07-10T12:11:29.883883+00:00 0:00:00.513312 52222 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-10T12:11:26.841054+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-07-10T11:00:00+00:00 TriggerDagRunOperator 2021-07-10T12:11:29.262770+00:00 2021-07-10T12:11:29.649442+00:00 0:00:00.386672 52221 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-10T12:11:26.841090+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-07-10T11:05:00+00:00 EmrJobFlowSensor 2021-07-10T12:05:48.753539+00:00 2021-07-10T12:14:51.582749+00:00 0:09:02.829210 52220 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-10T12:05:46.361566+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-07-10T11:05:00+00:00 EmrCreateJobFlowOperator 2021-07-10T12:05:26.439670+00:00 2021-07-10T12:05:28.048108+00:00 0:00:01.608438 52219 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-10T12:05:24.187395+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-07-10T11:05:00+00:00 PythonOperator 2021-07-10T12:05:06.267470+00:00 2021-07-10T12:05:09.989729+00:00 0:00:03.722259 52218 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-10T12:05:04.173149+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-07-10T11:00:00+00:00 EmrJobFlowSensor 2021-07-10T12:01:02.212519+00:00 2021-07-10T12:11:05.083307+00:00 0:10:02.870788 52217 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-10T12:00:59.760544+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-07-10T11:00:00+00:00 EmrCreateJobFlowOperator 2021-07-10T12:00:40.042402+00:00 2021-07-10T12:00:41.863071+00:00 0:00:01.820669 52216 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-07-10T12:00:37.610395+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-07-10T11:00:00+00:00 PythonOperator 2021-07-10T12:00:09.783198+00:00 2021-07-10T12:00:13.489938+00:00 0:00:03.706740 52215 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-07-10T12:00:07.553075+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-10T10:00:00+00:00 EmrJobFlowSensor 2021-07-10T11:10:50.335254+00:00 2021-07-10T11:19:53.024095+00:00 0:09:02.688841 52213 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-10T11:10:47.819787+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-10T10:00:00+00:00 EmrJobFlowSensor 2021-07-10T11:10:48.172234+00:00 2021-07-10T11:19:50.919304+00:00 0:09:02.747070 52212 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-10T11:10:45.821083+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-10T10:00:00+00:00 EmrCreateJobFlowOperator 2021-07-10T11:10:28.249183+00:00 2021-07-10T11:10:29.926165+00:00 0:00:01.676982 52211 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-10T11:10:25.804743+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-10T10:00:00+00:00 EmrCreateJobFlowOperator 2021-07-10T11:10:28.120248+00:00 2021-07-10T11:10:30.061586+00:00 0:00:01.941338 52210 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-10T11:10:25.804790+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-10T10:00:00+00:00 PythonOperator 2021-07-10T11:10:06.974394+00:00 2021-07-10T11:10:10.963401+00:00 0:00:03.989007 52209 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-10T11:10:03.786015+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-10T10:00:00+00:00 PythonOperator 2021-07-10T11:10:04.092053+00:00 2021-07-10T11:10:08.654186+00:00 0:00:04.562133 52208 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-10T11:10:01.788625+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-07-10T10:00:00+00:00 TriggerDagRunOperator 2021-07-10T11:09:58.188468+00:00 2021-07-10T11:09:58.566444+00:00 0:00:00.377976 52207 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-10T11:09:55.739043+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-07-10T10:00:00+00:00 TriggerDagRunOperator 2021-07-10T11:09:58.120230+00:00 2021-07-10T11:09:58.740318+00:00 0:00:00.620088 52206 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-10T11:09:55.739010+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-07-10T10:05:00+00:00 EmrJobFlowSensor 2021-07-10T11:05:53.620119+00:00 2021-07-10T11:14:56.504016+00:00 0:09:02.883897 52205 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-10T11:05:51.325769+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-07-10T10:05:00+00:00 EmrCreateJobFlowOperator 2021-07-10T11:05:31.590343+00:00 2021-07-10T11:05:33.332768+00:00 0:00:01.742425 52204 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-10T11:05:29.314176+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-07-10T10:05:00+00:00 PythonOperator 2021-07-10T11:05:11.495853+00:00 2021-07-10T11:05:15.340971+00:00 0:00:03.845118 52203 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-10T11:05:09.289285+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-07-10T10:00:00+00:00 EmrJobFlowSensor 2021-07-10T11:00:48.987293+00:00 2021-07-10T11:09:51.685164+00:00 0:09:02.697871 52202 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-10T11:00:46.624369+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-07-10T10:00:00+00:00 EmrCreateJobFlowOperator 2021-07-10T11:00:28.917520+00:00 2021-07-10T11:00:30.624101+00:00 0:00:01.706581 52201 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-07-10T11:00:26.606743+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-07-10T10:00:00+00:00 PythonOperator 2021-07-10T11:00:07.444876+00:00 2021-07-10T11:00:11.181993+00:00 0:00:03.737117 52200 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-07-10T11:00:04.652264+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-10T09:00:00+00:00 EmrJobFlowSensor 2021-07-10T10:11:10.366902+00:00 2021-07-10T10:21:13.279691+00:00 0:10:02.912789 52198 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-10T10:11:08.093126+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-10T09:00:00+00:00 EmrJobFlowSensor 2021-07-10T10:11:04.655341+00:00 2021-07-10T10:20:07.547694+00:00 0:09:02.892353 52197 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-10T10:11:02.085945+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-10T09:00:00+00:00 EmrCreateJobFlowOperator 2021-07-10T10:10:44.403449+00:00 2021-07-10T10:10:46.226362+00:00 0:00:01.822913 52196 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-10T10:10:42.024299+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-10T09:00:00+00:00 EmrCreateJobFlowOperator 2021-07-10T10:10:34.301286+00:00 2021-07-10T10:10:35.951128+00:00 0:00:01.649842 52195 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-10T10:10:32.019772+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-10T09:00:00+00:00 PythonOperator 2021-07-10T10:10:18.658252+00:00 2021-07-10T10:10:22.734574+00:00 0:00:04.076322 52194 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-10T10:10:16.060061+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-10T09:00:00+00:00 PythonOperator 2021-07-10T10:10:12.713443+00:00 2021-07-10T10:10:16.457819+00:00 0:00:03.744376 52193 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-10T10:10:10.045458+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-07-10T09:00:00+00:00 TriggerDagRunOperator 2021-07-10T10:10:04.448378+00:00 2021-07-10T10:10:04.968692+00:00 0:00:00.520314 52192 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-10T10:10:01.991249+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-07-10T09:00:00+00:00 TriggerDagRunOperator 2021-07-10T10:10:04.183608+00:00 2021-07-10T10:10:04.585373+00:00 0:00:00.401765 52191 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-10T10:10:01.991208+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-07-10T09:05:00+00:00 EmrJobFlowSensor 2021-07-10T10:05:50.088117+00:00 2021-07-10T10:14:52.918495+00:00 0:09:02.830378 52190 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-10T10:05:47.689507+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-07-10T09:05:00+00:00 EmrCreateJobFlowOperator 2021-07-10T10:05:27.964300+00:00 2021-07-10T10:05:29.587717+00:00 0:00:01.623417 52189 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-10T10:05:25.662950+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-07-10T09:05:00+00:00 PythonOperator 2021-07-10T10:05:07.847710+00:00 2021-07-10T10:05:11.573414+00:00 0:00:03.725704 52188 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-10T10:05:05.646039+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-07-10T09:00:00+00:00 EmrJobFlowSensor 2021-07-10T10:00:47.929795+00:00 2021-07-10T10:09:50.801580+00:00 0:09:02.871785 52187 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-10T10:00:45.246784+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-07-10T09:00:00+00:00 EmrCreateJobFlowOperator 2021-07-10T10:00:25.619023+00:00 2021-07-10T10:00:27.331381+00:00 0:00:01.712358 52186 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-07-10T10:00:23.260256+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-07-10T09:00:00+00:00 PythonOperator 2021-07-10T10:00:05.760713+00:00 2021-07-10T10:00:09.686133+00:00 0:00:03.925420 52185 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-07-10T10:00:03.181503+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-10T08:00:00+00:00 EmrJobFlowSensor 2021-07-10T09:10:30.965381+00:00 2021-07-10T09:20:34.068629+00:00 0:10:03.103248 52183 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-10T09:10:28.541564+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-10T08:00:00+00:00 EmrJobFlowSensor 2021-07-10T09:10:12.637738+00:00 2021-07-10T09:20:15.562863+00:00 0:10:02.925125 52182 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-10T09:10:10.342224+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-10T08:00:00+00:00 EmrCreateJobFlowOperator 2021-07-10T09:10:08.876106+00:00 2021-07-10T09:10:10.705657+00:00 0:00:01.829551 52181 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-10T09:10:06.349376+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-10T08:00:00+00:00 EmrCreateJobFlowOperator 2021-07-10T09:09:48.898055+00:00 2021-07-10T09:09:50.773051+00:00 0:00:01.874996 52180 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-10T09:09:46.377919+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-10T08:00:00+00:00 PythonOperator 2021-07-10T09:09:46.892613+00:00 2021-07-10T09:09:50.547796+00:00 0:00:03.655183 52179 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-10T09:09:44.380756+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-10T08:00:00+00:00 PythonOperator 2021-07-10T09:09:28.577770+00:00 2021-07-10T09:09:32.626705+00:00 0:00:04.048935 52178 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-10T09:09:26.319902+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-07-10T08:00:00+00:00 TriggerDagRunOperator 2021-07-10T09:09:22.653967+00:00 2021-07-10T09:09:23.153314+00:00 0:00:00.499347 52177 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-10T09:09:20.301827+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-07-10T08:00:00+00:00 TriggerDagRunOperator 2021-07-10T09:09:22.501720+00:00 2021-07-10T09:09:22.900001+00:00 0:00:00.398281 52176 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-10T09:09:20.301797+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-07-10T08:05:00+00:00 EmrJobFlowSensor 2021-07-10T09:05:48.619485+00:00 2021-07-10T09:13:51.154808+00:00 0:08:02.535323 52175 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-10T09:05:46.047429+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-07-10T08:05:00+00:00 EmrCreateJobFlowOperator 2021-07-10T09:05:26.151392+00:00 2021-07-10T09:05:27.873535+00:00 0:00:01.722143 52174 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-10T09:05:23.979703+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-07-10T08:05:00+00:00 PythonOperator 2021-07-10T09:05:06.276906+00:00 2021-07-10T09:05:09.713003+00:00 0:00:03.436097 52173 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-10T09:05:03.965029+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-07-10T08:00:00+00:00 EmrJobFlowSensor 2021-07-10T09:01:02.167293+00:00 2021-07-10T09:09:04.881359+00:00 0:08:02.714066 52172 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-10T09:00:59.746625+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-07-10T08:00:00+00:00 EmrCreateJobFlowOperator 2021-07-10T09:00:39.819891+00:00 2021-07-10T09:00:41.555138+00:00 0:00:01.735247 52171 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-07-10T09:00:37.526241+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-07-10T08:00:00+00:00 PythonOperator 2021-07-10T09:00:14.096573+00:00 2021-07-10T09:00:17.565754+00:00 0:00:03.469181 52170 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-07-10T09:00:11.501082+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-10T07:00:00+00:00 EmrJobFlowSensor 2021-07-10T08:12:00.057030+00:00 2021-07-10T08:22:03.014140+00:00 0:10:02.957110 52168 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-10T08:11:57.762684+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-10T07:00:00+00:00 EmrJobFlowSensor 2021-07-10T08:11:48.046472+00:00 2021-07-10T08:19:50.691497+00:00 0:08:02.645025 52167 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-10T08:11:45.721056+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-10T07:00:00+00:00 EmrCreateJobFlowOperator 2021-07-10T08:11:39.906039+00:00 2021-07-10T08:11:41.580785+00:00 0:00:01.674746 52166 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-10T08:11:37.714708+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-10T07:00:00+00:00 EmrCreateJobFlowOperator 2021-07-10T08:11:26.170918+00:00 2021-07-10T08:11:28.016260+00:00 0:00:01.845342 52165 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-10T08:11:23.772405+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-10T07:00:00+00:00 PythonOperator 2021-07-10T08:11:18.032470+00:00 2021-07-10T08:11:21.945821+00:00 0:00:03.913351 52164 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-10T08:11:15.762431+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-10T07:00:00+00:00 PythonOperator 2021-07-10T08:11:04.474728+00:00 2021-07-10T08:11:08.231387+00:00 0:00:03.756659 52163 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-10T08:11:01.693616+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-07-10T07:00:00+00:00 TriggerDagRunOperator 2021-07-10T08:10:56.281026+00:00 2021-07-10T08:10:56.811998+00:00 0:00:00.530972 52162 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-10T08:10:53.672002+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-07-10T07:00:00+00:00 TriggerDagRunOperator 2021-07-10T08:10:56.058967+00:00 2021-07-10T08:10:56.450257+00:00 0:00:00.391290 52161 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-10T08:10:53.671974+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-07-10T07:05:00+00:00 EmrJobFlowSensor 2021-07-10T08:06:05.180530+00:00 2021-07-10T08:15:07.905953+00:00 0:09:02.725423 52160 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-10T08:06:03.038526+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-07-10T07:05:00+00:00 EmrCreateJobFlowOperator 2021-07-10T08:05:43.402401+00:00 2021-07-10T08:05:45.118219+00:00 0:00:01.715818 52159 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-10T08:05:41.141158+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-07-10T07:05:00+00:00 PythonOperator 2021-07-10T08:05:21.179190+00:00 2021-07-10T08:05:25.048243+00:00 0:00:03.869053 52158 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-10T08:05:19.012357+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-07-10T07:00:00+00:00 EmrJobFlowSensor 2021-07-10T08:00:49.117080+00:00 2021-07-10T08:10:52.013587+00:00 0:10:02.896507 52157 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-10T08:00:46.622580+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-07-10T07:00:00+00:00 EmrCreateJobFlowOperator 2021-07-10T08:00:27.022176+00:00 2021-07-10T08:00:28.796930+00:00 0:00:01.774754 52156 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-07-10T08:00:24.659322+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-07-10T07:00:00+00:00 PythonOperator 2021-07-10T08:00:06.861938+00:00 2021-07-10T08:00:10.905159+00:00 0:00:04.043221 52155 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-07-10T08:00:04.586226+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-10T06:00:00+00:00 EmrJobFlowSensor 2021-07-10T07:18:00.521775+00:00 2021-07-10T07:27:03.346925+00:00 0:09:02.825150 52154 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-10T07:17:58.057467+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-10T06:00:00+00:00 EmrJobFlowSensor 2021-07-10T07:17:56.182489+00:00 2021-07-10T07:27:59.263032+00:00 0:10:03.080543 52153 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-10T07:17:53.869947+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-10T06:00:00+00:00 EmrCreateJobFlowOperator 2021-07-10T07:17:40.036192+00:00 2021-07-10T07:17:41.759374+00:00 0:00:01.723182 52152 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-10T07:17:37.866205+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-10T06:00:00+00:00 EmrCreateJobFlowOperator 2021-07-10T07:17:36.014812+00:00 2021-07-10T07:17:37.673184+00:00 0:00:01.658372 52151 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-10T07:17:33.816217+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-10T06:00:00+00:00 PythonOperator 2021-07-10T07:17:18.815176+00:00 2021-07-10T07:17:22.945989+00:00 0:00:04.130813 52150 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-10T07:17:15.803134+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-10T06:00:00+00:00 PythonOperator 2021-07-10T07:17:14.745450+00:00 2021-07-10T07:17:19.863527+00:00 0:00:05.118077 52149 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-10T07:17:11.797239+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-07-10T06:00:00+00:00 TriggerDagRunOperator 2021-07-10T07:17:06.414707+00:00 2021-07-10T07:17:06.911437+00:00 0:00:00.496730 52148 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-10T07:17:03.793556+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-07-10T06:00:00+00:00 TriggerDagRunOperator 2021-07-10T07:17:06.279040+00:00 2021-07-10T07:17:06.695836+00:00 0:00:00.416796 52147 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-10T07:17:03.793522+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-07-10T06:05:00+00:00 EmrJobFlowSensor 2021-07-10T07:05:54.593343+00:00 2021-07-10T07:14:57.476497+00:00 0:09:02.883154 52145 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-10T07:05:52.286253+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-07-10T06:05:00+00:00 EmrCreateJobFlowOperator 2021-07-10T07:05:34.433569+00:00 2021-07-10T07:05:36.057531+00:00 0:00:01.623962 52144 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-10T07:05:32.261299+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-07-10T06:05:00+00:00 PythonOperator 2021-07-10T07:05:12.401546+00:00 2021-07-10T07:05:15.825388+00:00 0:00:03.423842 52143 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-10T07:05:10.246449+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-07-10T06:00:00+00:00 EmrJobFlowSensor 2021-07-10T07:01:08.181879+00:00 2021-07-10T07:11:11.033603+00:00 0:10:02.851724 52142 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-10T07:01:05.868379+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-07-10T06:00:00+00:00 EmrCreateJobFlowOperator 2021-07-10T07:00:46.187770+00:00 2021-07-10T07:00:47.919483+00:00 0:00:01.731713 52141 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-07-10T07:00:43.879732+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-07-10T06:00:00+00:00 PythonOperator 2021-07-10T07:00:24.090446+00:00 2021-07-10T07:00:27.595003+00:00 0:00:03.504557 52140 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-07-10T07:00:21.813528+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-10T05:00:00+00:00 EmrJobFlowSensor 2021-07-10T06:12:33.770844+00:00 2021-07-10T06:21:36.394618+00:00 0:09:02.623774 52139 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-10T06:12:30.876945+00:00 2 default_pool