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 trigger_dagrun_booking-processing-job_v002 2021-05-11T17:00:00+00:00 TriggerDagRunOperator 2021-05-11T18:11:28.352898+00:00 2021-05-11T18:11:28.769867+00:00 0:00:00.416969 26996 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T18:11:25.634564+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-11T17:05:00+00:00 EmrJobFlowSensor 2021-05-11T18:05:47.587862+00:00 2021-05-11T18:14:50.251017+00:00 0:09:02.663155 26994 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T18:05:45.232665+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-11T17:05:00+00:00 EmrCreateJobFlowOperator 2021-05-11T18:05:27.295519+00:00 2021-05-11T18:05:28.917639+00:00 0:00:01.622120 26993 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T18:05:25.219186+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-11T17:05:00+00:00 PythonOperator 2021-05-11T18:05:05.322140+00:00 2021-05-11T18:05:08.371635+00:00 0:00:03.049495 26992 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T18:05:03.189500+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-11T17:00:00+00:00 EmrJobFlowSensor 2021-05-11T18:01:02.993175+00:00 2021-05-11T18:09:05.632110+00:00 0:08:02.638935 26991 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T18:01:00.651334+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-11T17:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T18:00:40.790511+00:00 2021-05-11T18:00:42.497691+00:00 0:00:01.707180 26990 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-11T18:00:38.593530+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-11T17:00:00+00:00 PythonOperator 2021-05-11T18:00:18.901295+00:00 2021-05-11T18:00:22.019183+00:00 0:00:03.117888 26989 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-11T18:00:16.545581+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-11T16:00:00+00:00 EmrJobFlowSensor 2021-05-11T17:11:08.144786+00:00 2021-05-11T17:20:10.941506+00:00 0:09:02.796720 26988 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T17:11:05.887634+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-11T16:00:00+00:00 EmrJobFlowSensor 2021-05-11T17:11:08.077891+00:00 2021-05-11T17:22:11.152812+00:00 0:11:03.074921 26987 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T17:11:05.887670+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-11T16:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T17:10:47.941242+00:00 2021-05-11T17:10:49.640225+00:00 0:00:01.698983 26986 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T17:10:45.796182+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-11T16:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T17:10:44.317954+00:00 2021-05-11T17:10:46.035682+00:00 0:00:01.717728 26985 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T17:10:41.850295+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-11T16:00:00+00:00 PythonOperator 2021-05-11T17:10:24.284728+00:00 2021-05-11T17:10:27.425380+00:00 0:00:03.140652 26984 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T17:10:21.769448+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-11T16:00:00+00:00 PythonOperator 2021-05-11T17:10:21.797996+00:00 2021-05-11T17:10:25.134913+00:00 0:00:03.336917 26983 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T17:10:19.712053+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-11T16:00:00+00:00 TriggerDagRunOperator 2021-05-11T17:10:18.442859+00:00 2021-05-11T17:10:19.025880+00:00 0:00:00.583021 26982 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T17:10:15.861793+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-11T16:00:00+00:00 TriggerDagRunOperator 2021-05-11T17:10:18.177485+00:00 2021-05-11T17:10:18.647059+00:00 0:00:00.469574 26981 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T17:10:15.861837+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-11T16:05:00+00:00 EmrJobFlowSensor 2021-05-11T17:09:10.267892+00:00 2021-05-11T17:17:12.846826+00:00 0:08:02.578934 26980 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T17:09:07.741094+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-11T16:05:00+00:00 EmrCreateJobFlowOperator 2021-05-11T17:08:49.980964+00:00 2021-05-11T17:08:51.740240+00:00 0:00:01.759276 26979 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T17:08:47.594333+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-11T16:05:00+00:00 PythonOperator 2021-05-11T17:08:28.062747+00:00 2021-05-11T17:08:31.151584+00:00 0:00:03.088837 26978 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T17:08:25.565934+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-11T16:00:00+00:00 EmrJobFlowSensor 2021-05-11T17:01:05.300919+00:00 2021-05-11T17:10:08.035587+00:00 0:09:02.734668 26976 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T17:01:03.085074+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-11T16:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T17:00:43.213009+00:00 2021-05-11T17:00:44.915130+00:00 0:00:01.702121 26975 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-11T17:00:40.991724+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-11T16:00:00+00:00 PythonOperator 2021-05-11T17:00:21.161962+00:00 2021-05-11T17:00:24.280027+00:00 0:00:03.118065 26974 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-11T17:00:18.931149+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-11T15:00:00+00:00 EmrJobFlowSensor 2021-05-11T16:14:40.143600+00:00 2021-05-11T16:23:42.750994+00:00 0:09:02.607394 26973 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T16:14:38.005395+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-11T15:00:00+00:00 EmrJobFlowSensor 2021-05-11T16:14:38.321818+00:00 2021-05-11T16:23:41.067072+00:00 0:09:02.745254 26972 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T16:14:36.004481+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-11T15:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T16:14:20.123117+00:00 2021-05-11T16:14:21.808296+00:00 0:00:01.685179 26971 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T16:14:17.986232+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-11T15:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T16:14:16.089006+00:00 2021-05-11T16:14:17.825641+00:00 0:00:01.736635 26970 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T16:14:14.000700+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-11T15:00:00+00:00 PythonOperator 2021-05-11T16:13:58.515502+00:00 2021-05-11T16:14:01.607225+00:00 0:00:03.091723 26969 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T16:13:55.944616+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-11T15:00:00+00:00 PythonOperator 2021-05-11T16:13:56.292716+00:00 2021-05-11T16:13:59.816853+00:00 0:00:03.524137 26968 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T16:13:53.940260+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-11T15:00:00+00:00 TriggerDagRunOperator 2021-05-11T16:13:50.441326+00:00 2021-05-11T16:13:50.953801+00:00 0:00:00.512475 26967 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T16:13:47.939073+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-11T15:00:00+00:00 TriggerDagRunOperator 2021-05-11T16:13:50.296754+00:00 2021-05-11T16:13:50.714957+00:00 0:00:00.418203 26966 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T16:13:47.939042+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-11T15:05:00+00:00 EmrJobFlowSensor 2021-05-11T16:06:01.369421+00:00 2021-05-11T16:14:03.856195+00:00 0:08:02.486774 26965 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T16:05:59.270900+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-11T15:05:00+00:00 EmrCreateJobFlowOperator 2021-05-11T16:05:35.356061+00:00 2021-05-11T16:05:37.015239+00:00 0:00:01.659178 26964 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T16:05:33.241653+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-11T15:05:00+00:00 PythonOperator 2021-05-11T16:05:07.277808+00:00 2021-05-11T16:05:10.362086+00:00 0:00:03.084278 26963 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T16:05:05.210976+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-11T15:00:00+00:00 EmrJobFlowSensor 2021-05-11T16:04:37.315851+00:00 2021-05-11T16:13:40.039805+00:00 0:09:02.723954 26962 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T16:04:35.185129+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-11T15:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T16:04:15.295283+00:00 2021-05-11T16:04:16.971844+00:00 0:00:01.676561 26961 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-11T16:04:13.170206+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-11T15:00:00+00:00 PythonOperator 2021-05-11T16:03:55.744129+00:00 2021-05-11T16:03:59.070026+00:00 0:00:03.325897 26960 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-11T16:03:53.142373+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-11T14:00:00+00:00 EmrJobFlowSensor 2021-05-11T15:23:34.602841+00:00 2021-05-11T15:34:37.744889+00:00 0:11:03.142048 26958 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T15:23:32.226774+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-11T14:00:00+00:00 EmrJobFlowSensor 2021-05-11T15:23:30.488548+00:00 2021-05-11T15:33:33.261540+00:00 0:10:02.772992 26957 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T15:23:28.253140+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-11T14:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T15:23:14.659911+00:00 2021-05-11T15:23:16.509034+00:00 0:00:01.849123 26956 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T15:23:12.104814+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-11T14:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T15:23:08.366141+00:00 2021-05-11T15:23:10.160289+00:00 0:00:01.794148 26955 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T15:23:06.101383+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-11T14:00:00+00:00 PythonOperator 2021-05-11T15:22:52.269402+00:00 2021-05-11T15:22:55.542564+00:00 0:00:03.273162 26954 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T15:22:50.090056+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-11T14:00:00+00:00 PythonOperator 2021-05-11T15:22:46.506555+00:00 2021-05-11T15:22:49.636787+00:00 0:00:03.130232 26953 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T15:22:44.367321+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-11T14:00:00+00:00 TriggerDagRunOperator 2021-05-11T15:22:28.813566+00:00 2021-05-11T15:22:29.321133+00:00 0:00:00.507567 26952 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T15:22:25.979560+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-11T14:00:00+00:00 TriggerDagRunOperator 2021-05-11T15:22:28.599678+00:00 2021-05-11T15:22:29.017771+00:00 0:00:00.418093 26951 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T15:22:25.979532+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-11T14:05:00+00:00 EmrJobFlowSensor 2021-05-11T15:06:00.553722+00:00 2021-05-11T15:14:03.010179+00:00 0:08:02.456457 26950 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T15:05:58.341476+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-11T14:05:00+00:00 EmrCreateJobFlowOperator 2021-05-11T15:05:38.354785+00:00 2021-05-11T15:05:39.987158+00:00 0:00:01.632373 26949 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T15:05:36.151246+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-11T14:05:00+00:00 PythonOperator 2021-05-11T15:05:16.343119+00:00 2021-05-11T15:05:19.617460+00:00 0:00:03.274341 26948 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T15:05:14.061547+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-11T14:00:00+00:00 EmrJobFlowSensor 2021-05-11T15:01:03.780319+00:00 2021-05-11T15:22:08.355920+00:00 0:21:04.575601 26947 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T15:01:01.599501+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-11T14:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T15:00:37.809300+00:00 2021-05-11T15:00:39.488114+00:00 0:00:01.678814 26946 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-11T15:00:35.548107+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-11T14:00:00+00:00 PythonOperator 2021-05-11T15:00:15.954243+00:00 2021-05-11T15:00:19.150370+00:00 0:00:03.196127 26945 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-11T15:00:13.530875+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-11T13:00:00+00:00 EmrJobFlowSensor 2021-05-11T14:11:15.517941+00:00 2021-05-11T14:19:18.018430+00:00 0:08:02.500489 26943 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T14:11:13.315752+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-11T13:00:00+00:00 EmrJobFlowSensor 2021-05-11T14:11:07.371716+00:00 2021-05-11T14:21:10.254033+00:00 0:10:02.882317 26942 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T14:11:05.308624+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-11T13:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T14:10:53.892775+00:00 2021-05-11T14:10:55.616510+00:00 0:00:01.723735 26941 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T14:10:51.351300+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-11T13:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T14:10:45.504784+00:00 2021-05-11T14:10:47.190716+00:00 0:00:01.685932 26940 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T14:10:43.293785+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-11T13:00:00+00:00 PythonOperator 2021-05-11T14:10:33.852360+00:00 2021-05-11T14:10:37.033453+00:00 0:00:03.181093 26939 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T14:10:31.285836+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-11T13:00:00+00:00 PythonOperator 2021-05-11T14:10:25.402453+00:00 2021-05-11T14:10:28.759500+00:00 0:00:03.357047 26938 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T14:10:23.203630+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-11T13:00:00+00:00 TriggerDagRunOperator 2021-05-11T14:10:15.713526+00:00 2021-05-11T14:10:16.261962+00:00 0:00:00.548436 26937 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T14:10:13.257640+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-11T13:00:00+00:00 TriggerDagRunOperator 2021-05-11T14:10:15.565171+00:00 2021-05-11T14:10:15.985620+00:00 0:00:00.420449 26936 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T14:10:13.257675+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-11T13:05:00+00:00 EmrJobFlowSensor 2021-05-11T14:05:52.868020+00:00 2021-05-11T14:14:55.569775+00:00 0:09:02.701755 26935 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T14:05:50.647828+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-11T13:05:00+00:00 EmrCreateJobFlowOperator 2021-05-11T14:05:32.876023+00:00 2021-05-11T14:05:34.687620+00:00 0:00:01.811597 26934 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T14:05:30.558274+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-11T13:05:00+00:00 PythonOperator 2021-05-11T14:05:10.558794+00:00 2021-05-11T14:05:13.741410+00:00 0:00:03.182616 26933 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T14:05:08.421357+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-11T13:00:00+00:00 EmrJobFlowSensor 2021-05-11T14:00:52.029555+00:00 2021-05-11T14:09:54.775383+00:00 0:09:02.745828 26932 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T14:00:49.940869+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-11T13:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T14:00:30.125093+00:00 2021-05-11T14:00:31.850590+00:00 0:00:01.725497 26931 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-11T14:00:27.919868+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-11T13:00:00+00:00 PythonOperator 2021-05-11T14:00:08.780114+00:00 2021-05-11T14:00:11.873953+00:00 0:00:03.093839 26930 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-11T14:00:05.966546+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-11T12:00:00+00:00 EmrJobFlowSensor 2021-05-11T13:11:24.799492+00:00 2021-05-11T13:20:27.523121+00:00 0:09:02.723629 26928 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T13:11:22.657901+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-11T12:00:00+00:00 EmrJobFlowSensor 2021-05-11T13:11:16.750365+00:00 2021-05-11T13:21:19.639555+00:00 0:10:02.889190 26927 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T13:11:14.649002+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-11T12:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T13:10:59.042007+00:00 2021-05-11T13:11:00.919422+00:00 0:00:01.877415 26926 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T13:10:56.636527+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-11T12:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T13:10:52.985843+00:00 2021-05-11T13:10:54.793841+00:00 0:00:01.807998 26925 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T13:10:50.631592+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-11T12:00:00+00:00 PythonOperator 2021-05-11T13:10:36.755449+00:00 2021-05-11T13:10:39.950164+00:00 0:00:03.194715 26924 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T13:10:34.613139+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-11T12:00:00+00:00 PythonOperator 2021-05-11T13:10:31.052404+00:00 2021-05-11T13:10:34.463598+00:00 0:00:03.411194 26923 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T13:10:28.666762+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-11T12:00:00+00:00 TriggerDagRunOperator 2021-05-11T13:10:25.324757+00:00 2021-05-11T13:10:25.841435+00:00 0:00:00.516678 26922 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T13:10:22.667541+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-11T12:00:00+00:00 TriggerDagRunOperator 2021-05-11T13:10:24.998683+00:00 2021-05-11T13:10:25.437866+00:00 0:00:00.439183 26921 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T13:10:22.667489+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-11T12:05:00+00:00 EmrJobFlowSensor 2021-05-11T13:05:58.454606+00:00 2021-05-11T13:15:01.073997+00:00 0:09:02.619391 26920 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T13:05:56.224122+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-11T12:05:00+00:00 EmrCreateJobFlowOperator 2021-05-11T13:05:36.533568+00:00 2021-05-11T13:05:38.151706+00:00 0:00:01.618138 26919 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T13:05:34.261751+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-11T12:05:00+00:00 PythonOperator 2021-05-11T13:05:14.406078+00:00 2021-05-11T13:05:17.411018+00:00 0:00:03.004940 26918 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T13:05:12.133940+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-11T12:00:00+00:00 EmrJobFlowSensor 2021-05-11T13:01:04.128467+00:00 2021-05-11T13:10:07.037620+00:00 0:09:02.909153 26917 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T13:01:01.780876+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-11T12:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T13:00:43.789944+00:00 2021-05-11T13:00:45.538221+00:00 0:00:01.748277 26916 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-11T13:00:41.669695+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-11T12:00:00+00:00 PythonOperator 2021-05-11T13:00:22.496810+00:00 2021-05-11T13:00:25.626261+00:00 0:00:03.129451 26915 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-11T13:00:19.740948+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-11T11:00:00+00:00 EmrJobFlowSensor 2021-05-11T12:15:36.836886+00:00 2021-05-11T12:25:39.765196+00:00 0:10:02.928310 26913 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T12:15:34.454174+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-11T11:00:00+00:00 EmrJobFlowSensor 2021-05-11T12:15:22.741297+00:00 2021-05-11T12:27:25.991823+00:00 0:12:03.250526 26912 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T12:15:20.340868+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-11T11:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T12:15:04.507556+00:00 2021-05-11T12:15:06.185814+00:00 0:00:01.678258 26911 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T12:15:02.321725+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-11T11:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T12:14:56.642641+00:00 2021-05-11T12:14:58.521900+00:00 0:00:01.879259 26910 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T12:14:54.309259+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-11T11:00:00+00:00 PythonOperator 2021-05-11T12:14:39.376050+00:00 2021-05-11T12:14:42.550814+00:00 0:00:03.174764 26909 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T12:14:36.298973+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-11T11:00:00+00:00 PythonOperator 2021-05-11T12:14:34.515002+00:00 2021-05-11T12:14:38.936166+00:00 0:00:04.421164 26908 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T12:14:32.288197+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-11T11:00:00+00:00 TriggerDagRunOperator 2021-05-11T12:14:28.774335+00:00 2021-05-11T12:14:29.307351+00:00 0:00:00.533016 26907 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T12:14:26.290814+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-11T11:00:00+00:00 TriggerDagRunOperator 2021-05-11T12:14:28.479854+00:00 2021-05-11T12:14:28.896991+00:00 0:00:00.417137 26906 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T12:14:26.290845+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-11T11:05:00+00:00 EmrJobFlowSensor 2021-05-11T12:06:05.558011+00:00 2021-05-11T12:16:08.322013+00:00 0:10:02.764002 26905 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T12:06:03.409784+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-11T11:05:00+00:00 EmrCreateJobFlowOperator 2021-05-11T12:05:43.579877+00:00 2021-05-11T12:05:45.327168+00:00 0:00:01.747291 26904 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T12:05:41.390960+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-11T11:05:00+00:00 PythonOperator 2021-05-11T12:05:21.523636+00:00 2021-05-11T12:05:24.662651+00:00 0:00:03.139015 26903 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T12:05:19.347854+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-11T11:00:00+00:00 EmrJobFlowSensor 2021-05-11T12:01:10.922476+00:00 2021-05-11T12:14:14.613480+00:00 0:13:03.691004 26902 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T12:01:08.719053+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-11T11:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T12:00:43.093848+00:00 2021-05-11T12:00:44.901690+00:00 0:00:01.807842 26901 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-11T12:00:40.697699+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-11T11:00:00+00:00 PythonOperator 2021-05-11T12:00:17.083999+00:00 2021-05-11T12:00:20.201122+00:00 0:00:03.117123 26900 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-11T12:00:14.653121+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-11T11:30:27.816525+00:00 EmrJobFlowSensor 2021-05-11T11:31:29.161533+00:00 2021-05-11T11:41:37.212089+00:00 0:10:08.050556 26898 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T11:31:26.665871+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-11T11:30:27.816525+00:00 EmrCreateJobFlowOperator 2021-05-11T11:31:08.729237+00:00 2021-05-11T11:31:10.555810+00:00 0:00:01.826573 26897 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T11:31:06.588121+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-11T11:30:27.816525+00:00 PythonOperator 2021-05-11T11:30:46.578391+00:00 2021-05-11T11:30:49.712990+00:00 0:00:03.134599 26896 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T11:30:44.508709+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-11T10:00:00+00:00 EmrJobFlowSensor 2021-05-11T11:13:21.119956+00:00 2021-05-11T11:25:29.406764+00:00 0:12:08.286808 26895 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T11:13:18.886874+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-11T10:00:00+00:00 EmrJobFlowSensor 2021-05-11T11:13:06.895664+00:00 2021-05-11T11:22:09.466927+00:00 0:09:02.571263 26894 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T11:13:04.813643+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-11T10:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T11:13:01.133345+00:00 2021-05-11T11:13:03.017545+00:00 0:00:01.884200 26893 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T11:12:58.840784+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-11T10:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T11:12:44.978431+00:00 2021-05-11T11:12:46.715471+00:00 0:00:01.737040 26892 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-11T11:12:42.793994+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-11T10:00:00+00:00 PythonOperator 2021-05-11T11:12:39.333039+00:00 2021-05-11T11:12:42.694325+00:00 0:00:03.361286 26891 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T11:12:36.788278+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-11T10:00:00+00:00 PythonOperator 2021-05-11T11:12:25.512824+00:00 2021-05-11T11:12:28.771633+00:00 0:00:03.258809 26890 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T11:12:22.732096+00:00 2 default_pool