Task Instances

  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success campaign-flow-job_v002 check_cluster_status 2021-05-05T00:00:00+00:00 EmrJobFlowSensor 2021-05-05T01:01:08.204123+00:00 2021-05-05T01:11:11.070900+00:00 0:10:02.866777 24558 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T01:01:06.092451+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-05T00:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T01:00:44.413848+00:00 2021-05-05T01:00:46.128806+00:00 0:00:01.714958 24557 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-05T01:00:42.153062+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-05T00:00:00+00:00 PythonOperator 2021-05-05T01:00:24.311180+00:00 2021-05-05T01:00:27.416661+00:00 0:00:03.105481 24556 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-05T01:00:22.024508+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-04T23:00:00+00:00 EmrJobFlowSensor 2021-05-05T00:10:34.502112+00:00 2021-05-05T00:19:37.126584+00:00 0:09:02.624472 24555 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T00:10:32.334963+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-04T23:00:00+00:00 EmrJobFlowSensor 2021-05-05T00:10:30.610829+00:00 2021-05-05T00:20:33.339119+00:00 0:10:02.728290 24554 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T00:10:28.351924+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-04T23:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T00:10:12.523316+00:00 2021-05-05T00:10:14.325307+00:00 0:00:01.801991 24553 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T00:10:10.317808+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-04T23:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T00:10:08.495639+00:00 2021-05-05T00:10:10.228537+00:00 0:00:01.732898 24552 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T00:10:06.323555+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-04T23:00:00+00:00 PythonOperator 2021-05-05T00:09:53.077450+00:00 2021-05-05T00:09:56.350376+00:00 0:00:03.272926 24551 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T00:09:50.370348+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-04T23:00:00+00:00 PythonOperator 2021-05-05T00:09:46.477451+00:00 2021-05-05T00:09:49.511456+00:00 0:00:03.034005 24550 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T00:09:44.297685+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-04T23:00:00+00:00 TriggerDagRunOperator 2021-05-05T00:09:32.827656+00:00 2021-05-05T00:09:33.260713+00:00 0:00:00.433057 24549 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T00:09:30.343648+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-04T23:00:00+00:00 TriggerDagRunOperator 2021-05-05T00:09:32.858900+00:00 2021-05-05T00:09:33.447622+00:00 0:00:00.588722 24548 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T00:09:30.343677+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-04T23:05:00+00:00 EmrJobFlowSensor 2021-05-05T00:08:14.387923+00:00 2021-05-05T00:17:16.917950+00:00 0:09:02.530027 24547 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T00:08:12.169404+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-04T23:05:00+00:00 EmrCreateJobFlowOperator 2021-05-05T00:07:52.161130+00:00 2021-05-05T00:07:53.810053+00:00 0:00:01.648923 24546 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T00:07:50.089989+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-04T23:05:00+00:00 PythonOperator 2021-05-05T00:07:32.276263+00:00 2021-05-05T00:07:35.298758+00:00 0:00:03.022495 24545 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T00:07:30.071423+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-04T23:00:00+00:00 EmrJobFlowSensor 2021-05-05T00:01:05.704278+00:00 2021-05-05T00:09:08.383307+00:00 0:08:02.679029 24543 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T00:01:03.346693+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-04T23:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T00:00:45.475892+00:00 2021-05-05T00:00:47.138895+00:00 0:00:01.663003 24542 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-05T00:00:43.294958+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-04T23:00:00+00:00 PythonOperator 2021-05-05T00:00:23.849652+00:00 2021-05-05T00:00:26.949123+00:00 0:00:03.099471 24541 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-05T00:00:21.187780+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-04T22:00:00+00:00 EmrJobFlowSensor 2021-05-04T23:10:28.486849+00:00 2021-05-04T23:19:31.262586+00:00 0:09:02.775737 24540 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T23:10:26.276365+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-04T22:00:00+00:00 EmrJobFlowSensor 2021-05-04T23:10:20.800172+00:00 2021-05-04T23:20:23.536892+00:00 0:10:02.736720 24539 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T23:10:18.250173+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-04T22:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T23:10:08.465069+00:00 2021-05-04T23:10:10.264529+00:00 0:00:01.799460 24538 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T23:10:06.220832+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-04T22:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T23:09:58.395394+00:00 2021-05-04T23:10:00.135696+00:00 0:00:01.740302 24537 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T23:09:56.244228+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-04T22:00:00+00:00 PythonOperator 2021-05-04T23:09:46.474799+00:00 2021-05-04T23:09:49.513686+00:00 0:00:03.038887 24536 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T23:09:44.260042+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-04T22:00:00+00:00 PythonOperator 2021-05-04T23:09:36.313806+00:00 2021-05-04T23:09:39.509715+00:00 0:00:03.195909 24535 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T23:09:34.191943+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-04T22:00:00+00:00 TriggerDagRunOperator 2021-05-04T23:09:24.501930+00:00 2021-05-04T23:09:25.013633+00:00 0:00:00.511703 24534 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T23:09:22.184508+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-04T22:00:00+00:00 TriggerDagRunOperator 2021-05-04T23:09:24.455164+00:00 2021-05-04T23:09:24.841630+00:00 0:00:00.386466 24533 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T23:09:22.184541+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-04T22:05:00+00:00 EmrJobFlowSensor 2021-05-04T23:06:07.988959+00:00 2021-05-04T23:15:10.562414+00:00 0:09:02.573455 24532 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T23:06:05.884849+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-04T22:05:00+00:00 EmrCreateJobFlowOperator 2021-05-04T23:05:46.053971+00:00 2021-05-04T23:05:47.786570+00:00 0:00:01.732599 24531 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T23:05:43.841362+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-04T22:05:00+00:00 PythonOperator 2021-05-04T23:05:24.698350+00:00 2021-05-04T23:05:27.714388+00:00 0:00:03.016038 24530 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T23:05:21.867167+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-05-03T23:00:00+00:00 EmrJobFlowSensor 2021-05-04T23:01:10.359433+00:00 2021-05-04T23:10:12.940416+00:00 0:09:02.580983 24528 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T23:01:08.225113+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-04T22:00:00+00:00 EmrJobFlowSensor 2021-05-04T23:01:08.615105+00:00 2021-05-04T23:09:11.327869+00:00 0:08:02.712764 24527 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T23:01:06.220018+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-04T22:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T23:00:40.650573+00:00 2021-05-04T23:00:42.453553+00:00 0:00:01.802980 24526 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-04T23:00:38.244753+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-05-03T23:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T23:00:40.507344+00:00 2021-05-04T23:00:42.195586+00:00 0:00:01.688242 24525 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T23:00:38.244720+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-05-03T23:00:00+00:00 PythonOperator 2021-05-04T23:00:20.476742+00:00 2021-05-04T23:00:23.543568+00:00 0:00:03.066826 24524 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T23:00:18.106262+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-04T22:00:00+00:00 PythonOperator 2021-05-04T23:00:18.335027+00:00 2021-05-04T23:00:21.417995+00:00 0:00:03.082968 24523 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-04T23:00:16.099574+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-04T21:00:00+00:00 EmrJobFlowSensor 2021-05-04T22:10:55.523651+00:00 2021-05-04T22:20:58.520577+00:00 0:10:02.996926 24522 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T22:10:53.021811+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-04T21:00:00+00:00 EmrJobFlowSensor 2021-05-04T22:10:55.382358+00:00 2021-05-04T22:19:58.093662+00:00 0:09:02.711304 24521 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T22:10:53.021781+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-04T21:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T22:10:33.705581+00:00 2021-05-04T22:10:35.624011+00:00 0:00:01.918430 24520 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T22:10:31.070281+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-04T21:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T22:10:33.464319+00:00 2021-05-04T22:10:35.162248+00:00 0:00:01.697929 24519 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T22:10:31.070330+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-04T21:00:00+00:00 PythonOperator 2021-05-04T22:10:11.634333+00:00 2021-05-04T22:10:14.950226+00:00 0:00:03.315893 24518 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T22:10:08.989632+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-04T21:00:00+00:00 PythonOperator 2021-05-04T22:10:11.522447+00:00 2021-05-04T22:10:14.660730+00:00 0:00:03.138283 24517 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T22:10:08.989598+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-04T21:00:00+00:00 TriggerDagRunOperator 2021-05-04T22:10:05.884047+00:00 2021-05-04T22:10:06.343716+00:00 0:00:00.459669 24516 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T22:10:03.054277+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-04T21:00:00+00:00 TriggerDagRunOperator 2021-05-04T22:10:05.739048+00:00 2021-05-04T22:10:06.303440+00:00 0:00:00.564392 24515 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T22:10:03.054326+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-04T21:05:00+00:00 EmrJobFlowSensor 2021-05-04T22:05:50.857071+00:00 2021-05-04T22:14:53.420095+00:00 0:09:02.563024 24514 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T22:05:48.685218+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-04T21:05:00+00:00 EmrCreateJobFlowOperator 2021-05-04T22:05:30.896865+00:00 2021-05-04T22:05:32.674874+00:00 0:00:01.778009 24513 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T22:05:28.642529+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-04T21:05:00+00:00 PythonOperator 2021-05-04T22:05:09.000146+00:00 2021-05-04T22:05:12.030750+00:00 0:00:03.030604 24512 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T22:05:06.622318+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-04T21:00:00+00:00 EmrJobFlowSensor 2021-05-04T22:00:54.526152+00:00 2021-05-04T22:09:57.178286+00:00 0:09:02.652134 24510 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T22:00:52.358009+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-04T21:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T22:00:34.631545+00:00 2021-05-04T22:00:36.453820+00:00 0:00:01.822275 24509 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-04T22:00:32.342815+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-04T21:00:00+00:00 PythonOperator 2021-05-04T22:00:12.512708+00:00 2021-05-04T22:00:15.603725+00:00 0:00:03.091017 24508 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-04T22:00:10.319293+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-04T20:00:00+00:00 EmrJobFlowSensor 2021-05-04T21:13:38.459594+00:00 2021-05-04T21:22:41.177549+00:00 0:09:02.717955 24507 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T21:13:36.096985+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-04T20:00:00+00:00 EmrJobFlowSensor 2021-05-04T21:13:34.299579+00:00 2021-05-04T21:23:37.183305+00:00 0:10:02.883726 24506 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T21:13:32.085768+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-04T20:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T21:13:16.589797+00:00 2021-05-04T21:13:18.408010+00:00 0:00:01.818213 24505 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T21:13:14.037766+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-04T20:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T21:13:14.351621+00:00 2021-05-04T21:13:16.360343+00:00 0:00:02.008722 24504 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T21:13:12.028560+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-04T20:00:00+00:00 PythonOperator 2021-05-04T21:12:56.187446+00:00 2021-05-04T21:12:59.404167+00:00 0:00:03.216721 24503 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T21:12:54.015147+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-04T20:00:00+00:00 PythonOperator 2021-05-04T21:12:52.271857+00:00 2021-05-04T21:12:55.606037+00:00 0:00:03.334180 24502 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T21:12:50.014358+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-04T20:00:00+00:00 TriggerDagRunOperator 2021-05-04T21:12:42.386984+00:00 2021-05-04T21:12:42.916425+00:00 0:00:00.529441 24501 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T21:12:40.004638+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-04T20:00:00+00:00 TriggerDagRunOperator 2021-05-04T21:12:42.209954+00:00 2021-05-04T21:12:42.743370+00:00 0:00:00.533416 24500 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T21:12:40.004606+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-04T20:05:00+00:00 EmrJobFlowSensor 2021-05-04T21:06:00.170535+00:00 2021-05-04T21:14:02.622891+00:00 0:08:02.452356 24499 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T21:05:57.543467+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-04T20:05:00+00:00 EmrCreateJobFlowOperator 2021-05-04T21:05:39.878474+00:00 2021-05-04T21:05:41.647485+00:00 0:00:01.769011 24498 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T21:05:37.465586+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-04T20:05:00+00:00 PythonOperator 2021-05-04T21:05:17.480239+00:00 2021-05-04T21:05:20.493613+00:00 0:00:03.013374 24497 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T21:05:15.330480+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-04T20:00:00+00:00 EmrJobFlowSensor 2021-05-04T21:02:17.333297+00:00 2021-05-04T21:12:20.197063+00:00 0:10:02.863766 24496 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T21:02:15.032949+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-04T20:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T21:01:55.343657+00:00 2021-05-04T21:01:57.141276+00:00 0:00:01.797619 24495 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-04T21:01:53.002588+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-04T20:00:00+00:00 PythonOperator 2021-05-04T21:01:35.731842+00:00 2021-05-04T21:01:38.852310+00:00 0:00:03.120468 24494 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-04T21:01:32.988373+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-04T19:00:00+00:00 EmrJobFlowSensor 2021-05-04T20:10:40.597121+00:00 2021-05-04T20:18:43.117899+00:00 0:08:02.520778 24492 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T20:10:38.273797+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-04T19:00:00+00:00 EmrJobFlowSensor 2021-05-04T20:10:24.765766+00:00 2021-05-04T20:20:27.690438+00:00 0:10:02.924672 24491 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T20:10:22.264826+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-04T19:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T20:10:20.484559+00:00 2021-05-04T20:10:22.164953+00:00 0:00:01.680394 24490 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T20:10:18.260432+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-04T19:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T20:10:04.617753+00:00 2021-05-04T20:10:06.468660+00:00 0:00:01.850907 24489 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T20:10:02.244654+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-04T19:00:00+00:00 PythonOperator 2021-05-04T20:09:58.323438+00:00 2021-05-04T20:10:01.353589+00:00 0:00:03.030151 24488 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T20:09:56.135293+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-04T19:00:00+00:00 PythonOperator 2021-05-04T20:09:40.413290+00:00 2021-05-04T20:09:43.717952+00:00 0:00:03.304662 24487 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T20:09:38.120462+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-04T19:00:00+00:00 TriggerDagRunOperator 2021-05-04T20:09:24.595295+00:00 2021-05-04T20:09:25.129577+00:00 0:00:00.534282 24486 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T20:09:22.110629+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-04T19:00:00+00:00 TriggerDagRunOperator 2021-05-04T20:09:24.567098+00:00 2021-05-04T20:09:24.969716+00:00 0:00:00.402618 24485 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T20:09:22.110598+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-04T19:05:00+00:00 EmrJobFlowSensor 2021-05-04T20:05:56.351473+00:00 2021-05-04T20:14:59.075978+00:00 0:09:02.724505 24484 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T20:05:53.964140+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-04T19:05:00+00:00 EmrCreateJobFlowOperator 2021-05-04T20:05:36.339914+00:00 2021-05-04T20:05:37.980630+00:00 0:00:01.640716 24483 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T20:05:33.887105+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-04T19:05:00+00:00 PythonOperator 2021-05-04T20:05:14.003932+00:00 2021-05-04T20:05:17.055269+00:00 0:00:03.051337 24482 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T20:05:11.805736+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-04T19:00:00+00:00 EmrJobFlowSensor 2021-05-04T20:01:06.006267+00:00 2021-05-04T20:09:08.677048+00:00 0:08:02.670781 24481 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T20:01:03.555374+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-04T19:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T20:00:43.781569+00:00 2021-05-04T20:00:45.595913+00:00 0:00:01.814344 24480 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-04T20:00:41.488358+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-04T19:00:00+00:00 PythonOperator 2021-05-04T20:00:23.713331+00:00 2021-05-04T20:00:26.810540+00:00 0:00:03.097209 24479 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-04T20:00:21.417223+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-04T18:00:00+00:00 EmrJobFlowSensor 2021-05-04T19:12:09.550101+00:00 2021-05-04T19:22:12.507392+00:00 0:10:02.957291 24477 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T19:12:06.886255+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-04T18:00:00+00:00 EmrJobFlowSensor 2021-05-04T19:12:09.245192+00:00 2021-05-04T19:21:11.954813+00:00 0:09:02.709621 24476 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T19:12:06.886285+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-04T18:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T19:11:49.112780+00:00 2021-05-04T19:11:50.789189+00:00 0:00:01.676409 24475 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T19:11:46.814518+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-04T18:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T19:11:47.170786+00:00 2021-05-04T19:11:48.981241+00:00 0:00:01.810455 24474 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T19:11:44.817766+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-04T18:00:00+00:00 PythonOperator 2021-05-04T19:11:27.407880+00:00 2021-05-04T19:11:30.412096+00:00 0:00:03.004216 24473 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T19:11:24.862621+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-04T18:00:00+00:00 PythonOperator 2021-05-04T19:11:25.322626+00:00 2021-05-04T19:11:28.754446+00:00 0:00:03.431820 24472 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T19:11:22.866076+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-04T18:00:00+00:00 TriggerDagRunOperator 2021-05-04T19:11:07.376595+00:00 2021-05-04T19:11:07.914293+00:00 0:00:00.537698 24471 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T19:11:04.850812+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-04T18:00:00+00:00 TriggerDagRunOperator 2021-05-04T19:11:07.326158+00:00 2021-05-04T19:11:07.765417+00:00 0:00:00.439259 24470 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T19:11:04.850763+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-04T18:05:00+00:00 EmrJobFlowSensor 2021-05-04T19:05:48.182679+00:00 2021-05-04T19:14:50.786358+00:00 0:09:02.603679 24469 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T19:05:46.023767+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-04T18:05:00+00:00 EmrCreateJobFlowOperator 2021-05-04T19:05:26.453931+00:00 2021-05-04T19:05:28.138446+00:00 0:00:01.684515 24468 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T19:05:24.054920+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-04T18:05:00+00:00 PythonOperator 2021-05-04T19:05:04.371667+00:00 2021-05-04T19:05:07.441594+00:00 0:00:03.069927 24467 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T19:05:02.054255+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-04T18:00:00+00:00 EmrJobFlowSensor 2021-05-04T19:00:58.010843+00:00 2021-05-04T19:11:00.961313+00:00 0:10:02.950470 24466 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T19:00:55.701265+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-04T18:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T19:00:36.000856+00:00 2021-05-04T19:00:37.728260+00:00 0:00:01.727404 24465 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-04T19:00:33.646182+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-04T18:00:00+00:00 PythonOperator 2021-05-04T19:00:14.254956+00:00 2021-05-04T19:00:17.398564+00:00 0:00:03.143608 24464 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-04T19:00:11.628068+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-04T17:00:00+00:00 EmrJobFlowSensor 2021-05-04T18:12:04.808396+00:00 2021-05-04T18:21:07.506391+00:00 0:09:02.697995 24462 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T18:12:02.596049+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-04T17:00:00+00:00 EmrJobFlowSensor 2021-05-04T18:11:58.887647+00:00 2021-05-04T18:22:01.823291+00:00 0:10:02.935644 24461 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T18:11:56.593288+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-04T17:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T18:11:41.008332+00:00 2021-05-04T18:11:42.759778+00:00 0:00:01.751446 24460 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T18:11:38.648521+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-04T17:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T18:11:37.071919+00:00 2021-05-04T18:11:38.862269+00:00 0:00:01.790350 24459 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T18:11:34.646967+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-04T17:00:00+00:00 PythonOperator 2021-05-04T18:11:20.632101+00:00 2021-05-04T18:11:23.932787+00:00 0:00:03.300686 24458 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T18:11:18.406366+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-04T17:00:00+00:00 PythonOperator 2021-05-04T18:11:15.053542+00:00 2021-05-04T18:11:18.135660+00:00 0:00:03.082118 24457 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T18:11:12.546213+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-04T17:00:00+00:00 TriggerDagRunOperator 2021-05-04T18:10:57.352321+00:00 2021-05-04T18:10:57.866621+00:00 0:00:00.514300 24456 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T18:10:54.458872+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-04T17:00:00+00:00 TriggerDagRunOperator 2021-05-04T18:10:56.921537+00:00 2021-05-04T18:10:57.375664+00:00 0:00:00.454127 24455 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T18:10:54.458919+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-04T17:05:00+00:00 EmrJobFlowSensor 2021-05-04T18:05:54.277198+00:00 2021-05-04T18:14:56.827144+00:00 0:09:02.549946 24454 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T18:05:51.844685+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-04T17:05:00+00:00 EmrCreateJobFlowOperator 2021-05-04T18:05:33.912760+00:00 2021-05-04T18:05:35.647097+00:00 0:00:01.734337 24453 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-04T18:05:31.734482+00:00 2 default_pool