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 create_cluster_and_add_emr_steps 2021-04-29T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T05:00:30.450782+00:00 2021-04-29T05:00:32.247519+00:00 0:00:01.796737 22442 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-29T05:00:28.046327+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-29T04:00:00+00:00 PythonOperator 2021-04-29T05:00:08.833251+00:00 2021-04-29T05:00:11.948831+00:00 0:00:03.115580 22441 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-29T05:00:06.067456+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-29T03:00:00+00:00 EmrJobFlowSensor 2021-04-29T04:11:25.656974+00:00 2021-04-29T04:21:28.516088+00:00 0:10:02.859114 22439 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T04:11:23.296120+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-29T03:00:00+00:00 EmrJobFlowSensor 2021-04-29T04:11:21.532969+00:00 2021-04-29T04:20:24.219818+00:00 0:09:02.686849 22438 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T04:11:19.298971+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-29T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T04:11:03.576232+00:00 2021-04-29T04:11:05.300458+00:00 0:00:01.724226 22437 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-29T04:11:01.218649+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-29T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T04:10:57.786434+00:00 2021-04-29T04:10:59.581372+00:00 0:00:01.794938 22436 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-29T04:10:55.354217+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-29T03:00:00+00:00 PythonOperator 2021-04-29T04:10:41.690906+00:00 2021-04-29T04:10:44.953262+00:00 0:00:03.262356 22435 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T04:10:39.256116+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-29T03:00:00+00:00 PythonOperator 2021-04-29T04:10:37.816141+00:00 2021-04-29T04:10:40.845274+00:00 0:00:03.029133 22434 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T04:10:35.347597+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-29T03:00:00+00:00 TriggerDagRunOperator 2021-04-29T04:10:17.763170+00:00 2021-04-29T04:10:18.204780+00:00 0:00:00.441610 22433 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T04:10:15.258429+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-29T03:00:00+00:00 TriggerDagRunOperator 2021-04-29T04:10:17.746020+00:00 2021-04-29T04:10:18.346501+00:00 0:00:00.600481 22432 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T04:10:15.258477+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-29T03:05:00+00:00 EmrJobFlowSensor 2021-04-29T04:06:05.248664+00:00 2021-04-29T04:15:07.825580+00:00 0:09:02.576916 22431 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T04:06:02.653306+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-29T03:05:00+00:00 EmrCreateJobFlowOperator 2021-04-29T04:05:42.881706+00:00 2021-04-29T04:05:44.629212+00:00 0:00:01.747506 22430 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-29T04:05:40.517606+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-29T03:05:00+00:00 PythonOperator 2021-04-29T04:05:21.019685+00:00 2021-04-29T04:05:23.996648+00:00 0:00:02.976963 22429 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T04:05:18.641457+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-29T03:00:00+00:00 EmrJobFlowSensor 2021-04-29T04:01:00.509129+00:00 2021-04-29T04:10:03.378298+00:00 0:09:02.869169 22428 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T04:00:58.140915+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-29T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T04:00:38.215372+00:00 2021-04-29T04:00:39.952222+00:00 0:00:01.736850 22427 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-29T04:00:35.949080+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-29T03:00:00+00:00 PythonOperator 2021-04-29T04:00:18.857173+00:00 2021-04-29T04:00:21.922986+00:00 0:00:03.065813 22426 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-29T04:00:15.928552+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-29T02:00:00+00:00 EmrJobFlowSensor 2021-04-29T03:24:11.845728+00:00 2021-04-29T03:24:13.310555+00:00 0:00:01.464827 22424 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T03:24:09.623770+00:00 3 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-29T02:00:00+00:00 EmrJobFlowSensor 2021-04-29T03:11:26.665857+00:00 2021-04-29T03:29:30.556866+00:00 0:18:03.891009 22423 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T03:11:24.359263+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-29T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T03:11:04.873756+00:00 2021-04-29T03:11:06.688266+00:00 0:00:01.814510 22421 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-29T03:11:02.372168+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-29T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T03:11:00.811725+00:00 2021-04-29T03:11:02.548598+00:00 0:00:01.736873 22420 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-29T03:10:58.259958+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-29T02:00:00+00:00 PythonOperator 2021-04-29T03:10:42.335048+00:00 2021-04-29T03:10:45.415563+00:00 0:00:03.080515 22419 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T03:10:40.118158+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-29T02:00:00+00:00 PythonOperator 2021-04-29T03:10:38.861073+00:00 2021-04-29T03:10:42.083971+00:00 0:00:03.222898 22418 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T03:10:36.179045+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-29T02:00:00+00:00 TriggerDagRunOperator 2021-04-29T03:10:24.567305+00:00 2021-04-29T03:10:25.036453+00:00 0:00:00.469148 22417 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T03:10:22.104536+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-29T02:00:00+00:00 TriggerDagRunOperator 2021-04-29T03:10:24.512487+00:00 2021-04-29T03:10:25.106851+00:00 0:00:00.594364 22416 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T03:10:22.104504+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-29T02:05:00+00:00 EmrJobFlowSensor 2021-04-29T03:06:05.973637+00:00 2021-04-29T03:15:08.505275+00:00 0:09:02.531638 22415 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T03:06:03.694602+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-29T02:05:00+00:00 EmrCreateJobFlowOperator 2021-04-29T03:05:43.906726+00:00 2021-04-29T03:05:45.630667+00:00 0:00:01.723941 22414 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-29T03:05:41.625689+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-29T02:05:00+00:00 PythonOperator 2021-04-29T03:05:21.756781+00:00 2021-04-29T03:05:24.698147+00:00 0:00:02.941366 22413 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T03:05:19.600871+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-29T02:00:00+00:00 EmrJobFlowSensor 2021-04-29T03:01:01.664046+00:00 2021-04-29T03:10:04.499782+00:00 0:09:02.835736 22412 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T03:00:59.278425+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-29T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T03:00:39.856141+00:00 2021-04-29T03:00:41.673622+00:00 0:00:01.817481 22411 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-29T03:00:37.260818+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-29T02:00:00+00:00 PythonOperator 2021-04-29T03:00:19.591349+00:00 2021-04-29T03:00:22.716892+00:00 0:00:03.125543 22410 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-29T03:00:17.155624+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-29T01:00:00+00:00 EmrJobFlowSensor 2021-04-29T02:11:21.531942+00:00 2021-04-29T02:21:24.491531+00:00 0:10:02.959589 22408 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T02:11:19.339693+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-29T01:00:00+00:00 EmrJobFlowSensor 2021-04-29T02:11:03.819972+00:00 2021-04-29T02:23:06.855452+00:00 0:12:03.035480 22407 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T02:11:01.371037+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-29T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T02:10:59.897126+00:00 2021-04-29T02:11:01.777262+00:00 0:00:01.880136 22406 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-29T02:10:57.359981+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-29T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T02:10:41.420572+00:00 2021-04-29T02:10:43.217320+00:00 0:00:01.796748 22405 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-29T02:10:39.230415+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-29T01:00:00+00:00 PythonOperator 2021-04-29T02:10:39.577157+00:00 2021-04-29T02:10:42.643850+00:00 0:00:03.066693 22404 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T02:10:37.236448+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-29T01:00:00+00:00 PythonOperator 2021-04-29T02:10:21.828414+00:00 2021-04-29T02:10:25.072744+00:00 0:00:03.244330 22403 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T02:10:19.208243+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-29T01:00:00+00:00 TriggerDagRunOperator 2021-04-29T02:10:13.662395+00:00 2021-04-29T02:10:14.183841+00:00 0:00:00.521446 22402 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T02:10:11.203350+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-29T01:00:00+00:00 TriggerDagRunOperator 2021-04-29T02:10:13.594947+00:00 2021-04-29T02:10:14.039977+00:00 0:00:00.445030 22401 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T02:10:11.203324+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-29T01:05:00+00:00 EmrJobFlowSensor 2021-04-29T02:06:02.924858+00:00 2021-04-29T02:16:05.703518+00:00 0:10:02.778660 22400 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T02:06:00.683114+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-29T01:05:00+00:00 EmrCreateJobFlowOperator 2021-04-29T02:05:40.957732+00:00 2021-04-29T02:05:42.629469+00:00 0:00:01.671737 22399 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-29T02:05:38.669334+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-29T01:05:00+00:00 PythonOperator 2021-04-29T02:05:13.036063+00:00 2021-04-29T02:05:15.987521+00:00 0:00:02.951458 22398 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T02:05:10.591494+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-29T01:00:00+00:00 EmrJobFlowSensor 2021-04-29T02:01:00.431049+00:00 2021-04-29T02:10:03.090852+00:00 0:09:02.659803 22397 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T02:00:58.194339+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-29T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T02:00:38.317780+00:00 2021-04-29T02:00:40.050290+00:00 0:00:01.732510 22396 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-29T02:00:36.131606+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-29T01:00:00+00:00 PythonOperator 2021-04-29T02:00:16.943499+00:00 2021-04-29T02:00:19.969561+00:00 0:00:03.026062 22395 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-29T02:00:14.245582+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-29T00:00:00+00:00 EmrJobFlowSensor 2021-04-29T01:12:36.271517+00:00 2021-04-29T01:22:39.187540+00:00 0:10:02.916023 22393 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T01:12:33.414671+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-29T00:00:00+00:00 EmrJobFlowSensor 2021-04-29T01:12:33.820904+00:00 2021-04-29T01:25:37.368711+00:00 0:13:03.547807 22392 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T01:12:31.413293+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-29T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T01:12:12.332220+00:00 2021-04-29T01:12:14.009677+00:00 0:00:01.677457 22391 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-29T01:12:09.462000+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-29T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T01:12:10.011480+00:00 2021-04-29T01:12:12.066619+00:00 0:00:02.055139 22390 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-29T01:12:07.476013+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-29T00:00:00+00:00 PythonOperator 2021-04-29T01:11:51.586548+00:00 2021-04-29T01:11:54.706827+00:00 0:00:03.120279 22389 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T01:11:49.335156+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-29T00:00:00+00:00 PythonOperator 2021-04-29T01:11:49.868404+00:00 2021-04-29T01:11:53.095170+00:00 0:00:03.226766 22388 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T01:11:47.344620+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-29T00:00:00+00:00 TriggerDagRunOperator 2021-04-29T01:11:30.209430+00:00 2021-04-29T01:11:30.609021+00:00 0:00:00.399591 22387 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T01:11:27.321608+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-29T00:00:00+00:00 TriggerDagRunOperator 2021-04-29T01:11:29.848406+00:00 2021-04-29T01:11:30.408913+00:00 0:00:00.560507 22386 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T01:11:27.321574+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-29T00:05:00+00:00 EmrJobFlowSensor 2021-04-29T01:05:48.981978+00:00 2021-04-29T01:14:51.507736+00:00 0:09:02.525758 22385 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T01:05:46.656071+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-29T00:05:00+00:00 EmrCreateJobFlowOperator 2021-04-29T01:05:28.845258+00:00 2021-04-29T01:05:30.571752+00:00 0:00:01.726494 22384 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-29T01:05:26.562074+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-29T00:05:00+00:00 PythonOperator 2021-04-29T01:05:06.717834+00:00 2021-04-29T01:05:09.695359+00:00 0:00:02.977525 22383 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T01:05:04.550037+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-29T00:00:00+00:00 EmrJobFlowSensor 2021-04-29T01:01:18.430707+00:00 2021-04-29T01:11:21.199471+00:00 0:10:02.768764 22382 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T01:01:16.237245+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-29T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T01:00:56.391345+00:00 2021-04-29T01:00:58.103852+00:00 0:00:01.712507 22381 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-29T01:00:54.205073+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-29T00:00:00+00:00 PythonOperator 2021-04-29T01:00:33.036015+00:00 2021-04-29T01:00:36.064708+00:00 0:00:03.028693 22380 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-29T01:00:30.187129+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-28T23:00:00+00:00 EmrJobFlowSensor 2021-04-29T00:10:57.772841+00:00 2021-04-29T00:20:00.387726+00:00 0:09:02.614885 22378 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T00:10:55.404154+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-28T23:00:00+00:00 EmrJobFlowSensor 2021-04-29T00:10:53.921588+00:00 2021-04-29T00:20:56.743415+00:00 0:10:02.821827 22377 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T00:10:51.461051+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-28T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T00:10:37.515060+00:00 2021-04-29T00:10:39.213930+00:00 0:00:01.698870 22376 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-29T00:10:35.387519+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-28T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T00:10:33.634845+00:00 2021-04-29T00:10:35.314367+00:00 0:00:01.679522 22375 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-29T00:10:31.391241+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-28T23:00:00+00:00 PythonOperator 2021-04-29T00:10:16.057851+00:00 2021-04-29T00:10:19.570007+00:00 0:00:03.512156 22374 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T00:10:13.278679+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-28T23:00:00+00:00 PythonOperator 2021-04-29T00:10:11.384849+00:00 2021-04-29T00:10:15.211254+00:00 0:00:03.826405 22373 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T00:10:09.276025+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-28T23:00:00+00:00 TriggerDagRunOperator 2021-04-29T00:10:01.823562+00:00 2021-04-29T00:10:02.357007+00:00 0:00:00.533445 22372 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T00:09:59.269551+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-28T23:00:00+00:00 TriggerDagRunOperator 2021-04-29T00:10:01.766625+00:00 2021-04-29T00:10:02.220190+00:00 0:00:00.453565 22371 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T00:09:59.269627+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-28T23:05:00+00:00 EmrJobFlowSensor 2021-04-29T00:06:04.962499+00:00 2021-04-29T00:14:07.503210+00:00 0:08:02.540711 22370 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T00:06:02.641071+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-28T23:05:00+00:00 EmrCreateJobFlowOperator 2021-04-29T00:05:42.768041+00:00 2021-04-29T00:05:44.431368+00:00 0:00:01.663327 22369 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-29T00:05:40.595742+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-28T23:05:00+00:00 PythonOperator 2021-04-29T00:05:20.777252+00:00 2021-04-29T00:05:23.793879+00:00 0:00:03.016627 22368 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T00:05:18.574887+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-28T23:00:00+00:00 EmrJobFlowSensor 2021-04-29T00:00:48.822793+00:00 2021-04-29T00:09:51.586009+00:00 0:09:02.763216 22367 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T00:00:46.302672+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-28T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T00:00:26.666218+00:00 2021-04-29T00:00:28.375560+00:00 0:00:01.709342 22366 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-29T00:00:24.349989+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-28T23:00:00+00:00 PythonOperator 2021-04-29T00:00:04.796950+00:00 2021-04-29T00:00:07.872603+00:00 0:00:03.075653 22365 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-29T00:00:02.244450+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-28T22:00:00+00:00 EmrJobFlowSensor 2021-04-28T23:12:31.516513+00:00 2021-04-28T23:21:34.087915+00:00 0:09:02.571402 22363 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T23:12:29.290814+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-28T22:00:00+00:00 EmrJobFlowSensor 2021-04-28T23:12:13.388403+00:00 2021-04-28T23:21:16.001629+00:00 0:09:02.613226 22362 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T23:12:11.197638+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-28T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T23:12:09.506189+00:00 2021-04-28T23:12:11.239401+00:00 0:00:01.733212 22361 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T23:12:07.196397+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-28T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T23:11:53.370917+00:00 2021-04-28T23:11:55.173300+00:00 0:00:01.802383 22360 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T23:11:51.113147+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-28T22:00:00+00:00 PythonOperator 2021-04-28T23:11:47.300437+00:00 2021-04-28T23:11:50.341806+00:00 0:00:03.041369 22359 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T23:11:45.113766+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-28T22:00:00+00:00 PythonOperator 2021-04-28T23:11:31.715794+00:00 2021-04-28T23:11:35.044845+00:00 0:00:03.329051 22358 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T23:11:29.094640+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-28T22:00:00+00:00 TriggerDagRunOperator 2021-04-28T23:11:23.800347+00:00 2021-04-28T23:11:24.368562+00:00 0:00:00.568215 22357 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T23:11:21.163223+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-28T22:00:00+00:00 TriggerDagRunOperator 2021-04-28T23:11:23.591770+00:00 2021-04-28T23:11:24.045998+00:00 0:00:00.454228 22356 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T23:11:21.163174+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-28T22:05:00+00:00 EmrJobFlowSensor 2021-04-28T23:06:00.899949+00:00 2021-04-28T23:15:03.443148+00:00 0:09:02.543199 22355 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T23:05:58.654225+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-28T22:05:00+00:00 EmrCreateJobFlowOperator 2021-04-28T23:05:35.152671+00:00 2021-04-28T23:05:36.844794+00:00 0:00:01.692123 22354 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T23:05:32.644493+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-28T22:05:00+00:00 PythonOperator 2021-04-28T23:05:12.698296+00:00 2021-04-28T23:05:15.641330+00:00 0:00:02.943034 22353 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T23:05:10.494670+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-04-27T23:00:00+00:00 EmrJobFlowSensor 2021-04-28T23:00:58.553293+00:00 2021-04-28T23:10:01.086574+00:00 0:09:02.533281 22352 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T23:00:56.159320+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-28T22:00:00+00:00 EmrJobFlowSensor 2021-04-28T23:00:48.370749+00:00 2021-04-28T23:10:51.080548+00:00 0:10:02.709799 22351 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T23:00:46.159748+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-04-27T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T23:00:38.286870+00:00 2021-04-28T23:00:39.998672+00:00 0:00:01.711802 22350 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T23:00:36.116472+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-28T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T23:00:26.287739+00:00 2021-04-28T23:00:27.996923+00:00 0:00:01.709184 22349 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-28T23:00:24.103725+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-04-27T23:00:00+00:00 PythonOperator 2021-04-28T23:00:16.394811+00:00 2021-04-28T23:00:19.425611+00:00 0:00:03.030800 22348 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T23:00:14.111766+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-28T22:00:00+00:00 PythonOperator 2021-04-28T23:00:04.892905+00:00 2021-04-28T23:00:08.040029+00:00 0:00:03.147124 22347 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-28T23:00:02.098555+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-28T21:00:00+00:00 EmrJobFlowSensor 2021-04-28T22:10:25.500318+00:00 2021-04-28T22:19:28.149276+00:00 0:09:02.648958 22345 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T22:10:23.078213+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-28T21:00:00+00:00 EmrJobFlowSensor 2021-04-28T22:10:21.242681+00:00 2021-04-28T22:20:24.248406+00:00 0:10:03.005725 22344 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T22:10:19.075830+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-28T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T22:10:05.334525+00:00 2021-04-28T22:10:07.077058+00:00 0:00:01.742533 22343 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T22:10:03.060629+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-28T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T22:10:01.289095+00:00 2021-04-28T22:10:03.117541+00:00 0:00:01.828446 22342 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T22:09:59.081776+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-28T21:00:00+00:00 PythonOperator 2021-04-28T22:09:41.408225+00:00 2021-04-28T22:09:44.426480+00:00 0:00:03.018255 22341 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T22:09:39.053191+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-28T21:00:00+00:00 PythonOperator 2021-04-28T22:09:39.284429+00:00 2021-04-28T22:09:42.592423+00:00 0:00:03.307994 22340 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T22:09:37.053031+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-28T21:00:00+00:00 TriggerDagRunOperator 2021-04-28T22:09:29.385294+00:00 2021-04-28T22:09:29.917702+00:00 0:00:00.532408 22339 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T22:09:26.934028+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-28T21:00:00+00:00 TriggerDagRunOperator 2021-04-28T22:09:29.243868+00:00 2021-04-28T22:09:29.662989+00:00 0:00:00.419121 22338 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T22:09:26.934060+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-28T21:05:00+00:00 EmrJobFlowSensor 2021-04-28T22:06:06.880965+00:00 2021-04-28T22:15:09.668994+00:00 0:09:02.788029 22337 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T22:06:04.712756+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-28T21:05:00+00:00 EmrCreateJobFlowOperator 2021-04-28T22:05:42.808335+00:00 2021-04-28T22:05:44.443006+00:00 0:00:01.634671 22336 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T22:05:40.540760+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-28T21:05:00+00:00 PythonOperator 2021-04-28T22:05:12.764134+00:00 2021-04-28T22:05:15.724390+00:00 0:00:02.960256 22335 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T22:05:10.516992+00:00 2 default_pool