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 create_emr_steps 2021-04-28T04:00:00+00:00 PythonOperator 2021-04-28T05:11:46.989299+00:00 2021-04-28T05:11:50.340558+00:00 0:00:03.351259 22087 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T05:11:44.659146+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-28T04:00:00+00:00 PythonOperator 2021-04-28T05:11:41.008803+00:00 2021-04-28T05:11:44.075590+00:00 0:00:03.066787 22086 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T05:11:38.656153+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-28T04:00:00+00:00 TriggerDagRunOperator 2021-04-28T05:11:20.957838+00:00 2021-04-28T05:11:21.470389+00:00 0:00:00.512551 22085 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T05:11:18.585830+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-28T04:00:00+00:00 TriggerDagRunOperator 2021-04-28T05:11:20.823771+00:00 2021-04-28T05:11:21.242431+00:00 0:00:00.418660 22084 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T05:11:18.585863+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-28T04:05:00+00:00 EmrJobFlowSensor 2021-04-28T05:06:08.544108+00:00 2021-04-28T05:15:11.142713+00:00 0:09:02.598605 22083 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T05:06:06.089583+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-28T04:05:00+00:00 EmrCreateJobFlowOperator 2021-04-28T05:05:46.205060+00:00 2021-04-28T05:05:47.868761+00:00 0:00:01.663701 22082 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T05:05:44.055599+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-28T04:05:00+00:00 PythonOperator 2021-04-28T05:05:24.043407+00:00 2021-04-28T05:05:27.046529+00:00 0:00:03.003122 22081 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T05:05:21.956479+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-28T04:00:00+00:00 EmrJobFlowSensor 2021-04-28T05:01:00.364612+00:00 2021-04-28T05:11:03.300559+00:00 0:10:02.935947 22080 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T05:00:57.652700+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-28T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T05:00:38.061692+00:00 2021-04-28T05:00:39.766238+00:00 0:00:01.704546 22079 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-28T05:00:35.652241+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-28T04:00:00+00:00 PythonOperator 2021-04-28T05:00:17.925890+00:00 2021-04-28T05:00:20.895831+00:00 0:00:02.969941 22078 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-28T05:00:15.569881+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-28T03:00:00+00:00 EmrJobFlowSensor 2021-04-28T04:11:14.419436+00:00 2021-04-28T04:19:16.915318+00:00 0:08:02.495882 22076 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T04:11:11.986677+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-28T03:00:00+00:00 EmrJobFlowSensor 2021-04-28T04:11:10.379174+00:00 2021-04-28T04:20:13.131118+00:00 0:09:02.751944 22075 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T04:11:07.984047+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-28T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T04:10:52.095306+00:00 2021-04-28T04:10:53.833083+00:00 0:00:01.737777 22074 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T04:10:49.959915+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-28T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T04:10:48.196794+00:00 2021-04-28T04:10:49.935992+00:00 0:00:01.739198 22073 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T04:10:45.956389+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-28T03:00:00+00:00 PythonOperator 2021-04-28T04:10:30.747501+00:00 2021-04-28T04:10:34.040805+00:00 0:00:03.293304 22072 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T04:10:27.946161+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-28T03:00:00+00:00 PythonOperator 2021-04-28T04:10:26.236053+00:00 2021-04-28T04:10:29.828060+00:00 0:00:03.592007 22071 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T04:10:23.933369+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-28T03:00:00+00:00 TriggerDagRunOperator 2021-04-28T04:10:14.448487+00:00 2021-04-28T04:10:14.879254+00:00 0:00:00.430767 22070 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T04:10:11.922237+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-28T03:00:00+00:00 TriggerDagRunOperator 2021-04-28T04:10:14.229285+00:00 2021-04-28T04:10:14.827979+00:00 0:00:00.598694 22069 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T04:10:11.922269+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-28T03:05:00+00:00 EmrJobFlowSensor 2021-04-28T04:05:53.857460+00:00 2021-04-28T04:15:56.484581+00:00 0:10:02.627121 22068 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T04:05:51.654394+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-28T03:05:00+00:00 EmrCreateJobFlowOperator 2021-04-28T04:05:33.909233+00:00 2021-04-28T04:05:35.663613+00:00 0:00:01.754380 22067 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T04:05:31.573859+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-28T03:05:00+00:00 PythonOperator 2021-04-28T04:05:11.703595+00:00 2021-04-28T04:05:14.695933+00:00 0:00:02.992338 22066 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T04:05:09.516176+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-28T03:00:00+00:00 EmrJobFlowSensor 2021-04-28T04:01:03.026255+00:00 2021-04-28T04:10:05.608461+00:00 0:09:02.582206 22065 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T04:01:00.853944+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-28T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T04:00:41.239213+00:00 2021-04-28T04:00:42.955146+00:00 0:00:01.715933 22064 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-28T04:00:38.815066+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-28T03:00:00+00:00 PythonOperator 2021-04-28T04:00:19.693468+00:00 2021-04-28T04:00:22.690842+00:00 0:00:02.997374 22063 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-28T04:00:16.851003+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-28T02:00:00+00:00 EmrJobFlowSensor 2021-04-28T03:12:16.013735+00:00 2021-04-28T03:21:18.671772+00:00 0:09:02.658037 22061 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T03:12:13.565876+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-28T02:00:00+00:00 EmrJobFlowSensor 2021-04-28T03:12:07.910148+00:00 2021-04-28T03:21:10.662859+00:00 0:09:02.752711 22060 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T03:12:05.555722+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-28T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T03:11:53.831924+00:00 2021-04-28T03:11:55.659797+00:00 0:00:01.827873 22059 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T03:11:51.432172+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-28T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T03:11:47.665834+00:00 2021-04-28T03:11:49.358908+00:00 0:00:01.693074 22058 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T03:11:45.425093+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-28T02:00:00+00:00 PythonOperator 2021-04-28T03:11:33.698761+00:00 2021-04-28T03:11:36.952391+00:00 0:00:03.253630 22057 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T03:11:31.413221+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-28T02:00:00+00:00 PythonOperator 2021-04-28T03:11:25.637567+00:00 2021-04-28T03:11:28.662756+00:00 0:00:03.025189 22056 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T03:11:23.406105+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-28T02:00:00+00:00 TriggerDagRunOperator 2021-04-28T03:11:15.822441+00:00 2021-04-28T03:11:16.238728+00:00 0:00:00.416287 22055 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T03:11:13.406499+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-28T02:00:00+00:00 TriggerDagRunOperator 2021-04-28T03:11:15.675147+00:00 2021-04-28T03:11:16.233534+00:00 0:00:00.558387 22054 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T03:11:13.406449+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-28T02:05:00+00:00 EmrJobFlowSensor 2021-04-28T03:06:08.983061+00:00 2021-04-28T03:14:11.509564+00:00 0:08:02.526503 22053 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T03:06:06.646263+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-28T02:05:00+00:00 EmrCreateJobFlowOperator 2021-04-28T03:05:44.772882+00:00 2021-04-28T03:05:46.450474+00:00 0:00:01.677592 22052 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T03:05:42.600445+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-28T02:05:00+00:00 PythonOperator 2021-04-28T03:05:22.811067+00:00 2021-04-28T03:05:25.784539+00:00 0:00:02.973472 22051 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T03:05:20.528945+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-28T02:00:00+00:00 EmrJobFlowSensor 2021-04-28T03:01:06.410961+00:00 2021-04-28T03:11:09.293084+00:00 0:10:02.882123 22050 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T03:01:04.187996+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-28T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T03:00:44.784626+00:00 2021-04-28T03:00:46.611183+00:00 0:00:01.826557 22049 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-28T03:00:42.122088+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-28T02:00:00+00:00 PythonOperator 2021-04-28T03:00:22.497636+00:00 2021-04-28T03:00:25.505601+00:00 0:00:03.007965 22048 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-28T03:00:20.103423+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-28T01:00:00+00:00 EmrJobFlowSensor 2021-04-28T02:11:27.544652+00:00 2021-04-28T02:19:29.951143+00:00 0:08:02.406491 22046 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T02:11:25.071004+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-28T01:00:00+00:00 EmrJobFlowSensor 2021-04-28T02:11:21.104395+00:00 2021-04-28T02:23:24.250094+00:00 0:12:03.145699 22045 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T02:11:18.989064+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-28T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T02:11:07.284960+00:00 2021-04-28T02:11:08.988201+00:00 0:00:01.703241 22044 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T02:11:04.949938+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-28T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T02:11:01.242378+00:00 2021-04-28T02:11:03.113487+00:00 0:00:01.871109 22043 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T02:10:58.893324+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-28T01:00:00+00:00 PythonOperator 2021-04-28T02:10:43.156581+00:00 2021-04-28T02:10:46.165562+00:00 0:00:03.008981 22042 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T02:10:40.870687+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-28T01:00:00+00:00 PythonOperator 2021-04-28T02:10:27.665310+00:00 2021-04-28T02:10:30.915401+00:00 0:00:03.250091 22041 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T02:10:24.860676+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-28T01:00:00+00:00 TriggerDagRunOperator 2021-04-28T02:10:19.206879+00:00 2021-04-28T02:10:19.690907+00:00 0:00:00.484028 22040 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T02:10:16.853103+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-28T01:00:00+00:00 TriggerDagRunOperator 2021-04-28T02:10:19.177598+00:00 2021-04-28T02:10:19.757672+00:00 0:00:00.580074 22039 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T02:10:16.853070+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-28T01:05:00+00:00 EmrJobFlowSensor 2021-04-28T02:06:02.498621+00:00 2021-04-28T02:14:05.005816+00:00 0:08:02.507195 22038 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T02:06:00.323855+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-28T01:05:00+00:00 EmrCreateJobFlowOperator 2021-04-28T02:05:42.545565+00:00 2021-04-28T02:05:44.226250+00:00 0:00:01.680685 22037 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T02:05:40.294427+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-28T01:05:00+00:00 PythonOperator 2021-04-28T02:05:20.695603+00:00 2021-04-28T02:05:23.685924+00:00 0:00:02.990321 22036 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T02:05:18.264188+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-28T01:00:00+00:00 EmrJobFlowSensor 2021-04-28T02:01:04.148111+00:00 2021-04-28T02:10:06.799899+00:00 0:09:02.651788 22035 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T02:01:01.902857+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-28T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T02:00:42.254761+00:00 2021-04-28T02:00:44.050260+00:00 0:00:01.795499 22034 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-28T02:00:39.948226+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-28T01:00:00+00:00 PythonOperator 2021-04-28T02:00:22.783321+00:00 2021-04-28T02:00:25.780983+00:00 0:00:02.997662 22033 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-28T02:00:19.829406+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-28T00:00:00+00:00 EmrJobFlowSensor 2021-04-28T01:10:09.343994+00:00 2021-04-28T01:18:11.901278+00:00 0:08:02.557284 22031 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T01:10:06.776593+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-28T00:00:00+00:00 EmrJobFlowSensor 2021-04-28T01:10:09.229311+00:00 2021-04-28T01:20:12.095344+00:00 0:10:02.866033 22030 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T01:10:06.776548+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-28T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T01:09:47.148728+00:00 2021-04-28T01:09:48.941290+00:00 0:00:01.792562 22029 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T01:09:44.683727+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-28T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T01:09:47.033263+00:00 2021-04-28T01:09:48.742035+00:00 0:00:01.708772 22028 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T01:09:44.683694+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-28T00:00:00+00:00 PythonOperator 2021-04-28T01:09:27.017395+00:00 2021-04-28T01:09:30.319738+00:00 0:00:03.302343 22027 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T01:09:24.670468+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-28T00:00:00+00:00 PythonOperator 2021-04-28T01:09:25.006523+00:00 2021-04-28T01:09:27.967026+00:00 0:00:02.960503 22026 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T01:09:22.674026+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-28T00:00:00+00:00 TriggerDagRunOperator 2021-04-28T01:09:15.233942+00:00 2021-04-28T01:09:15.798007+00:00 0:00:00.564065 22025 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T01:09:12.757910+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-28T00:00:00+00:00 TriggerDagRunOperator 2021-04-28T01:09:15.194931+00:00 2021-04-28T01:09:15.614308+00:00 0:00:00.419377 22024 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T01:09:12.757956+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-28T00:05:00+00:00 EmrJobFlowSensor 2021-04-28T01:06:06.611921+00:00 2021-04-28T01:15:09.285484+00:00 0:09:02.673563 22023 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T01:06:04.364896+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-28T00:05:00+00:00 EmrCreateJobFlowOperator 2021-04-28T01:05:44.602620+00:00 2021-04-28T01:05:46.306523+00:00 0:00:01.703903 22022 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T01:05:42.235260+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-28T00:05:00+00:00 PythonOperator 2021-04-28T01:05:22.713097+00:00 2021-04-28T01:05:25.680482+00:00 0:00:02.967385 22021 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T01:05:20.270129+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-28T00:00:00+00:00 EmrJobFlowSensor 2021-04-28T01:00:48.300655+00:00 2021-04-28T01:08:50.933736+00:00 0:08:02.633081 22020 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T01:00:45.955490+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-28T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T01:00:26.008451+00:00 2021-04-28T01:00:27.695511+00:00 0:00:01.687060 22019 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-28T01:00:23.865049+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-28T00:00:00+00:00 PythonOperator 2021-04-28T01:00:06.152762+00:00 2021-04-28T01:00:09.449598+00:00 0:00:03.296836 22018 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-28T01:00:03.844984+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-27T23:00:00+00:00 EmrJobFlowSensor 2021-04-28T00:10:29.430287+00:00 2021-04-28T00:18:31.880414+00:00 0:08:02.450127 22016 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T00:10:26.756536+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-27T23:00:00+00:00 EmrJobFlowSensor 2021-04-28T00:10:29.228951+00:00 2021-04-28T00:20:32.061011+00:00 0:10:02.832060 22015 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T00:10:26.756582+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-27T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T00:10:09.419966+00:00 2021-04-28T00:10:11.120441+00:00 0:00:01.700475 22014 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T00:10:06.669775+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-27T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T00:10:06.949133+00:00 2021-04-28T00:10:09.039734+00:00 0:00:02.090601 22013 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T00:10:04.766605+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-27T23:00:00+00:00 PythonOperator 2021-04-28T00:09:47.061766+00:00 2021-04-28T00:09:50.051832+00:00 0:00:02.990066 22012 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T00:09:44.670838+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-27T23:00:00+00:00 PythonOperator 2021-04-28T00:09:46.959391+00:00 2021-04-28T00:09:50.226484+00:00 0:00:03.267093 22011 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T00:09:44.670872+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-27T23:00:00+00:00 TriggerDagRunOperator 2021-04-28T00:09:31.139552+00:00 2021-04-28T00:09:31.559655+00:00 0:00:00.420103 22010 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T00:09:28.587459+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-27T23:00:00+00:00 TriggerDagRunOperator 2021-04-28T00:09:31.167619+00:00 2021-04-28T00:09:31.697060+00:00 0:00:00.529441 22009 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T00:09:28.587413+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-27T23:05:00+00:00 EmrJobFlowSensor 2021-04-28T00:05:54.605800+00:00 2021-04-28T00:14:57.232742+00:00 0:09:02.626942 22008 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-28T00:05:52.257681+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-27T23:05:00+00:00 EmrCreateJobFlowOperator 2021-04-28T00:05:34.612687+00:00 2021-04-28T00:05:36.285830+00:00 0:00:01.673143 22007 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-28T00:05:32.185176+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-27T23:05:00+00:00 PythonOperator 2021-04-28T00:05:12.386043+00:00 2021-04-28T00:05:15.474428+00:00 0:00:03.088385 22006 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T00:05:10.161959+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-27T23:00:00+00:00 EmrJobFlowSensor 2021-04-28T00:01:11.939100+00:00 2021-04-28T00:09:14.510193+00:00 0:08:02.571093 22005 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-28T00:01:09.719189+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-27T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-28T00:00:37.909185+00:00 2021-04-28T00:00:39.768451+00:00 0:00:01.859266 22004 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-28T00:00:35.691396+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-27T23:00:00+00:00 PythonOperator 2021-04-28T00:00:16.026816+00:00 2021-04-28T00:00:19.071397+00:00 0:00:03.044581 22003 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-28T00:00:13.626261+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-27T22:00:00+00:00 EmrJobFlowSensor 2021-04-27T23:11:19.883268+00:00 2021-04-27T23:21:22.688800+00:00 0:10:02.805532 22001 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T23:11:17.782881+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-27T22:00:00+00:00 EmrJobFlowSensor 2021-04-27T23:11:08.100181+00:00 2021-04-27T23:20:10.629468+00:00 0:09:02.529287 22000 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T23:11:05.844493+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-27T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T23:10:57.968438+00:00 2021-04-27T23:10:59.829911+00:00 0:00:01.861473 21999 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T23:10:55.750016+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-27T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T23:10:48.138178+00:00 2021-04-27T23:10:49.943630+00:00 0:00:01.805452 21998 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T23:10:45.766995+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-27T22:00:00+00:00 PythonOperator 2021-04-27T23:10:35.923114+00:00 2021-04-27T23:10:39.119198+00:00 0:00:03.196084 21997 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T23:10:33.691461+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-27T22:00:00+00:00 PythonOperator 2021-04-27T23:10:25.883813+00:00 2021-04-27T23:10:28.862124+00:00 0:00:02.978311 21996 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T23:10:23.659435+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-27T22:00:00+00:00 TriggerDagRunOperator 2021-04-27T23:10:14.129060+00:00 2021-04-27T23:10:14.524697+00:00 0:00:00.395637 21995 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T23:10:11.650094+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-27T22:00:00+00:00 TriggerDagRunOperator 2021-04-27T23:10:13.970796+00:00 2021-04-27T23:10:14.510460+00:00 0:00:00.539664 21994 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T23:10:11.650128+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-27T22:05:00+00:00 EmrJobFlowSensor 2021-04-27T23:05:59.341633+00:00 2021-04-27T23:16:02.103181+00:00 0:10:02.761548 21993 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T23:05:57.210817+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-27T22:05:00+00:00 EmrCreateJobFlowOperator 2021-04-27T23:05:37.448831+00:00 2021-04-27T23:05:39.163555+00:00 0:00:01.714724 21992 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T23:05:35.195620+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-27T22:05:00+00:00 PythonOperator 2021-04-27T23:05:17.386910+00:00 2021-04-27T23:05:20.360707+00:00 0:00:02.973797 21991 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T23:05:15.128655+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-27T22:00:00+00:00 EmrJobFlowSensor 2021-04-27T23:01:05.309800+00:00 2021-04-27T23:10:07.988516+00:00 0:09:02.678716 21990 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T23:01:02.693302+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-04-26T23:00:00+00:00 EmrJobFlowSensor 2021-04-27T23:00:46.799933+00:00 2021-04-27T23:09:49.380803+00:00 0:09:02.580870 21989 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T23:00:44.624619+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-27T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T23:00:42.897626+00:00 2021-04-27T23:00:44.703880+00:00 0:00:01.806254 21988 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-27T23:00:40.611220+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-04-26T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T23:00:27.166336+00:00 2021-04-27T23:00:28.822764+00:00 0:00:01.656428 21987 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T23:00:24.602593+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-27T22:00:00+00:00 PythonOperator 2021-04-27T23:00:22.799362+00:00 2021-04-27T23:00:26.201084+00:00 0:00:03.401722 21986 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-27T23:00:20.596640+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-04-26T23:00:00+00:00 PythonOperator 2021-04-27T23:00:05.313455+00:00 2021-04-27T23:00:08.425898+00:00 0:00:03.112443 21985 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T23:00:02.585549+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-27T21:00:00+00:00 EmrJobFlowSensor 2021-04-27T22:12:24.767169+00:00 2021-04-27T22:21:27.471383+00:00 0:09:02.704214 21983 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T22:12:22.602339+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-27T21:00:00+00:00 EmrJobFlowSensor 2021-04-27T22:12:16.726425+00:00 2021-04-27T22:22:19.604812+00:00 0:10:02.878387 21982 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T22:12:14.595031+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-27T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T22:12:02.901015+00:00 2021-04-27T22:12:04.764048+00:00 0:00:01.863033 21981 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T22:12:00.583023+00:00 2 default_pool