Task Instances

  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-29T06:05:00+00:00 EmrCreateJobFlowOperator 2021-04-29T07:05:41.262094+00:00 2021-04-29T07:05:42.995458+00:00 0:00:01.733364 22475 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-29T07:05:38.943539+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-29T06:05:00+00:00 PythonOperator 2021-04-29T07:05:20.981798+00:00 2021-04-29T07:05:24.097468+00:00 0:00:03.115670 22474 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T07:05:18.800091+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-29T06:00:00+00:00 EmrJobFlowSensor 2021-04-29T07:00:54.664120+00:00 2021-04-29T07:09:57.277350+00:00 0:09:02.613230 22473 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T07:00:52.307109+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-29T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T07:00:34.524251+00:00 2021-04-29T07:00:36.242996+00:00 0:00:01.718745 22472 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-29T07:00:32.284110+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-29T06:00:00+00:00 PythonOperator 2021-04-29T07:00:10.660398+00:00 2021-04-29T07:00:13.716611+00:00 0:00:03.056213 22471 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-29T07:00:08.211717+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-29T05:00:00+00:00 EmrJobFlowSensor 2021-04-29T06:12:32.102295+00:00 2021-04-29T06:21:34.653626+00:00 0:09:02.551331 22469 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T06:12:29.653512+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-29T05:00:00+00:00 EmrJobFlowSensor 2021-04-29T06:12:18.482846+00:00 2021-04-29T06:22:21.236327+00:00 0:10:02.753481 22468 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T06:12:15.495196+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-29T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T06:12:09.808455+00:00 2021-04-29T06:12:11.515675+00:00 0:00:01.707220 22467 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-29T06:12:07.493711+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-29T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T06:11:57.697635+00:00 2021-04-29T06:11:59.474142+00:00 0:00:01.776507 22466 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-29T06:11:55.423535+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-29T05:00:00+00:00 PythonOperator 2021-04-29T06:11:48.129259+00:00 2021-04-29T06:11:51.172834+00:00 0:00:03.043575 22465 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T06:11:45.466805+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-29T05:00:00+00:00 PythonOperator 2021-04-29T06:11:35.958975+00:00 2021-04-29T06:11:39.273016+00:00 0:00:03.314041 22464 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T06:11:33.403299+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-29T05:00:00+00:00 TriggerDagRunOperator 2021-04-29T06:11:30.231899+00:00 2021-04-29T06:11:30.758564+00:00 0:00:00.526665 22463 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T06:11:27.456389+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-29T05:00:00+00:00 TriggerDagRunOperator 2021-04-29T06:11:30.019030+00:00 2021-04-29T06:11:30.461869+00:00 0:00:00.442839 22462 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T06:11:27.456343+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-29T05:05:00+00:00 EmrJobFlowSensor 2021-04-29T06:06:05.300604+00:00 2021-04-29T06:15:07.951336+00:00 0:09:02.650732 22461 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T06:06:02.946883+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-29T05:05:00+00:00 EmrCreateJobFlowOperator 2021-04-29T06:05:43.196431+00:00 2021-04-29T06:05:44.915006+00:00 0:00:01.718575 22460 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-29T06:05:40.863893+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-29T05:05:00+00:00 PythonOperator 2021-04-29T06:05:21.176898+00:00 2021-04-29T06:05:24.175706+00:00 0:00:02.998808 22459 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T06:05:18.843408+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-29T05:00:00+00:00 EmrJobFlowSensor 2021-04-29T06:01:04.886341+00:00 2021-04-29T06:11:07.881551+00:00 0:10:02.995210 22458 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T06:01:02.393014+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-29T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T06:00:42.537348+00:00 2021-04-29T06:00:44.243857+00:00 0:00:01.706509 22457 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-29T06:00:40.329412+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-29T05:00:00+00:00 PythonOperator 2021-04-29T06:00:20.738197+00:00 2021-04-29T06:00:23.776179+00:00 0:00:03.037982 22456 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-29T06:00:18.313674+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-29T04:00:00+00:00 EmrJobFlowSensor 2021-04-29T05:11:31.827018+00:00 2021-04-29T05:20:34.454772+00:00 0:09:02.627754 22454 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T05:11:29.262040+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-29T04:00:00+00:00 EmrJobFlowSensor 2021-04-29T05:11:27.398259+00:00 2021-04-29T05:21:30.207435+00:00 0:10:02.809176 22453 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T05:11:25.105631+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-29T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T05:11:11.341825+00:00 2021-04-29T05:11:13.181511+00:00 0:00:01.839686 22452 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-29T05:11:09.090129+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-29T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-29T05:11:05.369661+00:00 2021-04-29T05:11:07.064445+00:00 0:00:01.694784 22451 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-29T05:11:03.099841+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-29T04:00:00+00:00 PythonOperator 2021-04-29T05:10:49.372423+00:00 2021-04-29T05:10:52.437513+00:00 0:00:03.065090 22450 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T05:10:47.070459+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-29T04:00:00+00:00 PythonOperator 2021-04-29T05:10:43.458909+00:00 2021-04-29T05:10:46.732414+00:00 0:00:03.273505 22449 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T05:10:41.066511+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-29T04:00:00+00:00 TriggerDagRunOperator 2021-04-29T05:10:19.407075+00:00 2021-04-29T05:10:19.933549+00:00 0:00:00.526474 22448 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T05:10:17.045343+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-29T04:00:00+00:00 TriggerDagRunOperator 2021-04-29T05:10:19.333445+00:00 2021-04-29T05:10:19.750651+00:00 0:00:00.417206 22447 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T05:10:17.045310+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-29T04:05:00+00:00 EmrJobFlowSensor 2021-04-29T05:06:11.039894+00:00 2021-04-29T05:14:13.576095+00:00 0:08:02.536201 22446 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-29T05:06:08.742466+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-29T04:05:00+00:00 EmrCreateJobFlowOperator 2021-04-29T05:05:42.811505+00:00 2021-04-29T05:05:44.509466+00:00 0:00:01.697961 22445 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-29T05:05:40.594468+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-29T04:05:00+00:00 PythonOperator 2021-04-29T05:05:20.783640+00:00 2021-04-29T05:05:23.763060+00:00 0:00:02.979420 22444 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T05:05:18.521683+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-29T04:00:00+00:00 EmrJobFlowSensor 2021-04-29T05:00:54.443086+00:00 2021-04-29T05:09:57.095026+00:00 0:09:02.651940 22443 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-29T05:00:52.040656+00:00 2 default_pool
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