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 booking-processing-job_v002 check_cluster_status 2021-04-03T12:00:00+00:00 EmrJobFlowSensor 2021-04-03T13:11:49.645292+00:00 2021-04-03T13:20:52.369108+00:00 0:09:02.723816 13136 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T13:11:47.313189+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-03T12:00:00+00:00 EmrJobFlowSensor 2021-04-03T13:11:33.608407+00:00 2021-04-03T13:20:36.166141+00:00 0:09:02.557734 13135 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T13:11:31.300564+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-03T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T13:11:27.822368+00:00 2021-04-03T13:11:29.609085+00:00 0:00:01.786717 13134 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T13:11:25.377369+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-03T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T13:11:13.539309+00:00 2021-04-03T13:11:15.304564+00:00 0:00:01.765255 13133 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T13:11:11.273261+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-03T12:00:00+00:00 PythonOperator 2021-04-03T13:11:07.392707+00:00 2021-04-03T13:11:10.385201+00:00 0:00:02.992494 13132 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T13:11:05.271766+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-03T12:00:00+00:00 PythonOperator 2021-04-03T13:10:51.522376+00:00 2021-04-03T13:10:54.349723+00:00 0:00:02.827347 13131 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T13:10:49.257386+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-03T12:00:00+00:00 TriggerDagRunOperator 2021-04-03T13:10:43.763979+00:00 2021-04-03T13:10:44.286634+00:00 0:00:00.522655 13130 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T13:10:41.251131+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-03T12:00:00+00:00 TriggerDagRunOperator 2021-04-03T13:10:43.668133+00:00 2021-04-03T13:10:44.230560+00:00 0:00:00.562427 13129 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T13:10:41.251099+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-03T12:05:00+00:00 EmrJobFlowSensor 2021-04-03T13:05:49.196036+00:00 2021-04-03T13:14:51.689189+00:00 0:09:02.493153 13128 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T13:05:46.846503+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-03T12:05:00+00:00 EmrCreateJobFlowOperator 2021-04-03T13:05:29.037861+00:00 2021-04-03T13:05:30.763697+00:00 0:00:01.725836 13127 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T13:05:26.743569+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-03T12:05:00+00:00 PythonOperator 2021-04-03T13:05:06.955400+00:00 2021-04-03T13:05:09.634394+00:00 0:00:02.678994 13126 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T13:05:04.723138+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-03T12:00:00+00:00 EmrJobFlowSensor 2021-04-03T13:01:34.660847+00:00 2021-04-03T13:10:37.291892+00:00 0:09:02.631045 13125 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T13:01:32.436201+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-03T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T13:01:12.731903+00:00 2021-04-03T13:01:14.420882+00:00 0:00:01.688979 13124 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-03T13:01:10.381219+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-03T12:00:00+00:00 PythonOperator 2021-04-03T13:00:52.771125+00:00 2021-04-03T13:00:55.630198+00:00 0:00:02.859073 13123 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-03T13:00:50.355010+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-03T11:00:00+00:00 EmrJobFlowSensor 2021-04-03T12:11:10.214770+00:00 2021-04-03T12:21:12.949093+00:00 0:10:02.734323 13121 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T12:11:07.889322+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-03T11:00:00+00:00 EmrJobFlowSensor 2021-04-03T12:11:06.359366+00:00 2021-04-03T12:21:09.187665+00:00 0:10:02.828299 13120 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T12:11:03.956055+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-03T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T12:10:48.140251+00:00 2021-04-03T12:10:49.867189+00:00 0:00:01.726938 13119 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T12:10:45.834002+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-03T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T12:10:44.022730+00:00 2021-04-03T12:10:45.697243+00:00 0:00:01.674513 13118 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T12:10:41.830435+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-03T11:00:00+00:00 PythonOperator 2021-04-03T12:10:28.477404+00:00 2021-04-03T12:10:31.728337+00:00 0:00:03.250933 13117 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T12:10:25.814849+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-03T11:00:00+00:00 PythonOperator 2021-04-03T12:10:22.034382+00:00 2021-04-03T12:10:24.872587+00:00 0:00:02.838205 13116 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T12:10:19.810818+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-03T11:00:00+00:00 TriggerDagRunOperator 2021-04-03T12:10:18.179760+00:00 2021-04-03T12:10:18.737215+00:00 0:00:00.557455 13115 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T12:10:15.807247+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-03T11:00:00+00:00 TriggerDagRunOperator 2021-04-03T12:10:18.020949+00:00 2021-04-03T12:10:18.423106+00:00 0:00:00.402157 13114 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T12:10:15.807213+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-03T11:05:00+00:00 EmrJobFlowSensor 2021-04-03T12:05:53.551671+00:00 2021-04-03T12:14:56.105605+00:00 0:09:02.553934 13113 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T12:05:51.324827+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-03T11:05:00+00:00 EmrCreateJobFlowOperator 2021-04-03T12:05:33.698098+00:00 2021-04-03T12:05:35.452418+00:00 0:00:01.754320 13112 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T12:05:31.309352+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-03T11:05:00+00:00 PythonOperator 2021-04-03T12:05:11.683056+00:00 2021-04-03T12:05:14.505781+00:00 0:00:02.822725 13111 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T12:05:09.292086+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-03T11:00:00+00:00 EmrJobFlowSensor 2021-04-03T12:00:55.459721+00:00 2021-04-03T12:09:58.293362+00:00 0:09:02.833641 13110 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T12:00:52.940884+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-03T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T12:00:33.231197+00:00 2021-04-03T12:00:34.968728+00:00 0:00:01.737531 13109 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-03T12:00:30.866166+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-03T11:00:00+00:00 PythonOperator 2021-04-03T12:00:13.098756+00:00 2021-04-03T12:00:15.801771+00:00 0:00:02.703015 13108 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-03T12:00:10.798905+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-03T10:00:00+00:00 EmrJobFlowSensor 2021-04-03T11:12:28.196996+00:00 2021-04-03T11:21:30.925257+00:00 0:09:02.728261 13106 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T11:12:25.804551+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-03T10:00:00+00:00 EmrJobFlowSensor 2021-04-03T11:12:24.249988+00:00 2021-04-03T11:21:26.874053+00:00 0:09:02.624065 13105 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T11:12:21.800660+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-03T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T11:12:06.360455+00:00 2021-04-03T11:12:08.179488+00:00 0:00:01.819033 13104 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T11:12:03.856224+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-03T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T11:12:02.102388+00:00 2021-04-03T11:12:03.793590+00:00 0:00:01.691202 13103 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T11:11:59.782569+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-03T10:00:00+00:00 PythonOperator 2021-04-03T11:11:46.299954+00:00 2021-04-03T11:11:49.479734+00:00 0:00:03.179780 13102 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T11:11:43.752903+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-03T10:00:00+00:00 PythonOperator 2021-04-03T11:11:42.115520+00:00 2021-04-03T11:11:44.996891+00:00 0:00:02.881371 13101 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T11:11:39.762579+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-03T10:00:00+00:00 TriggerDagRunOperator 2021-04-03T11:11:18.058639+00:00 2021-04-03T11:11:18.650358+00:00 0:00:00.591719 13100 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T11:11:15.654997+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-03T10:00:00+00:00 TriggerDagRunOperator 2021-04-03T11:11:17.912331+00:00 2021-04-03T11:11:18.559014+00:00 0:00:00.646683 13099 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T11:11:15.654963+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-03T10:05:00+00:00 EmrJobFlowSensor 2021-04-03T11:05:57.382247+00:00 2021-04-03T11:14:59.950477+00:00 0:09:02.568230 13098 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T11:05:55.259055+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-03T10:05:00+00:00 EmrCreateJobFlowOperator 2021-04-03T11:05:35.484499+00:00 2021-04-03T11:05:37.110100+00:00 0:00:01.625601 13097 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T11:05:33.242068+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-03T10:05:00+00:00 PythonOperator 2021-04-03T11:05:13.491232+00:00 2021-04-03T11:05:16.286325+00:00 0:00:02.795093 13096 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T11:05:11.217058+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-03T10:00:00+00:00 EmrJobFlowSensor 2021-04-03T11:01:05.031970+00:00 2021-04-03T11:11:07.833000+00:00 0:10:02.801030 13095 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T11:01:02.814752+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-03T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T11:00:43.101160+00:00 2021-04-03T11:00:44.766341+00:00 0:00:01.665181 13094 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-03T11:00:40.795181+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-03T10:00:00+00:00 PythonOperator 2021-04-03T11:00:21.629893+00:00 2021-04-03T11:00:24.555713+00:00 0:00:02.925820 13093 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-03T11:00:18.772559+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-03T09:00:00+00:00 EmrJobFlowSensor 2021-04-03T10:10:26.592192+00:00 2021-04-03T10:20:29.364078+00:00 0:10:02.771886 13091 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T10:10:24.178286+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-03T09:00:00+00:00 EmrJobFlowSensor 2021-04-03T10:10:06.574653+00:00 2021-04-03T10:19:09.459985+00:00 0:09:02.885332 13090 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T10:10:04.098016+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-03T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T10:10:06.380536+00:00 2021-04-03T10:10:08.153962+00:00 0:00:01.773426 13089 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T10:10:04.098055+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-03T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T10:09:46.372234+00:00 2021-04-03T10:09:48.206154+00:00 0:00:01.833920 13088 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T10:09:44.074850+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-03T09:00:00+00:00 PythonOperator 2021-04-03T10:09:44.207212+00:00 2021-04-03T10:09:47.104345+00:00 0:00:02.897133 13087 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T10:09:42.071807+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-03T09:00:00+00:00 PythonOperator 2021-04-03T10:09:24.326195+00:00 2021-04-03T10:09:27.141904+00:00 0:00:02.815709 13086 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T10:09:22.053943+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-03T09:00:00+00:00 TriggerDagRunOperator 2021-04-03T10:09:18.662292+00:00 2021-04-03T10:09:19.335310+00:00 0:00:00.673018 13085 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T10:09:16.048637+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-03T09:00:00+00:00 TriggerDagRunOperator 2021-04-03T10:09:18.296803+00:00 2021-04-03T10:09:18.729698+00:00 0:00:00.432895 13084 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T10:09:16.048674+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-03T09:05:00+00:00 EmrJobFlowSensor 2021-04-03T10:05:58.230137+00:00 2021-04-03T10:15:00.958390+00:00 0:09:02.728253 13083 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T10:05:55.812243+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-03T09:05:00+00:00 EmrCreateJobFlowOperator 2021-04-03T10:05:35.961427+00:00 2021-04-03T10:05:37.593070+00:00 0:00:01.631643 13082 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T10:05:33.787686+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-03T09:05:00+00:00 PythonOperator 2021-04-03T10:05:09.906704+00:00 2021-04-03T10:05:12.593463+00:00 0:00:02.686759 13081 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T10:05:07.749429+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-03T09:00:00+00:00 EmrJobFlowSensor 2021-04-03T10:01:05.714149+00:00 2021-04-03T10:09:08.387605+00:00 0:08:02.673456 13080 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T10:01:03.342512+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-03T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T10:00:45.543173+00:00 2021-04-03T10:00:47.271738+00:00 0:00:01.728565 13079 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-03T10:00:43.251617+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-03T09:00:00+00:00 PythonOperator 2021-04-03T10:00:23.807227+00:00 2021-04-03T10:00:26.594550+00:00 0:00:02.787323 13078 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-03T10:00:21.234836+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-03T08:00:00+00:00 EmrJobFlowSensor 2021-04-03T09:10:36.744110+00:00 2021-04-03T09:20:39.543416+00:00 0:10:02.799306 13076 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T09:10:34.390029+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-03T08:00:00+00:00 EmrJobFlowSensor 2021-04-03T09:10:28.696070+00:00 2021-04-03T09:19:31.316589+00:00 0:09:02.620519 13075 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T09:10:26.388886+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-03T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T09:10:14.759877+00:00 2021-04-03T09:10:16.499323+00:00 0:00:01.739446 13074 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T09:10:12.364210+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-03T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T09:10:08.698668+00:00 2021-04-03T09:10:10.500471+00:00 0:00:01.801803 13073 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T09:10:06.354530+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-03T08:00:00+00:00 PythonOperator 2021-04-03T09:09:52.801829+00:00 2021-04-03T09:09:55.754671+00:00 0:00:02.952842 13072 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T09:09:50.303596+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-03T08:00:00+00:00 PythonOperator 2021-04-03T09:09:46.612474+00:00 2021-04-03T09:09:49.330609+00:00 0:00:02.718135 13071 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T09:09:44.305458+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-03T08:00:00+00:00 TriggerDagRunOperator 2021-04-03T09:09:28.942804+00:00 2021-04-03T09:09:29.503759+00:00 0:00:00.560955 13070 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T09:09:26.285917+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-03T08:00:00+00:00 TriggerDagRunOperator 2021-04-03T09:09:28.752335+00:00 2021-04-03T09:09:29.150075+00:00 0:00:00.397740 13069 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T09:09:26.285866+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-03T08:05:00+00:00 EmrJobFlowSensor 2021-04-03T09:05:52.100793+00:00 2021-04-03T09:13:54.522646+00:00 0:08:02.421853 13068 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T09:05:49.926371+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-03T08:05:00+00:00 EmrCreateJobFlowOperator 2021-04-03T09:05:32.284567+00:00 2021-04-03T09:05:33.985268+00:00 0:00:01.700701 13067 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T09:05:29.911245+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-03T08:05:00+00:00 PythonOperator 2021-04-03T09:05:10.201830+00:00 2021-04-03T09:05:13.002983+00:00 0:00:02.801153 13066 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T09:05:07.895101+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-03T08:00:00+00:00 EmrJobFlowSensor 2021-04-03T09:01:05.789275+00:00 2021-04-03T09:09:08.422139+00:00 0:08:02.632864 13065 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T09:01:03.444342+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-03T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T09:00:43.589904+00:00 2021-04-03T09:00:45.352163+00:00 0:00:01.762259 13064 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-03T09:00:41.245367+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-03T08:00:00+00:00 PythonOperator 2021-04-03T09:00:23.640196+00:00 2021-04-03T09:00:26.510034+00:00 0:00:02.869838 13063 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-03T09:00:21.186755+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-03T07:00:00+00:00 EmrJobFlowSensor 2021-04-03T08:12:06.131240+00:00 2021-04-03T08:23:09.100738+00:00 0:11:02.969498 13061 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T08:12:03.889362+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-03T07:00:00+00:00 EmrJobFlowSensor 2021-04-03T08:11:56.395278+00:00 2021-04-03T08:21:59.208143+00:00 0:10:02.812865 13060 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T08:11:53.875106+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-03T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T08:11:44.123436+00:00 2021-04-03T08:11:45.792481+00:00 0:00:01.669045 13059 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T08:11:41.845781+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-03T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T08:11:36.309799+00:00 2021-04-03T08:11:38.163613+00:00 0:00:01.853814 13058 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T08:11:33.840220+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-03T07:00:00+00:00 PythonOperator 2021-04-03T08:11:22.009438+00:00 2021-04-03T08:11:25.072578+00:00 0:00:03.063140 13057 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T08:11:19.824928+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-03T07:00:00+00:00 PythonOperator 2021-04-03T08:11:12.539849+00:00 2021-04-03T08:11:15.288630+00:00 0:00:02.748781 13056 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T08:11:09.944773+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-03T07:00:00+00:00 TriggerDagRunOperator 2021-04-03T08:11:00.313349+00:00 2021-04-03T08:11:00.874915+00:00 0:00:00.561566 13055 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T08:10:57.879188+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-03T07:00:00+00:00 TriggerDagRunOperator 2021-04-03T08:11:00.294180+00:00 2021-04-03T08:11:00.762353+00:00 0:00:00.468173 13054 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T08:10:57.879152+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-03T07:05:00+00:00 EmrJobFlowSensor 2021-04-03T08:06:07.447690+00:00 2021-04-03T08:15:10.077660+00:00 0:09:02.629970 13053 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T08:06:05.277587+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-03T07:05:00+00:00 EmrCreateJobFlowOperator 2021-04-03T08:05:45.617374+00:00 2021-04-03T08:05:47.327472+00:00 0:00:01.710098 13052 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T08:05:43.257379+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-03T07:05:00+00:00 PythonOperator 2021-04-03T08:05:25.727453+00:00 2021-04-03T08:05:28.543096+00:00 0:00:02.815643 13051 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T08:05:23.245489+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-03T07:00:00+00:00 EmrJobFlowSensor 2021-04-03T08:00:52.890634+00:00 2021-04-03T08:10:55.691278+00:00 0:10:02.800644 13050 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T08:00:50.689622+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-03T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T08:00:32.927547+00:00 2021-04-03T08:00:34.776432+00:00 0:00:01.848885 13049 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-03T08:00:30.658984+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-03T07:00:00+00:00 PythonOperator 2021-04-03T08:00:10.923863+00:00 2021-04-03T08:00:13.853681+00:00 0:00:02.929818 13048 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-03T08:00:08.591893+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-03T06:00:00+00:00 EmrJobFlowSensor 2021-04-03T07:11:18.342945+00:00 2021-04-03T07:21:21.198924+00:00 0:10:02.855979 13046 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T07:11:15.955576+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-03T06:00:00+00:00 EmrJobFlowSensor 2021-04-03T07:11:10.523694+00:00 2021-04-03T07:20:13.147058+00:00 0:09:02.623364 13045 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T07:11:07.890290+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-03T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T07:10:58.030455+00:00 2021-04-03T07:10:59.867130+00:00 0:00:01.836675 13044 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T07:10:55.847901+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-03T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T07:10:50.143806+00:00 2021-04-03T07:10:51.965624+00:00 0:00:01.821818 13043 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T07:10:47.837211+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-03T06:00:00+00:00 PythonOperator 2021-04-03T07:10:36.144580+00:00 2021-04-03T07:10:39.018367+00:00 0:00:02.873787 13042 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T07:10:33.827449+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-03T06:00:00+00:00 PythonOperator 2021-04-03T07:10:28.192554+00:00 2021-04-03T07:10:31.237761+00:00 0:00:03.045207 13041 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T07:10:25.822117+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-03T06:00:00+00:00 TriggerDagRunOperator 2021-04-03T07:10:16.109604+00:00 2021-04-03T07:10:16.657131+00:00 0:00:00.547527 13040 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T07:10:13.809417+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-03T06:00:00+00:00 TriggerDagRunOperator 2021-04-03T07:10:16.043664+00:00 2021-04-03T07:10:16.435073+00:00 0:00:00.391409 13039 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T07:10:13.809453+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-03T06:05:00+00:00 EmrJobFlowSensor 2021-04-03T07:05:57.366944+00:00 2021-04-03T07:14:59.936872+00:00 0:09:02.569928 13038 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T07:05:55.168604+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-03T06:05:00+00:00 EmrCreateJobFlowOperator 2021-04-03T07:05:31.285723+00:00 2021-04-03T07:05:32.949389+00:00 0:00:01.663666 13037 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T07:05:29.158475+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-03T06:05:00+00:00 PythonOperator 2021-04-03T07:05:09.660724+00:00 2021-04-03T07:05:12.340388+00:00 0:00:02.679664 13036 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T07:05:07.244096+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-03T06:00:00+00:00 EmrJobFlowSensor 2021-04-03T07:00:52.923857+00:00 2021-04-03T07:09:55.620092+00:00 0:09:02.696235 13035 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T07:00:50.622715+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-03T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T07:00:30.938049+00:00 2021-04-03T07:00:32.811865+00:00 0:00:01.873816 13034 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-03T07:00:28.607397+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-03T06:00:00+00:00 PythonOperator 2021-04-03T07:00:09.319524+00:00 2021-04-03T07:00:12.237709+00:00 0:00:02.918185 13033 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-03T07:00:06.646194+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-03T05:00:00+00:00 EmrJobFlowSensor 2021-04-03T06:12:16.419511+00:00 2021-04-03T06:22:19.378524+00:00 0:10:02.959013 13031 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T06:12:14.086136+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-03T05:00:00+00:00 EmrJobFlowSensor 2021-04-03T06:12:12.179510+00:00 2021-04-03T06:21:14.762368+00:00 0:09:02.582858 13030 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T06:12:10.037562+00:00 2 default_pool