Task Instances

  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success campaign-history-job_v002 create_emr_steps 2021-04-15T13:00:00+00:00 PythonOperator 2021-04-15T14:15:16.789991+00:00 2021-04-15T14:15:19.712307+00:00 0:00:02.922316 17490 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T14:15:14.247846+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-15T13:00:00+00:00 PythonOperator 2021-04-15T14:15:10.519539+00:00 2021-04-15T14:15:13.805213+00:00 0:00:03.285674 17489 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T14:15:08.246315+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-15T13:00:00+00:00 TriggerDagRunOperator 2021-04-15T14:14:54.833171+00:00 2021-04-15T14:14:55.361749+00:00 0:00:00.528578 17488 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T14:14:52.233035+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-15T13:00:00+00:00 TriggerDagRunOperator 2021-04-15T14:14:54.822263+00:00 2021-04-15T14:14:55.233809+00:00 0:00:00.411546 17487 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T14:14:52.233003+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-15T13:05:00+00:00 EmrJobFlowSensor 2021-04-15T14:06:05.798957+00:00 2021-04-15T14:15:09.038063+00:00 0:09:03.239106 17486 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T14:06:03.399944+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-15T13:00:00+00:00 EmrJobFlowSensor 2021-04-15T14:05:44.092025+00:00 2021-04-15T14:14:46.770212+00:00 0:09:02.678187 17485 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T14:05:41.447481+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-15T13:05:00+00:00 EmrCreateJobFlowOperator 2021-04-15T14:05:41.733569+00:00 2021-04-15T14:05:43.664797+00:00 0:00:01.931228 17484 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-15T14:05:39.444308+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-15T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-15T14:05:21.873510+00:00 2021-04-15T14:05:23.718297+00:00 0:00:01.844787 17483 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-15T14:05:19.357083+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-15T13:05:00+00:00 PythonOperator 2021-04-15T14:05:19.592352+00:00 2021-04-15T14:05:22.447919+00:00 0:00:02.855567 17482 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T14:05:17.354862+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-15T13:00:00+00:00 PythonOperator 2021-04-15T14:05:00.099855+00:00 2021-04-15T14:05:03.124681+00:00 0:00:03.024826 17481 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-15T14:04:57.339982+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-15T12:00:00+00:00 EmrJobFlowSensor 2021-04-15T13:12:37.156514+00:00 2021-04-15T13:20:39.572339+00:00 0:08:02.415825 17479 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T13:12:34.486785+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-15T12:00:00+00:00 EmrJobFlowSensor 2021-04-15T13:12:34.674020+00:00 2021-04-15T13:22:37.841720+00:00 0:10:03.167700 17478 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T13:12:32.487572+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-15T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-15T13:12:15.181252+00:00 2021-04-15T13:12:16.865967+00:00 0:00:01.684715 17477 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-15T13:12:12.408999+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-15T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-15T13:12:12.907273+00:00 2021-04-15T13:12:14.915439+00:00 0:00:02.008166 17476 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-15T13:12:10.413963+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-15T12:00:00+00:00 PythonOperator 2021-04-15T13:11:52.807112+00:00 2021-04-15T13:11:55.652832+00:00 0:00:02.845720 17475 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T13:11:50.389657+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-15T12:00:00+00:00 PythonOperator 2021-04-15T13:11:50.793576+00:00 2021-04-15T13:11:54.260597+00:00 0:00:03.467021 17474 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T13:11:48.445372+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-15T12:00:00+00:00 TriggerDagRunOperator 2021-04-15T13:11:34.732893+00:00 2021-04-15T13:11:35.363206+00:00 0:00:00.630313 17473 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T13:11:32.360335+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-15T12:00:00+00:00 TriggerDagRunOperator 2021-04-15T13:11:34.534422+00:00 2021-04-15T13:11:35.067753+00:00 0:00:00.533331 17472 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T13:11:32.360363+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-15T12:05:00+00:00 EmrJobFlowSensor 2021-04-15T13:05:52.159640+00:00 2021-04-15T13:14:54.951175+00:00 0:09:02.791535 17471 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T13:05:49.865448+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-15T12:05:00+00:00 EmrCreateJobFlowOperator 2021-04-15T13:05:30.355731+00:00 2021-04-15T13:05:32.084577+00:00 0:00:01.728846 17470 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-15T13:05:27.869565+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-15T12:05:00+00:00 PythonOperator 2021-04-15T13:05:09.858297+00:00 2021-04-15T13:05:12.730781+00:00 0:00:02.872484 17469 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T13:05:07.718882+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-15T12:00:00+00:00 EmrJobFlowSensor 2021-04-15T13:01:03.639529+00:00 2021-04-15T13:11:06.445490+00:00 0:10:02.805961 17468 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T13:01:01.391430+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-15T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-15T13:00:41.522619+00:00 2021-04-15T13:00:43.324241+00:00 0:00:01.801622 17467 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-15T13:00:39.300871+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-15T12:00:00+00:00 PythonOperator 2021-04-15T13:00:21.600758+00:00 2021-04-15T13:00:24.583962+00:00 0:00:02.983204 17466 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-15T13:00:19.284766+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-15T11:00:00+00:00 EmrJobFlowSensor 2021-04-15T12:11:07.793216+00:00 2021-04-15T12:20:10.409909+00:00 0:09:02.616693 17464 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T12:11:05.630683+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-15T11:00:00+00:00 EmrJobFlowSensor 2021-04-15T12:11:05.999431+00:00 2021-04-15T12:19:08.694422+00:00 0:08:02.694991 17463 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T12:11:03.628892+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-15T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-15T12:10:46.207107+00:00 2021-04-15T12:10:47.911800+00:00 0:00:01.704693 17462 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-15T12:10:43.609900+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-15T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-15T12:10:43.913540+00:00 2021-04-15T12:10:45.928394+00:00 0:00:02.014854 17461 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-15T12:10:41.612890+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-15T11:00:00+00:00 PythonOperator 2021-04-15T12:10:24.219355+00:00 2021-04-15T12:10:27.305640+00:00 0:00:03.086285 17460 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T12:10:21.646434+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-15T11:00:00+00:00 PythonOperator 2021-04-15T12:10:22.015208+00:00 2021-04-15T12:10:25.062564+00:00 0:00:03.047356 17459 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T12:10:19.640844+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-15T11:00:00+00:00 TriggerDagRunOperator 2021-04-15T12:10:03.874574+00:00 2021-04-15T12:10:04.337439+00:00 0:00:00.462865 17458 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T12:10:01.503850+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-15T11:00:00+00:00 TriggerDagRunOperator 2021-04-15T12:10:03.743616+00:00 2021-04-15T12:10:04.307431+00:00 0:00:00.563815 17457 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T12:10:01.503880+00:00 2 default_pool
