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 check_cluster_status 2021-04-01T07:00:00+00:00 EmrJobFlowSensor 2021-04-01T08:18:21.202904+00:00 2021-04-01T08:27:23.733949+00:00 0:09:02.531045 12342 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T08:18:19.007414+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-01T07:00:00+00:00 EmrJobFlowSensor 2021-04-01T08:18:05.346721+00:00 2021-04-01T08:28:08.193912+00:00 0:10:02.847191 12341 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T08:18:02.985876+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-01T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T08:17:59.177267+00:00 2021-04-01T08:18:00.903995+00:00 0:00:01.726728 12340 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T08:17:56.915918+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-01T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T08:17:43.301890+00:00 2021-04-01T08:17:45.167285+00:00 0:00:01.865395 12339 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T08:17:40.904496+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-01T07:00:00+00:00 PythonOperator 2021-04-01T08:17:37.452178+00:00 2021-04-01T08:17:40.231940+00:00 0:00:02.779762 12338 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T08:17:34.960291+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-01T07:00:00+00:00 PythonOperator 2021-04-01T08:17:17.515425+00:00 2021-04-01T08:17:20.496481+00:00 0:00:02.981056 12337 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T08:17:14.944413+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-01T07:00:00+00:00 TriggerDagRunOperator 2021-04-01T08:17:05.620360+00:00 2021-04-01T08:17:06.067764+00:00 0:00:00.447404 12336 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T08:17:02.832208+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-01T07:00:00+00:00 TriggerDagRunOperator 2021-04-01T08:17:05.408787+00:00 2021-04-01T08:17:06.005191+00:00 0:00:00.596404 12335 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T08:17:02.832179+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-01T07:05:00+00:00 EmrJobFlowSensor 2021-04-01T08:05:54.132880+00:00 2021-04-01T08:14:56.717317+00:00 0:09:02.584437 12333 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T08:05:51.564154+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-01T07:05:00+00:00 EmrCreateJobFlowOperator 2021-04-01T08:05:33.900809+00:00 2021-04-01T08:05:35.568514+00:00 0:00:01.667705 12332 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T08:05:31.555848+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-01T07:05:00+00:00 PythonOperator 2021-04-01T08:05:11.572698+00:00 2021-04-01T08:05:14.262561+00:00 0:00:02.689863 12331 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T08:05:09.397704+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-01T07:00:00+00:00 EmrJobFlowSensor 2021-04-01T08:00:55.241494+00:00 2021-04-01T08:16:58.760596+00:00 0:16:03.519102 12330 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T08:00:52.900154+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-01T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T08:00:33.149024+00:00 2021-04-01T08:00:34.830519+00:00 0:00:01.681495 12329 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-01T08:00:30.866082+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-01T07:00:00+00:00 PythonOperator 2021-04-01T08:00:11.209819+00:00 2021-04-01T08:00:13.990249+00:00 0:00:02.780430 12328 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-01T08:00:08.863725+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-01T06:00:00+00:00 EmrJobFlowSensor 2021-04-01T07:14:00.337951+00:00 2021-04-01T07:23:03.191587+00:00 0:09:02.853636 12327 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T07:13:57.893347+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-01T06:00:00+00:00 EmrJobFlowSensor 2021-04-01T07:13:58.303041+00:00 2021-04-01T07:24:01.063142+00:00 0:10:02.760101 12326 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T07:13:55.957973+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-01T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T07:13:40.458050+00:00 2021-04-01T07:13:42.127757+00:00 0:00:01.669707 12325 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T07:13:37.848745+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-01T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T07:13:38.128503+00:00 2021-04-01T07:13:40.142673+00:00 0:00:02.014170 12324 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T07:13:35.846295+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-01T06:00:00+00:00 PythonOperator 2021-04-01T07:13:18.747837+00:00 2021-04-01T07:13:21.495206+00:00 0:00:02.747369 12323 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T07:13:15.832681+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-01T06:00:00+00:00 PythonOperator 2021-04-01T07:13:16.255157+00:00 2021-04-01T07:13:19.527968+00:00 0:00:03.272811 12322 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T07:13:13.829952+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-01T06:00:00+00:00 TriggerDagRunOperator 2021-04-01T07:12:56.263666+00:00 2021-04-01T07:12:56.786369+00:00 0:00:00.522703 12321 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T07:12:53.810978+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-01T06:00:00+00:00 TriggerDagRunOperator 2021-04-01T07:12:56.045751+00:00 2021-04-01T07:12:56.459134+00:00 0:00:00.413383 12320 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T07:12:53.811007+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-01T06:05:00+00:00 EmrJobFlowSensor 2021-04-01T07:06:12.040054+00:00 2021-04-01T07:15:14.663571+00:00 0:09:02.623517 12318 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T07:06:09.767713+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-01T06:05:00+00:00 EmrCreateJobFlowOperator 2021-04-01T07:05:51.810132+00:00 2021-04-01T07:05:53.464343+00:00 0:00:01.654211 12317 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T07:05:49.638015+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-01T06:05:00+00:00 PythonOperator 2021-04-01T07:05:15.804078+00:00 2021-04-01T07:05:18.578100+00:00 0:00:02.774022 12316 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T07:05:13.604579+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-01T06:00:00+00:00 EmrJobFlowSensor 2021-04-01T07:01:15.576380+00:00 2021-04-01T07:11:18.444671+00:00 0:10:02.868291 12315 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T07:01:13.290033+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-01T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T07:00:51.570536+00:00 2021-04-01T07:00:53.373486+00:00 0:00:01.802950 12314 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-01T07:00:49.269788+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-01T06:00:00+00:00 PythonOperator 2021-04-01T07:00:27.548746+00:00 2021-04-01T07:00:30.266755+00:00 0:00:02.718009 12313 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-01T07:00:25.275233+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-01T05:00:00+00:00 EmrJobFlowSensor 2021-04-01T06:11:28.937377+00:00 2021-04-01T06:22:31.825661+00:00 0:11:02.888284 12312 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T06:11:26.459646+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-01T05:00:00+00:00 EmrJobFlowSensor 2021-04-01T06:11:22.804909+00:00 2021-04-01T06:20:25.419204+00:00 0:09:02.614295 12311 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T06:11:20.461582+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-01T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T06:11:06.675035+00:00 2021-04-01T06:11:08.552543+00:00 0:00:01.877508 12310 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T06:11:04.381586+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-01T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T06:11:02.678825+00:00 2021-04-01T06:11:04.508526+00:00 0:00:01.829701 12309 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T06:11:00.378953+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-01T05:00:00+00:00 PythonOperator 2021-04-01T06:10:46.685630+00:00 2021-04-01T06:10:49.647037+00:00 0:00:02.961407 12308 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T06:10:44.330377+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-01T05:00:00+00:00 PythonOperator 2021-04-01T06:10:41.025456+00:00 2021-04-01T06:10:43.742256+00:00 0:00:02.716800 12307 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T06:10:38.449870+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-01T05:00:00+00:00 TriggerDagRunOperator 2021-04-01T06:10:29.128092+00:00 2021-04-01T06:10:29.675417+00:00 0:00:00.547325 12306 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T06:10:26.310664+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-01T05:00:00+00:00 TriggerDagRunOperator 2021-04-01T06:10:28.925518+00:00 2021-04-01T06:10:29.347993+00:00 0:00:00.422475 12305 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T06:10:26.310637+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-01T05:05:00+00:00 EmrJobFlowSensor 2021-04-01T06:05:55.275123+00:00 2021-04-01T06:14:57.936372+00:00 0:09:02.661249 12303 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T06:05:52.967156+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-01T05:05:00+00:00 EmrCreateJobFlowOperator 2021-04-01T06:05:33.267128+00:00 2021-04-01T06:05:34.892441+00:00 0:00:01.625313 12302 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T06:05:30.884753+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-01T05:05:00+00:00 PythonOperator 2021-04-01T06:05:10.889679+00:00 2021-04-01T06:05:13.630980+00:00 0:00:02.741301 12301 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T06:05:08.742623+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-01T05:00:00+00:00 EmrJobFlowSensor 2021-04-01T06:01:02.631103+00:00 2021-04-01T06:10:05.327143+00:00 0:09:02.696040 12300 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T06:01:00.380715+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-01T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T06:00:40.565336+00:00 2021-04-01T06:00:42.375533+00:00 0:00:01.810197 12299 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-01T06:00:38.296448+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-01T05:00:00+00:00 PythonOperator 2021-04-01T06:00:20.529161+00:00 2021-04-01T06:00:23.249023+00:00 0:00:02.719862 12298 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-01T06:00:18.241804+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-01T04:00:00+00:00 EmrJobFlowSensor 2021-04-01T05:11:07.930559+00:00 2021-04-01T05:21:10.762210+00:00 0:10:02.831651 12297 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T05:11:05.363544+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-01T04:00:00+00:00 EmrJobFlowSensor 2021-04-01T05:11:07.859910+00:00 2021-04-01T05:20:10.620858+00:00 0:09:02.760948 12296 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T05:11:05.363492+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-01T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T05:10:45.714621+00:00 2021-04-01T05:10:47.418623+00:00 0:00:01.704002 12295 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T05:10:43.343692+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-01T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T05:10:45.730377+00:00 2021-04-01T05:10:47.558743+00:00 0:00:01.828366 12294 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T05:10:43.343661+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-01T04:00:00+00:00 PythonOperator 2021-04-01T05:10:25.635346+00:00 2021-04-01T05:10:28.511227+00:00 0:00:02.875881 12293 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T05:10:23.222302+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-01T04:00:00+00:00 PythonOperator 2021-04-01T05:10:23.784962+00:00 2021-04-01T05:10:26.793558+00:00 0:00:03.008596 12292 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T05:10:21.221875+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-01T04:00:00+00:00 TriggerDagRunOperator 2021-04-01T05:10:17.943409+00:00 2021-04-01T05:10:18.482341+00:00 0:00:00.538932 12291 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T05:10:15.270693+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-01T04:00:00+00:00 TriggerDagRunOperator 2021-04-01T05:10:17.636372+00:00 2021-04-01T05:10:18.050885+00:00 0:00:00.414513 12290 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T05:10:15.270731+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-01T04:05:00+00:00 EmrJobFlowSensor 2021-04-01T05:09:27.278359+00:00 2021-04-01T05:18:29.771708+00:00 0:09:02.493349 12289 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T05:09:25.124463+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-01T04:05:00+00:00 EmrCreateJobFlowOperator 2021-04-01T05:09:07.280445+00:00 2021-04-01T05:09:08.942166+00:00 0:00:01.661721 12288 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T05:09:05.105630+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-01T04:05:00+00:00 PythonOperator 2021-04-01T05:08:45.817740+00:00 2021-04-01T05:08:48.590787+00:00 0:00:02.773047 12287 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T05:08:43.037511+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-01T04:00:00+00:00 EmrJobFlowSensor 2021-04-01T05:01:03.568998+00:00 2021-04-01T05:10:06.306620+00:00 0:09:02.737622 12285 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T05:01:01.154968+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-01T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T05:00:39.703760+00:00 2021-04-01T05:00:41.481725+00:00 0:00:01.777965 12284 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-01T05:00:37.175350+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-01T04:00:00+00:00 PythonOperator 2021-04-01T05:00:19.641469+00:00 2021-04-01T05:00:22.367466+00:00 0:00:02.725997 12283 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-01T05:00:17.093780+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-01T03:00:00+00:00 EmrJobFlowSensor 2021-04-01T04:13:24.817601+00:00 2021-04-01T04:23:27.627582+00:00 0:10:02.809981 12282 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T04:13:22.560527+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-01T03:00:00+00:00 EmrJobFlowSensor 2021-04-01T04:13:15.150973+00:00 2021-04-01T04:23:17.911833+00:00 0:10:02.760860 12281 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T04:13:12.549158+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-01T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T04:13:04.698729+00:00 2021-04-01T04:13:06.418563+00:00 0:00:01.719834 12280 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T04:13:02.422876+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-01T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T04:12:55.039146+00:00 2021-04-01T04:12:56.745812+00:00 0:00:01.706666 12279 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T04:12:52.412664+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-01T03:00:00+00:00 PythonOperator 2021-04-01T04:12:42.674885+00:00 2021-04-01T04:12:45.581067+00:00 0:00:02.906182 12278 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T04:12:40.391585+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-01T03:00:00+00:00 PythonOperator 2021-04-01T04:12:33.018377+00:00 2021-04-01T04:12:35.756072+00:00 0:00:02.737695 12277 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T04:12:30.385731+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-01T03:00:00+00:00 TriggerDagRunOperator 2021-04-01T04:12:20.920521+00:00 2021-04-01T04:12:21.332754+00:00 0:00:00.412233 12276 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T04:12:18.356273+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-01T03:00:00+00:00 TriggerDagRunOperator 2021-04-01T04:12:20.727973+00:00 2021-04-01T04:12:21.253699+00:00 0:00:00.525726 12275 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T04:12:18.356349+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-01T03:05:00+00:00 EmrJobFlowSensor 2021-04-01T04:06:10.159976+00:00 2021-04-01T04:15:12.800931+00:00 0:09:02.640955 12274 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T04:06:07.846565+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-01T03:05:00+00:00 EmrCreateJobFlowOperator 2021-04-01T04:05:43.911140+00:00 2021-04-01T04:05:45.574095+00:00 0:00:01.662955 12273 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T04:05:41.747497+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-01T03:05:00+00:00 PythonOperator 2021-04-01T04:05:21.880470+00:00 2021-04-01T04:05:24.569499+00:00 0:00:02.689029 12272 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T04:05:19.727321+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-01T03:00:00+00:00 EmrJobFlowSensor 2021-04-01T04:03:07.952201+00:00 2021-04-01T04:12:10.612355+00:00 0:09:02.660154 12271 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T04:03:05.563828+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-01T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T04:02:39.728759+00:00 2021-04-01T04:02:41.422565+00:00 0:00:01.693806 12270 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-01T04:02:37.511269+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-01T03:00:00+00:00 PythonOperator 2021-04-01T04:02:17.818538+00:00 2021-04-01T04:02:20.574514+00:00 0:00:02.755976 12269 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-01T04:02:15.490681+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-01T02:00:00+00:00 EmrJobFlowSensor 2021-04-01T03:12:03.905080+00:00 2021-04-01T03:24:06.890037+00:00 0:12:02.984957 12267 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T03:12:01.701185+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-01T02:00:00+00:00 EmrJobFlowSensor 2021-04-01T03:11:50.187198+00:00 2021-04-01T03:21:53.010069+00:00 0:10:02.822871 12266 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T03:11:47.749916+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-01T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T03:11:41.923786+00:00 2021-04-01T03:11:43.628613+00:00 0:00:01.704827 12265 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T03:11:39.685036+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-01T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T03:11:30.026381+00:00 2021-04-01T03:11:31.918405+00:00 0:00:01.892024 12264 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T03:11:27.595702+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-01T02:00:00+00:00 PythonOperator 2021-04-01T03:11:20.234050+00:00 2021-04-01T03:11:23.162940+00:00 0:00:02.928890 12263 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T03:11:17.592171+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-01T02:00:00+00:00 PythonOperator 2021-04-01T03:11:07.914046+00:00 2021-04-01T03:11:10.833645+00:00 0:00:02.919599 12262 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T03:11:05.556048+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-01T02:00:00+00:00 TriggerDagRunOperator 2021-04-01T03:11:03.924114+00:00 2021-04-01T03:11:04.361984+00:00 0:00:00.437870 12261 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T03:11:01.553883+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-01T02:00:00+00:00 TriggerDagRunOperator 2021-04-01T03:11:03.902373+00:00 2021-04-01T03:11:04.484108+00:00 0:00:00.581735 12260 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T03:11:01.553915+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-01T02:05:00+00:00 EmrJobFlowSensor 2021-04-01T03:05:59.374138+00:00 2021-04-01T03:15:02.104903+00:00 0:09:02.730765 12259 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T03:05:57.114549+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-01T02:05:00+00:00 EmrCreateJobFlowOperator 2021-04-01T03:05:37.504103+00:00 2021-04-01T03:05:39.268044+00:00 0:00:01.763941 12258 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T03:05:35.148081+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-01T02:05:00+00:00 PythonOperator 2021-04-01T03:05:15.505106+00:00 2021-04-01T03:05:18.201533+00:00 0:00:02.696427 12257 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T03:05:13.055913+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-01T02:00:00+00:00 EmrJobFlowSensor 2021-04-01T03:00:54.854891+00:00 2021-04-01T03:10:57.634113+00:00 0:10:02.779222 12256 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T03:00:52.494237+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-01T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T03:00:34.674817+00:00 2021-04-01T03:00:36.371078+00:00 0:00:01.696261 12255 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-01T03:00:32.449952+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-01T02:00:00+00:00 PythonOperator 2021-04-01T03:00:12.837654+00:00 2021-04-01T03:00:15.568722+00:00 0:00:02.731068 12254 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-01T03:00:10.430746+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-01T01:00:00+00:00 EmrJobFlowSensor 2021-04-01T02:12:15.900585+00:00 2021-04-01T02:22:18.494892+00:00 0:10:02.594307 12252 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T02:12:13.646658+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-01T01:00:00+00:00 EmrJobFlowSensor 2021-04-01T02:11:56.048973+00:00 2021-04-01T02:20:58.870468+00:00 0:09:02.821495 12251 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T02:11:53.625802+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-01T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T02:11:56.011881+00:00 2021-04-01T02:11:57.760840+00:00 0:00:01.748959 12250 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T02:11:53.625837+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-01T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T02:11:35.914072+00:00 2021-04-01T02:11:37.582424+00:00 0:00:01.668352 12249 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T02:11:33.605206+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-01T01:00:00+00:00 PythonOperator 2021-04-01T02:11:33.946663+00:00 2021-04-01T02:11:37.058486+00:00 0:00:03.111823 12248 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T02:11:31.603974+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-01T01:00:00+00:00 PythonOperator 2021-04-01T02:11:11.930149+00:00 2021-04-01T02:11:14.634330+00:00 0:00:02.704181 12247 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T02:11:09.649762+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-01T01:00:00+00:00 TriggerDagRunOperator 2021-04-01T02:11:08.139683+00:00 2021-04-01T02:11:08.705961+00:00 0:00:00.566278 12246 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T02:11:05.584696+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-01T01:00:00+00:00 TriggerDagRunOperator 2021-04-01T02:11:07.970829+00:00 2021-04-01T02:11:08.382326+00:00 0:00:00.411497 12245 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T02:11:05.584664+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-01T01:05:00+00:00 EmrJobFlowSensor 2021-04-01T02:05:53.106418+00:00 2021-04-01T02:14:55.712818+00:00 0:09:02.606400 12244 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T02:05:50.912628+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-01T01:05:00+00:00 EmrCreateJobFlowOperator 2021-04-01T02:05:33.194355+00:00 2021-04-01T02:05:34.855327+00:00 0:00:01.660972 12243 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T02:05:30.895908+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-01T01:05:00+00:00 PythonOperator 2021-04-01T02:05:11.095230+00:00 2021-04-01T02:05:13.776778+00:00 0:00:02.681548 12242 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T02:05:08.858740+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-01T01:00:00+00:00 EmrJobFlowSensor 2021-04-01T02:00:50.798903+00:00 2021-04-01T02:10:53.624650+00:00 0:10:02.825747 12241 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T02:00:48.481740+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-01T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T02:00:30.973226+00:00 2021-04-01T02:00:32.695345+00:00 0:00:01.722119 12240 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-01T02:00:28.557678+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-01T01:00:00+00:00 PythonOperator 2021-04-01T02:00:09.258182+00:00 2021-04-01T02:00:12.136915+00:00 0:00:02.878733 12239 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-01T02:00:06.390566+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-01T00:00:00+00:00 EmrJobFlowSensor 2021-04-01T01:11:26.113219+00:00 2021-04-01T01:21:28.914356+00:00 0:10:02.801137 12237 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T01:11:23.935712+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-01T00:00:00+00:00 EmrJobFlowSensor 2021-04-01T01:11:16.396670+00:00 2021-04-01T01:20:19.235854+00:00 0:09:02.839184 12236 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T01:11:13.929620+00:00 2 default_pool