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-flow-job_v002 check_cluster_status 2021-05-02T02:00:00+00:00 EmrJobFlowSensor 2021-05-02T03:00:56.006456+00:00 2021-05-02T03:09:58.898796+00:00 0:09:02.892340 23499 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T03:00:53.699702+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-02T02:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T03:00:34.082305+00:00 2021-05-02T03:00:35.907587+00:00 0:00:01.825282 23498 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-02T03:00:31.663355+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-02T02:00:00+00:00 PythonOperator 2021-05-02T03:00:12.045602+00:00 2021-05-02T03:00:15.094711+00:00 0:00:03.049109 23497 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-02T03:00:09.658572+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-02T01:00:00+00:00 EmrJobFlowSensor 2021-05-02T02:14:57.273176+00:00 2021-05-02T02:25:00.030850+00:00 0:10:02.757674 23496 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T02:14:54.957000+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-02T01:00:00+00:00 EmrJobFlowSensor 2021-05-02T02:14:47.038683+00:00 2021-05-02T02:23:49.653501+00:00 0:09:02.614818 23495 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T02:14:44.827955+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-02T01:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T02:14:37.034582+00:00 2021-05-02T02:14:38.744184+00:00 0:00:01.709602 23494 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-02T02:14:34.821188+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-02T01:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T02:14:25.091132+00:00 2021-05-02T02:14:26.750518+00:00 0:00:01.659386 23493 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-02T02:14:22.812106+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-02T01:00:00+00:00 PythonOperator 2021-05-02T02:14:15.049180+00:00 2021-05-02T02:14:18.267782+00:00 0:00:03.218602 23492 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T02:14:12.802207+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-02T01:00:00+00:00 PythonOperator 2021-05-02T02:14:03.039366+00:00 2021-05-02T02:14:06.097724+00:00 0:00:03.058358 23491 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T02:14:00.792404+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-02T01:00:00+00:00 TriggerDagRunOperator 2021-05-02T02:13:59.574732+00:00 2021-05-02T02:14:00.104813+00:00 0:00:00.530081 23490 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T02:13:56.856678+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-02T01:00:00+00:00 TriggerDagRunOperator 2021-05-02T02:13:59.409544+00:00 2021-05-02T02:13:59.826124+00:00 0:00:00.416580 23489 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T02:13:56.856720+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-02T01:05:00+00:00 EmrJobFlowSensor 2021-05-02T02:06:16.159034+00:00 2021-05-02T02:15:19.081892+00:00 0:09:02.922858 23488 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T02:06:13.965173+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-02T01:05:00+00:00 EmrCreateJobFlowOperator 2021-05-02T02:05:48.108710+00:00 2021-05-02T02:05:49.779904+00:00 0:00:01.671194 23487 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-02T02:05:45.929857+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-02T01:05:00+00:00 PythonOperator 2021-05-02T02:05:24.416940+00:00 2021-05-02T02:05:27.403967+00:00 0:00:02.987027 23486 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T02:05:21.973456+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-02T01:00:00+00:00 EmrJobFlowSensor 2021-05-02T02:04:42.091537+00:00 2021-05-02T02:13:44.775381+00:00 0:09:02.683844 23485 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T02:04:39.854711+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-02T01:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T02:04:22.119776+00:00 2021-05-02T02:04:23.825663+00:00 0:00:01.705887 23484 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-02T02:04:19.835133+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-02T01:00:00+00:00 PythonOperator 2021-05-02T02:04:00.421436+00:00 2021-05-02T02:04:03.457907+00:00 0:00:03.036471 23483 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-02T02:03:57.796170+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-02T00:00:00+00:00 EmrJobFlowSensor 2021-05-02T01:10:55.886887+00:00 2021-05-02T01:19:58.522969+00:00 0:09:02.636082 23481 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T01:10:53.627043+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-02T00:00:00+00:00 EmrJobFlowSensor 2021-05-02T01:10:49.801712+00:00 2021-05-02T01:20:52.537671+00:00 0:10:02.735959 23480 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T01:10:47.620766+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-02T00:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T01:10:36.004811+00:00 2021-05-02T01:10:37.669619+00:00 0:00:01.664808 23479 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-02T01:10:33.610533+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-02T00:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T01:10:25.846380+00:00 2021-05-02T01:10:27.729078+00:00 0:00:01.882698 23478 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-02T01:10:23.598611+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-02T00:00:00+00:00 PythonOperator 2021-05-02T01:10:05.855118+00:00 2021-05-02T01:10:08.884587+00:00 0:00:03.029469 23477 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T01:10:03.588592+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-02T00:00:00+00:00 PythonOperator 2021-05-02T01:10:00.307421+00:00 2021-05-02T01:10:03.579964+00:00 0:00:03.272543 23476 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T01:09:57.655121+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-02T00:00:00+00:00 TriggerDagRunOperator 2021-05-02T01:09:54.056003+00:00 2021-05-02T01:09:54.538329+00:00 0:00:00.482326 23475 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T01:09:51.565278+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-02T00:00:00+00:00 TriggerDagRunOperator 2021-05-02T01:09:54.001500+00:00 2021-05-02T01:09:54.597264+00:00 0:00:00.595764 23474 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T01:09:51.565231+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-02T00:05:00+00:00 EmrJobFlowSensor 2021-05-02T01:06:03.279297+00:00 2021-05-02T01:14:05.826664+00:00 0:08:02.547367 23473 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T01:06:00.997316+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-02T00:05:00+00:00 EmrCreateJobFlowOperator 2021-05-02T01:05:41.167409+00:00 2021-05-02T01:05:42.897502+00:00 0:00:01.730093 23472 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-02T01:05:38.962771+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-02T00:05:00+00:00 PythonOperator 2021-05-02T01:05:19.278029+00:00 2021-05-02T01:05:22.283522+00:00 0:00:03.005493 23471 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T01:05:16.932373+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-02T00:00:00+00:00 EmrJobFlowSensor 2021-05-02T01:00:46.696611+00:00 2021-05-02T01:09:49.460836+00:00 0:09:02.764225 23470 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T01:00:44.407042+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-02T00:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T01:00:24.722106+00:00 2021-05-02T01:00:26.480170+00:00 0:00:01.758064 23469 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-02T01:00:22.456371+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-02T00:00:00+00:00 PythonOperator 2021-05-02T01:00:04.875041+00:00 2021-05-02T01:00:08.122584+00:00 0:00:03.247543 23468 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-02T01:00:02.351138+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-01T23:00:00+00:00 EmrJobFlowSensor 2021-05-02T00:12:04.722835+00:00 2021-05-02T00:20:07.366951+00:00 0:08:02.644116 23466 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T00:12:02.113661+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-01T23:00:00+00:00 EmrJobFlowSensor 2021-05-02T00:11:24.741935+00:00 2021-05-02T00:20:27.294835+00:00 0:09:02.552900 23465 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T00:11:22.045914+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-01T23:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T00:10:58.554680+00:00 2021-05-02T00:11:00.389240+00:00 0:00:01.834560 23464 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-02T00:10:56.066753+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-01T23:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T00:10:50.493407+00:00 2021-05-02T00:10:52.290421+00:00 0:00:01.797014 23463 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-02T00:10:48.056681+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-01T23:00:00+00:00 PythonOperator 2021-05-02T00:10:36.511848+00:00 2021-05-02T00:10:39.560580+00:00 0:00:03.048732 23462 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T00:10:34.053788+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-01T23:00:00+00:00 PythonOperator 2021-05-02T00:10:30.589910+00:00 2021-05-02T00:10:33.881309+00:00 0:00:03.291399 23461 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T00:10:28.067278+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-01T23:00:00+00:00 TriggerDagRunOperator 2021-05-02T00:10:12.262163+00:00 2021-05-02T00:10:12.711175+00:00 0:00:00.449012 23460 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T00:10:09.920920+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-01T23:00:00+00:00 TriggerDagRunOperator 2021-05-02T00:10:12.209755+00:00 2021-05-02T00:10:12.844784+00:00 0:00:00.635029 23459 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T00:10:09.920981+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-01T23:05:00+00:00 EmrJobFlowSensor 2021-05-02T00:06:01.745736+00:00 2021-05-02T00:15:04.413923+00:00 0:09:02.668187 23458 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T00:05:59.561466+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-01T23:05:00+00:00 EmrCreateJobFlowOperator 2021-05-02T00:05:39.856549+00:00 2021-05-02T00:05:41.573110+00:00 0:00:01.716561 23457 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-02T00:05:37.543271+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-01T23:05:00+00:00 PythonOperator 2021-05-02T00:05:17.978498+00:00 2021-05-02T00:05:20.999564+00:00 0:00:03.021066 23456 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T00:05:15.581173+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-01T23:00:00+00:00 EmrJobFlowSensor 2021-05-02T00:00:57.425524+00:00 2021-05-02T00:10:00.163531+00:00 0:09:02.738007 23455 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T00:00:54.982712+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-01T23:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T00:00:37.360423+00:00 2021-05-02T00:00:39.112844+00:00 0:00:01.752421 23454 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-02T00:00:34.963561+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-01T23:00:00+00:00 PythonOperator 2021-05-02T00:00:15.368464+00:00 2021-05-02T00:00:18.469249+00:00 0:00:03.100785 23453 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-02T00:00:12.876837+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-01T22:00:00+00:00 EmrJobFlowSensor 2021-05-01T23:13:34.194875+00:00 2021-05-01T23:22:36.873992+00:00 0:09:02.679117 23451 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T23:13:31.843359+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-01T22:00:00+00:00 EmrJobFlowSensor 2021-05-01T23:12:24.050654+00:00 2021-05-01T23:21:26.715266+00:00 0:09:02.664612 23450 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T23:12:21.740075+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-01T22:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T23:12:11.926746+00:00 2021-05-01T23:12:13.770210+00:00 0:00:01.843464 23449 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-01T23:12:09.732715+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-01T22:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T23:11:58.204791+00:00 2021-05-01T23:11:59.980760+00:00 0:00:01.775969 23448 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-01T23:11:55.737096+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-01T22:00:00+00:00 PythonOperator 2021-05-01T23:11:40.822013+00:00 2021-05-01T23:11:44.434072+00:00 0:00:03.612059 23447 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T23:11:37.773584+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-01T22:00:00+00:00 PythonOperator 2021-05-01T23:11:36.264331+00:00 2021-05-01T23:11:39.918762+00:00 0:00:03.654431 23446 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T23:11:33.770468+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-01T22:00:00+00:00 TriggerDagRunOperator 2021-05-01T23:11:22.142947+00:00 2021-05-01T23:11:22.569139+00:00 0:00:00.426192 23445 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T23:11:19.691140+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-01T22:00:00+00:00 TriggerDagRunOperator 2021-05-01T23:11:21.909499+00:00 2021-05-01T23:11:22.451576+00:00 0:00:00.542077 23444 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T23:11:19.691108+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-01T22:05:00+00:00 EmrJobFlowSensor 2021-05-01T23:06:07.484500+00:00 2021-05-01T23:15:10.056630+00:00 0:09:02.572130 23443 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T23:06:05.251772+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-01T22:05:00+00:00 EmrCreateJobFlowOperator 2021-05-01T23:05:45.435458+00:00 2021-05-01T23:05:47.155498+00:00 0:00:01.720040 23442 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-01T23:05:43.196448+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-01T22:05:00+00:00 PythonOperator 2021-05-01T23:05:23.314399+00:00 2021-05-01T23:05:26.332728+00:00 0:00:03.018329 23441 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T23:05:21.128795+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-04-30T23:00:00+00:00 EmrJobFlowSensor 2021-05-01T23:00:58.886146+00:00 2021-05-01T23:10:01.549534+00:00 0:09:02.663388 23440 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T23:00:56.615100+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-01T22:00:00+00:00 EmrJobFlowSensor 2021-05-01T23:00:56.870296+00:00 2021-05-01T23:10:59.657018+00:00 0:10:02.786722 23439 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T23:00:54.604995+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-04-30T23:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T23:00:38.830770+00:00 2021-05-01T23:00:40.561235+00:00 0:00:01.730465 23438 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-01T23:00:36.586616+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-01T22:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T23:00:36.929622+00:00 2021-05-01T23:00:38.667094+00:00 0:00:01.737472 23437 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-01T23:00:34.585269+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-04-30T23:00:00+00:00 PythonOperator 2021-05-01T23:00:16.745847+00:00 2021-05-01T23:00:19.865840+00:00 0:00:03.119993 23436 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T23:00:14.507376+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-01T22:00:00+00:00 PythonOperator 2021-05-01T23:00:14.932444+00:00 2021-05-01T23:00:18.041418+00:00 0:00:03.108974 23435 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-01T23:00:12.501072+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-01T21:00:00+00:00 EmrJobFlowSensor 2021-05-01T22:11:21.650599+00:00 2021-05-01T22:20:24.341259+00:00 0:09:02.690660 23433 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T22:11:19.283995+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-01T21:00:00+00:00 EmrJobFlowSensor 2021-05-01T22:11:13.638088+00:00 2021-05-01T22:21:16.434895+00:00 0:10:02.796807 23432 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T22:11:11.252476+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-01T21:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T22:10:59.550785+00:00 2021-05-01T22:11:01.306310+00:00 0:00:01.755525 23431 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-01T22:10:57.245276+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-01T21:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T22:10:53.658609+00:00 2021-05-01T22:10:55.402268+00:00 0:00:01.743659 23430 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-01T22:10:51.236749+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-01T21:00:00+00:00 PythonOperator 2021-05-01T22:10:39.966392+00:00 2021-05-01T22:10:43.222151+00:00 0:00:03.255759 23429 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T22:10:37.225834+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-01T21:00:00+00:00 PythonOperator 2021-05-01T22:10:31.583694+00:00 2021-05-01T22:10:34.670841+00:00 0:00:03.087147 23428 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T22:10:29.345230+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-01T21:00:00+00:00 TriggerDagRunOperator 2021-05-01T22:10:15.898805+00:00 2021-05-01T22:10:16.405522+00:00 0:00:00.506717 23427 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T22:10:13.262831+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-01T21:00:00+00:00 TriggerDagRunOperator 2021-05-01T22:10:15.764363+00:00 2021-05-01T22:10:16.178895+00:00 0:00:00.414532 23426 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T22:10:13.262861+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-01T21:05:00+00:00 EmrJobFlowSensor 2021-05-01T22:06:01.088302+00:00 2021-05-01T22:15:03.719274+00:00 0:09:02.630972 23425 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T22:05:58.767621+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-01T21:05:00+00:00 EmrCreateJobFlowOperator 2021-05-01T22:05:39.168057+00:00 2021-05-01T22:05:40.943566+00:00 0:00:01.775509 23424 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-01T22:05:36.744191+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-01T21:05:00+00:00 PythonOperator 2021-05-01T22:05:16.751127+00:00 2021-05-01T22:05:19.820597+00:00 0:00:03.069470 23423 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T22:05:14.559786+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-01T21:00:00+00:00 EmrJobFlowSensor 2021-05-01T22:00:56.407961+00:00 2021-05-01T22:09:59.207368+00:00 0:09:02.799407 23422 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T22:00:54.151915+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-01T21:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T22:00:26.355676+00:00 2021-05-01T22:00:28.084861+00:00 0:00:01.729185 23421 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-01T22:00:24.127864+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-01T21:00:00+00:00 PythonOperator 2021-05-01T22:00:04.871193+00:00 2021-05-01T22:00:08.054843+00:00 0:00:03.183650 23420 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-01T22:00:02.143546+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-01T20:00:00+00:00 EmrJobFlowSensor 2021-05-01T21:11:30.852426+00:00 2021-05-01T21:21:33.692262+00:00 0:10:02.839836 23418 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T21:11:28.361608+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-01T20:00:00+00:00 EmrJobFlowSensor 2021-05-01T21:11:22.538916+00:00 2021-05-01T21:20:25.239989+00:00 0:09:02.701073 23417 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T21:11:20.246393+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-01T20:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T21:11:10.520199+00:00 2021-05-01T21:11:12.381521+00:00 0:00:01.861322 23416 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-01T21:11:08.233270+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-01T20:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T21:11:00.908295+00:00 2021-05-01T21:11:02.757917+00:00 0:00:01.849622 23415 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-01T21:10:58.258166+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-01T20:00:00+00:00 PythonOperator 2021-05-01T21:10:44.672590+00:00 2021-05-01T21:10:48.005657+00:00 0:00:03.333067 23414 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T21:10:42.123610+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-01T20:00:00+00:00 PythonOperator 2021-05-01T21:10:34.485518+00:00 2021-05-01T21:10:37.526865+00:00 0:00:03.041347 23413 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T21:10:32.111085+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-01T20:00:00+00:00 TriggerDagRunOperator 2021-05-01T21:10:16.787915+00:00 2021-05-01T21:10:17.212493+00:00 0:00:00.424578 23412 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T21:10:14.101531+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-01T20:00:00+00:00 TriggerDagRunOperator 2021-05-01T21:10:16.525392+00:00 2021-05-01T21:10:17.068141+00:00 0:00:00.542749 23411 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T21:10:14.101496+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-01T20:05:00+00:00 EmrJobFlowSensor 2021-05-01T21:05:57.896395+00:00 2021-05-01T21:15:00.579665+00:00 0:09:02.683270 23410 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T21:05:55.640226+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-01T20:05:00+00:00 EmrCreateJobFlowOperator 2021-05-01T21:05:36.120543+00:00 2021-05-01T21:05:37.769030+00:00 0:00:01.648487 23409 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-01T21:05:33.682532+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-01T20:05:00+00:00 PythonOperator 2021-05-01T21:05:16.079096+00:00 2021-05-01T21:05:19.037310+00:00 0:00:02.958214 23408 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T21:05:13.657161+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-01T20:00:00+00:00 EmrJobFlowSensor 2021-05-01T21:01:07.519954+00:00 2021-05-01T21:10:10.241430+00:00 0:09:02.721476 23407 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T21:01:05.191841+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-01T20:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T21:00:45.379186+00:00 2021-05-01T21:00:47.131644+00:00 0:00:01.752458 23406 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-01T21:00:43.096761+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-01T20:00:00+00:00 PythonOperator 2021-05-01T21:00:25.321271+00:00 2021-05-01T21:00:28.392797+00:00 0:00:03.071526 23405 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-01T21:00:23.030647+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-01T19:00:00+00:00 EmrJobFlowSensor 2021-05-01T20:12:16.926369+00:00 2021-05-01T20:21:19.486783+00:00 0:09:02.560414 23403 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T20:12:14.685922+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-01T19:00:00+00:00 EmrJobFlowSensor 2021-05-01T20:12:01.248999+00:00 2021-05-01T20:21:04.031613+00:00 0:09:02.782614 23402 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T20:11:58.753809+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-01T19:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T20:11:56.757293+00:00 2021-05-01T20:11:58.508288+00:00 0:00:01.750995 23401 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-01T20:11:54.586567+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-01T19:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T20:11:40.795987+00:00 2021-05-01T20:11:42.515291+00:00 0:00:01.719304 23400 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-01T20:11:38.537463+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-01T19:00:00+00:00 PythonOperator 2021-05-01T20:11:34.830745+00:00 2021-05-01T20:11:38.208848+00:00 0:00:03.378103 23399 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T20:11:32.533308+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-01T19:00:00+00:00 PythonOperator 2021-05-01T20:11:19.373304+00:00 2021-05-01T20:11:22.406740+00:00 0:00:03.033436 23398 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T20:11:16.575566+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-01T19:00:00+00:00 TriggerDagRunOperator 2021-05-01T20:11:11.127306+00:00 2021-05-01T20:11:11.662335+00:00 0:00:00.535029 23397 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T20:11:08.574738+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-01T19:00:00+00:00 TriggerDagRunOperator 2021-05-01T20:11:11.040173+00:00 2021-05-01T20:11:11.493611+00:00 0:00:00.453438 23396 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T20:11:08.574783+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-01T19:05:00+00:00 EmrJobFlowSensor 2021-05-01T20:05:58.199354+00:00 2021-05-01T20:15:00.864836+00:00 0:09:02.665482 23395 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T20:05:56.009800+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-01T19:05:00+00:00 EmrCreateJobFlowOperator 2021-05-01T20:05:36.354180+00:00 2021-05-01T20:05:38.034557+00:00 0:00:01.680377 23394 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-01T20:05:34.081812+00:00 2 default_pool