success primary-audience-global-ind_v003 create_cluster 2021-04-15T12:07:08.386972+00:00 PythonOperator 2021-04-15T12:07:37.407858+00:00 2021-04-15T12:07:40.843864+00:00 0:00:03.436006 17456 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T12:07:35.307891+00:00 2 default_pool
success primary-audience-global-ind_v003 validation 2021-04-15T12:07:08.386972+00:00 PythonOperator 2021-04-15T12:07:15.528860+00:00 2021-04-15T12:07:15.809708+00:00 0:00:00.280848 17455 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-15T12:07:13.296193+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-15T11:05:00+00:00 EmrJobFlowSensor 2021-04-15T12:05:47.497054+00:00 2021-04-15T12:13:50.086912+00:00 0:08:02.589858 17454 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T12:05:45.130279+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-15T11:05:00+00:00 EmrCreateJobFlowOperator 2021-04-15T12:05:25.357549+00:00 2021-04-15T12:05:27.009017+00:00 0:00:01.651468 17453 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-15T12:05:23.105619+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-15T11:05:00+00:00 PythonOperator 2021-04-15T12:05:03.271483+00:00 2021-04-15T12:05:06.101734+00:00 0:00:02.830251 17452 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T12:05:01.082176+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-15T11:00:00+00:00 EmrJobFlowSensor 2021-04-15T12:00:46.944421+00:00 2021-04-15T12:09:49.654929+00:00 0:09:02.710508 17451 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T12:00:44.664473+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-15T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-15T12:00:24.795096+00:00 2021-04-15T12:00:26.671519+00:00 0:00:01.876423 17450 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-15T12:00:22.543307+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-15T11:00:00+00:00 PythonOperator 2021-04-15T12:00:05.373722+00:00 2021-04-15T12:00:08.711338+00:00 0:00:03.337616 17449 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-15T12:00:02.524643+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-15T10:00:00+00:00 EmrJobFlowSensor 2021-04-15T11:11:31.210309+00:00 2021-04-15T11:20:33.757304+00:00 0:09:02.546995 17447 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T11:11:29.008056+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-15T10:00:00+00:00 EmrJobFlowSensor 2021-04-15T11:11:25.201653+00:00 2021-04-15T11:21:27.929160+00:00 0:10:02.727507 17446 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T11:11:23.046542+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-15T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-15T11:11:09.186898+00:00 2021-04-15T11:11:10.896713+00:00 0:00:01.709815 17445 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-15T11:11:06.990829+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-15T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-15T11:11:03.289034+00:00 2021-04-15T11:11:05.193178+00:00 0:00:01.904144 17444 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-15T11:11:00.988099+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-15T10:00:00+00:00 PythonOperator 2021-04-15T11:10:49.214631+00:00 2021-04-15T11:10:52.129374+00:00 0:00:02.914743 17443 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T11:10:46.907485+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-15T10:00:00+00:00 PythonOperator 2021-04-15T11:10:41.089271+00:00 2021-04-15T11:10:44.423769+00:00 0:00:03.334498 17442 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T11:10:38.901620+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-15T10:00:00+00:00 TriggerDagRunOperator 2021-04-15T11:10:25.538422+00:00 2021-04-15T11:10:26.053774+00:00 0:00:00.515352 17441 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T11:10:22.893046+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-15T10:00:00+00:00 TriggerDagRunOperator 2021-04-15T11:10:25.407327+00:00 2021-04-15T11:10:25.834538+00:00 0:00:00.427211 17440 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T11:10:22.893076+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-15T10:05:00+00:00 EmrJobFlowSensor 2021-04-15T11:06:06.614805+00:00 2021-04-15T11:14:09.226051+00:00 0:08:02.611246 17439 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T11:06:04.435498+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-15T10:05:00+00:00 EmrCreateJobFlowOperator 2021-04-15T11:05:45.553259+00:00 2021-04-15T11:05:47.278100+00:00 0:00:01.724841 17438 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-15T11:05:42.546728+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-15T10:05:00+00:00 PythonOperator 2021-04-15T11:05:22.544182+00:00 2021-04-15T11:05:25.606823+00:00 0:00:03.062641 17437 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T11:05:20.403632+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-15T10:00:00+00:00 EmrJobFlowSensor 2021-04-15T11:01:04.574212+00:00 2021-04-15T11:10:07.367431+00:00 0:09:02.793219 17436 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T11:01:02.088389+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-15T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-15T11:00:42.224109+00:00 2021-04-15T11:00:44.111867+00:00 0:00:01.887758 17435 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-15T11:00:40.043582+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-15T10:00:00+00:00 PythonOperator 2021-04-15T11:00:20.723297+00:00 2021-04-15T11:00:23.579991+00:00 0:00:02.856694 17434 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-15T11:00:18.051126+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-15T09:00:00+00:00 EmrJobFlowSensor 2021-04-15T10:10:16.720559+00:00 2021-04-15T10:18:19.245026+00:00 0:08:02.524467 17432 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T10:10:14.472509+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-15T09:00:00+00:00 EmrJobFlowSensor 2021-04-15T10:10:08.712569+00:00 2021-04-15T10:20:11.603957+00:00 0:10:02.891388 17431 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T10:10:06.416366+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-15T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-15T10:09:56.654029+00:00 2021-04-15T10:09:58.354708+00:00 0:00:01.700679 17430 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-15T10:09:54.413349+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-15T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-15T10:09:46.861355+00:00 2021-04-15T10:09:48.607735+00:00 0:00:01.746380 17429 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-15T10:09:44.398640+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-15T09:00:00+00:00 PythonOperator 2021-04-15T10:09:34.720647+00:00 2021-04-15T10:09:37.680004+00:00 0:00:02.959357 17428 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T10:09:32.387045+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-15T09:00:00+00:00 PythonOperator 2021-04-15T10:09:26.468655+00:00 2021-04-15T10:09:29.783277+00:00 0:00:03.314622 17427 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T10:09:24.353072+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-15T09:00:00+00:00 TriggerDagRunOperator 2021-04-15T10:09:10.960033+00:00 2021-04-15T10:09:11.514110+00:00 0:00:00.554077 17426 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T10:09:08.460877+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-15T09:00:00+00:00 TriggerDagRunOperator 2021-04-15T10:09:10.883408+00:00 2021-04-15T10:09:11.292510+00:00 0:00:00.409102 17425 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T10:09:08.460809+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-15T09:05:00+00:00 EmrJobFlowSensor 2021-04-15T10:05:56.272798+00:00 2021-04-15T10:14:58.870083+00:00 0:09:02.597285 17424 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T10:05:54.053476+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-15T09:05:00+00:00 EmrCreateJobFlowOperator 2021-04-15T10:05:34.333598+00:00 2021-04-15T10:05:35.982033+00:00 0:00:01.648435 17423 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-15T10:05:32.046628+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-15T09:05:00+00:00 PythonOperator 2021-04-15T10:05:12.065715+00:00 2021-04-15T10:05:14.931541+00:00 0:00:02.865826 17422 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T10:05:09.887142+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-15T09:00:00+00:00 EmrJobFlowSensor 2021-04-15T10:00:51.806611+00:00 2021-04-15T10:08:54.430050+00:00 0:08:02.623439 17421 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T10:00:49.422334+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-15T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-15T10:00:31.798666+00:00 2021-04-15T10:00:33.524217+00:00 0:00:01.725551 17420 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-15T10:00:29.481056+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-15T09:00:00+00:00 PythonOperator 2021-04-15T10:00:10.018024+00:00 2021-04-15T10:00:13.206901+00:00 0:00:03.188877 17419 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-15T10:00:07.388159+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-15T08:00:00+00:00 EmrJobFlowSensor 2021-04-15T09:12:22.233266+00:00 2021-04-15T09:22:25.079556+00:00 0:10:02.846290 17417 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T09:12:19.753394+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-15T08:00:00+00:00 EmrJobFlowSensor 2021-04-15T09:12:22.027516+00:00 2021-04-15T09:21:24.878572+00:00 0:09:02.851056 17416 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T09:12:19.753346+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-15T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-15T09:12:00.301434+00:00 2021-04-15T09:12:02.089967+00:00 0:00:01.788533 17415 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-15T09:11:57.744619+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-15T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-15T09:12:00.345124+00:00 2021-04-15T09:12:02.231912+00:00 0:00:01.886788 17414 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-15T09:11:57.744665+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-15T08:00:00+00:00 PythonOperator 2021-04-15T09:11:37.977103+00:00 2021-04-15T09:11:41.197459+00:00 0:00:03.220356 17413 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T09:11:35.589305+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-15T08:00:00+00:00 PythonOperator 2021-04-15T09:11:37.800436+00:00 2021-04-15T09:11:40.717472+00:00 0:00:02.917036 17412 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T09:11:35.589333+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-15T08:00:00+00:00 TriggerDagRunOperator 2021-04-15T09:11:24.018244+00:00 2021-04-15T09:11:24.447439+00:00 0:00:00.429195 17411 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T09:11:21.593832+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-15T08:00:00+00:00 TriggerDagRunOperator 2021-04-15T09:11:23.956456+00:00 2021-04-15T09:11:24.545512+00:00 0:00:00.589056 17410 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T09:11:21.593879+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-15T08:05:00+00:00 EmrJobFlowSensor 2021-04-15T09:05:59.006248+00:00 2021-04-15T09:14:01.326557+00:00 0:08:02.320309 17409 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T09:05:56.805389+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-15T08:05:00+00:00 EmrCreateJobFlowOperator 2021-04-15T09:05:36.989348+00:00 2021-04-15T09:05:38.707698+00:00 0:00:01.718350 17408 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-15T09:05:34.783252+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-15T08:05:00+00:00 PythonOperator 2021-04-15T09:05:14.853315+00:00 2021-04-15T09:05:17.741292+00:00 0:00:02.887977 17407 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T09:05:12.721188+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-15T08:00:00+00:00 EmrJobFlowSensor 2021-04-15T09:01:02.676237+00:00 2021-04-15T09:11:05.412887+00:00 0:10:02.736650 17406 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T09:01:00.244394+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-15T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-15T09:00:42.321980+00:00 2021-04-15T09:00:44.020692+00:00 0:00:01.698712 17405 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-15T09:00:40.116872+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-15T08:00:00+00:00 PythonOperator 2021-04-15T09:00:20.581512+00:00 2021-04-15T09:00:23.540520+00:00 0:00:02.959008 17404 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-15T09:00:18.099219+00:00 2 default_pool
success primary-audience-global-ind_v003 create_cluster 2021-04-15T08:33:49.474055+00:00 PythonOperator 2021-04-15T08:34:27.863855+00:00 2021-04-15T08:34:31.287097+00:00 0:00:03.423242 17402 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T08:34:25.131969+00:00 2 default_pool
success primary-audience-global-ind_v003 validation 2021-04-15T08:33:49.474055+00:00 PythonOperator 2021-04-15T08:34:05.331287+00:00 2021-04-15T08:34:05.690275+00:00 0:00:00.358988 17401 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-15T08:34:03.114576+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-15T07:00:00+00:00 EmrJobFlowSensor 2021-04-15T08:11:27.247483+00:00 2021-04-15T08:20:29.900489+00:00 0:09:02.653006 17400 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T08:11:24.848544+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-15T07:00:00+00:00 EmrJobFlowSensor 2021-04-15T08:11:25.105788+00:00 2021-04-15T08:21:28.103758+00:00 0:10:02.997970 17399 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T08:11:22.735580+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-15T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-15T08:11:07.219815+00:00 2021-04-15T08:11:09.054929+00:00 0:00:01.835114 17398 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-15T08:11:04.850343+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-15T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-15T08:11:05.444649+00:00 2021-04-15T08:11:07.236119+00:00 0:00:01.791470 17397 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-15T08:11:02.770586+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-15T07:00:00+00:00 PythonOperator 2021-04-15T08:10:45.271361+00:00 2021-04-15T08:10:48.420933+00:00 0:00:03.149572 17396 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T08:10:42.693876+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-15T07:00:00+00:00 PythonOperator 2021-04-15T08:10:42.934651+00:00 2021-04-15T08:10:46.073716+00:00 0:00:03.139065 17395 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T08:10:40.694397+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-15T07:00:00+00:00 TriggerDagRunOperator 2021-04-15T08:10:26.903830+00:00 2021-04-15T08:10:27.452988+00:00 0:00:00.549158 17394 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T08:10:24.634669+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-15T07:00:00+00:00 TriggerDagRunOperator 2021-04-15T08:10:26.879419+00:00 2021-04-15T08:10:27.305853+00:00 0:00:00.426434 17393 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T08:10:24.634639+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-15T07:05:00+00:00 EmrJobFlowSensor 2021-04-15T08:06:08.408858+00:00 2021-04-15T08:15:10.957905+00:00 0:09:02.549047 17392 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T08:06:06.216096+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-15T07:05:00+00:00 EmrCreateJobFlowOperator 2021-04-15T08:05:46.307403+00:00 2021-04-15T08:05:47.959885+00:00 0:00:01.652482 17391 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-15T08:05:44.197551+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-15T07:05:00+00:00 PythonOperator 2021-04-15T08:05:24.802451+00:00 2021-04-15T08:05:27.673196+00:00 0:00:02.870745 17390 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T08:05:22.185560+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-15T07:00:00+00:00 EmrJobFlowSensor 2021-04-15T08:01:00.204969+00:00 2021-04-15T08:10:02.955857+00:00 0:09:02.750888 17389 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T08:00:57.715894+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-15T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-15T08:00:37.928728+00:00 2021-04-15T08:00:39.805343+00:00 0:00:01.876615 17388 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-15T08:00:35.703290+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-15T07:00:00+00:00 PythonOperator 2021-04-15T08:00:16.663134+00:00 2021-04-15T08:00:19.582896+00:00 0:00:02.919762 17387 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-15T08:00:13.659262+00:00 2 default_pool
success Custom-EMR-cluster_v001 create_cluster_n_add_steps 2021-04-15T07:54:48.092215+00:00 PythonOperator 2021-04-15T07:55:13.424451+00:00 2021-04-15T07:55:16.426737+00:00 0:00:03.002286 17386 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T07:55:11.095077+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-15T06:00:00+00:00 EmrJobFlowSensor 2021-04-15T07:10:21.621319+00:00 2021-04-15T07:19:24.236433+00:00 0:09:02.615114 17384 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T07:10:19.304618+00:00 2 default_pool