Task Instances

  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success campaign-history-job_v002 check_cluster_status 2021-04-19T11:00:00+00:00 EmrJobFlowSensor 2021-04-19T12:11:20.887799+00:00 2021-04-19T12:20:23.589811+00:00 0:09:02.702012 18903 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T12:11:18.682245+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-19T11:00:00+00:00 EmrJobFlowSensor 2021-04-19T12:11:09.103493+00:00 2021-04-19T12:22:12.008762+00:00 0:11:02.905269 18902 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T12:11:06.652072+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-19T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T12:10:59.043826+00:00 2021-04-19T12:11:00.760861+00:00 0:00:01.717035 18901 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T12:10:56.744389+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-19T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T12:10:46.993872+00:00 2021-04-19T12:10:48.794739+00:00 0:00:01.800867 18900 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T12:10:44.675609+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-19T11:00:00+00:00 PythonOperator 2021-04-19T12:10:38.943568+00:00 2021-04-19T12:10:41.903838+00:00 0:00:02.960270 18899 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T12:10:36.640752+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-19T11:00:00+00:00 PythonOperator 2021-04-19T12:10:24.789688+00:00 2021-04-19T12:10:28.218791+00:00 0:00:03.429103 18898 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T12:10:22.607378+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-19T11:00:00+00:00 TriggerDagRunOperator 2021-04-19T12:10:20.920302+00:00 2021-04-19T12:10:21.443795+00:00 0:00:00.523493 18897 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T12:10:18.603525+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-19T11:00:00+00:00 TriggerDagRunOperator 2021-04-19T12:10:20.833545+00:00 2021-04-19T12:10:21.228452+00:00 0:00:00.394907 18896 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T12:10:18.603497+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-19T11:05:00+00:00 EmrJobFlowSensor 2021-04-19T12:07:00.701692+00:00 2021-04-19T12:16:03.306709+00:00 0:09:02.605017 18895 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T12:06:58.275766+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-19T11:05:00+00:00 EmrCreateJobFlowOperator 2021-04-19T12:06:38.737165+00:00 2021-04-19T12:06:40.444986+00:00 0:00:01.707821 18894 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T12:06:36.253586+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-19T11:05:00+00:00 PythonOperator 2021-04-19T12:05:20.254649+00:00 2021-04-19T12:05:23.156266+00:00 0:00:02.901617 18893 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T12:05:18.033125+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-19T11:00:00+00:00 EmrJobFlowSensor 2021-04-19T12:00:59.837060+00:00 2021-04-19T12:10:02.655769+00:00 0:09:02.818709 18892 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T12:00:57.591662+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-19T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T12:00:37.753324+00:00 2021-04-19T12:00:40.157110+00:00 0:00:02.403786 18891 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-19T12:00:35.510735+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-19T11:00:00+00:00 PythonOperator 2021-04-19T12:00:16.070273+00:00 2021-04-19T12:00:19.020140+00:00 0:00:02.949867 18890 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-19T12:00:13.543690+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-19T10:00:00+00:00 EmrJobFlowSensor 2021-04-19T11:12:21.109172+00:00 2021-04-19T11:23:24.384209+00:00 0:11:03.275037 18888 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T11:12:18.466567+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-19T10:00:00+00:00 EmrJobFlowSensor 2021-04-19T11:12:08.930408+00:00 2021-04-19T11:22:11.794599+00:00 0:10:02.864191 18887 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T11:12:06.452481+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-19T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T11:12:00.967817+00:00 2021-04-19T11:12:02.748251+00:00 0:00:01.780434 18886 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T11:11:58.452734+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-19T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T11:11:38.620684+00:00 2021-04-19T11:11:40.917169+00:00 0:00:02.296485 18885 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T11:11:36.412207+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-19T10:00:00+00:00 PythonOperator 2021-04-19T11:11:32.602680+00:00 2021-04-19T11:11:35.824096+00:00 0:00:03.221416 18884 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T11:11:30.407726+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-19T10:00:00+00:00 PythonOperator 2021-04-19T11:11:14.767649+00:00 2021-04-19T11:11:17.888502+00:00 0:00:03.120853 18883 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T11:11:12.392212+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-19T10:00:00+00:00 TriggerDagRunOperator 2021-04-19T11:11:09.162763+00:00 2021-04-19T11:11:09.689680+00:00 0:00:00.526917 18882 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T11:11:06.389544+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-19T10:00:00+00:00 TriggerDagRunOperator 2021-04-19T11:11:08.668242+00:00 2021-04-19T11:11:09.103787+00:00 0:00:00.435545 18881 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T11:11:06.389584+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-19T10:05:00+00:00 EmrJobFlowSensor 2021-04-19T11:05:50.126957+00:00 2021-04-19T11:14:52.681555+00:00 0:09:02.554598 18880 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T11:05:47.825190+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-19T10:05:00+00:00 EmrCreateJobFlowOperator 2021-04-19T11:05:28.176739+00:00 2021-04-19T11:05:29.790240+00:00 0:00:01.613501 18879 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T11:05:25.812334+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-19T10:05:00+00:00 PythonOperator 2021-04-19T11:05:07.921434+00:00 2021-04-19T11:05:10.847396+00:00 0:00:02.925962 18878 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T11:05:05.790396+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-19T10:00:00+00:00 EmrJobFlowSensor 2021-04-19T11:00:55.633170+00:00 2021-04-19T11:10:58.418411+00:00 0:10:02.785241 18877 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T11:00:53.382261+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-19T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T11:00:34.034974+00:00 2021-04-19T11:00:35.845840+00:00 0:00:01.810866 18876 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-19T11:00:31.339877+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-19T10:00:00+00:00 PythonOperator 2021-04-19T11:00:11.707177+00:00 2021-04-19T11:00:14.868121+00:00 0:00:03.160944 18875 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-19T11:00:09.244591+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-19T09:00:00+00:00 EmrJobFlowSensor 2021-04-19T10:24:55.924617+00:00 2021-04-19T10:33:58.693096+00:00 0:09:02.768479 18874 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T10:24:53.470287+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-19T09:00:00+00:00 EmrJobFlowSensor 2021-04-19T10:24:51.799278+00:00 2021-04-19T10:33:54.443376+00:00 0:09:02.644098 18873 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T10:24:49.479232+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-19T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T10:24:35.886420+00:00 2021-04-19T10:24:37.685686+00:00 0:00:01.799266 18872 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T10:24:33.475666+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-19T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T10:24:30.156424+00:00 2021-04-19T10:24:31.928666+00:00 0:00:01.772242 18871 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T10:24:27.546251+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-19T09:00:00+00:00 PythonOperator 2021-04-19T10:24:13.651974+00:00 2021-04-19T10:24:16.783433+00:00 0:00:03.131459 18870 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T10:24:11.440653+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-19T09:00:00+00:00 PythonOperator 2021-04-19T10:24:09.799618+00:00 2021-04-19T10:24:12.786138+00:00 0:00:02.986520 18869 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T10:24:07.396274+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-19T09:00:00+00:00 TriggerDagRunOperator 2021-04-19T10:23:47.826658+00:00 2021-04-19T10:23:48.240549+00:00 0:00:00.413891 18868 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T10:23:45.367014+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-19T09:00:00+00:00 TriggerDagRunOperator 2021-04-19T10:23:47.829466+00:00 2021-04-19T10:23:48.396461+00:00 0:00:00.566995 18867 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T10:23:45.367042+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-19T09:05:00+00:00 EmrJobFlowSensor 2021-04-19T10:06:03.255421+00:00 2021-04-19T10:15:05.893699+00:00 0:09:02.638278 18865 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T10:06:00.931567+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-19T09:05:00+00:00 EmrCreateJobFlowOperator 2021-04-19T10:05:39.452609+00:00 2021-04-19T10:05:41.159864+00:00 0:00:01.707255 18864 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T10:05:36.964488+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-19T09:05:00+00:00 PythonOperator 2021-04-19T10:05:19.653070+00:00 2021-04-19T10:05:22.589459+00:00 0:00:02.936389 18863 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T10:05:16.852987+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-19T09:00:00+00:00 EmrJobFlowSensor 2021-04-19T10:00:56.651264+00:00 2021-04-19T10:20:01.252457+00:00 0:19:04.601193 18862 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T10:00:54.343931+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-19T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T10:00:34.817887+00:00 2021-04-19T10:00:36.686036+00:00 0:00:01.868149 18861 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-19T10:00:32.365480+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-19T09:00:00+00:00 PythonOperator 2021-04-19T10:00:12.564792+00:00 2021-04-19T10:00:15.740281+00:00 0:00:03.175489 18860 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-19T10:00:10.222910+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-19T08:00:00+00:00 EmrJobFlowSensor 2021-04-19T09:12:12.791052+00:00 2021-04-19T09:20:15.427241+00:00 0:08:02.636189 18858 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T09:12:10.555698+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-19T08:00:00+00:00 EmrJobFlowSensor 2021-04-19T09:11:32.701332+00:00 2021-04-19T09:21:35.444521+00:00 0:10:02.743189 18857 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T09:11:30.435387+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-19T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T09:11:05.035248+00:00 2021-04-19T09:11:06.787821+00:00 0:00:01.752573 18856 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T09:11:02.464337+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-19T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T09:10:54.965520+00:00 2021-04-19T09:10:56.849705+00:00 0:00:01.884185 18855 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T09:10:52.475426+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-19T08:00:00+00:00 PythonOperator 2021-04-19T09:10:42.654073+00:00 2021-04-19T09:10:45.535360+00:00 0:00:02.881287 18854 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T09:10:40.391828+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-19T08:00:00+00:00 PythonOperator 2021-04-19T09:10:33.013770+00:00 2021-04-19T09:10:36.139749+00:00 0:00:03.125979 18853 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T09:10:30.446204+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-19T08:00:00+00:00 TriggerDagRunOperator 2021-04-19T09:10:20.593355+00:00 2021-04-19T09:10:21.050289+00:00 0:00:00.456934 18852 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T09:10:18.325846+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-19T08:00:00+00:00 TriggerDagRunOperator 2021-04-19T09:10:20.614613+00:00 2021-04-19T09:10:21.159833+00:00 0:00:00.545220 18851 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T09:10:18.325815+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-19T08:05:00+00:00 EmrJobFlowSensor 2021-04-19T09:05:57.998250+00:00 2021-04-19T09:15:00.491825+00:00 0:09:02.493575 18850 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T09:05:55.807800+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-19T08:05:00+00:00 EmrCreateJobFlowOperator 2021-04-19T09:05:35.955206+00:00 2021-04-19T09:05:37.809720+00:00 0:00:01.854514 18849 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T09:05:33.797717+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-19T08:05:00+00:00 PythonOperator 2021-04-19T09:05:14.679779+00:00 2021-04-19T09:05:17.795990+00:00 0:00:03.116211 18848 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T09:05:11.757169+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-19T08:00:00+00:00 EmrJobFlowSensor 2021-04-19T09:00:55.724145+00:00 2021-04-19T09:09:58.416079+00:00 0:09:02.691934 18847 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T09:00:53.397617+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-19T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T09:00:33.875510+00:00 2021-04-19T09:00:35.856862+00:00 0:00:01.981352 18846 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-19T09:00:31.450189+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-19T08:00:00+00:00 PythonOperator 2021-04-19T09:00:11.503624+00:00 2021-04-19T09:00:14.477813+00:00 0:00:02.974189 18845 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-19T09:00:09.287129+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-19T07:00:00+00:00 EmrJobFlowSensor 2021-04-19T08:15:03.056345+00:00 2021-04-19T08:25:05.775383+00:00 0:10:02.719038 18844 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T08:15:00.687420+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-19T07:00:00+00:00 EmrJobFlowSensor 2021-04-19T08:15:01.168160+00:00 2021-04-19T08:25:04.136739+00:00 0:10:02.968579 18843 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T08:14:58.764323+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-19T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T08:14:40.845715+00:00 2021-04-19T08:14:42.593695+00:00 0:00:01.747980 18842 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T08:14:38.607647+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-19T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T08:14:38.896529+00:00 2021-04-19T08:14:40.627651+00:00 0:00:01.731122 18841 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T08:14:36.660006+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-19T07:00:00+00:00 PythonOperator 2021-04-19T08:14:18.976053+00:00 2021-04-19T08:14:22.127951+00:00 0:00:03.151898 18840 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T08:14:16.584146+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-19T07:00:00+00:00 PythonOperator 2021-04-19T08:14:18.917275+00:00 2021-04-19T08:14:21.872755+00:00 0:00:02.955480 18839 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T08:14:16.584116+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-19T07:00:00+00:00 TriggerDagRunOperator 2021-04-19T08:13:57.670461+00:00 2021-04-19T08:13:58.236508+00:00 0:00:00.566047 18838 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T08:13:54.536357+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-19T07:00:00+00:00 TriggerDagRunOperator 2021-04-19T08:13:57.625928+00:00 2021-04-19T08:13:58.046535+00:00 0:00:00.420607 18837 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T08:13:54.536329+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-19T07:05:00+00:00 EmrJobFlowSensor 2021-04-19T08:05:53.871155+00:00 2021-04-19T08:14:56.468032+00:00 0:09:02.596877 18835 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T08:05:51.659881+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-19T07:05:00+00:00 EmrCreateJobFlowOperator 2021-04-19T08:05:34.583958+00:00 2021-04-19T08:05:36.280640+00:00 0:00:01.696682 18834 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T08:05:31.645706+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-19T07:05:00+00:00 PythonOperator 2021-04-19T08:05:10.231754+00:00 2021-04-19T08:05:13.178967+00:00 0:00:02.947213 18833 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T08:05:07.674886+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-19T07:00:00+00:00 EmrJobFlowSensor 2021-04-19T08:00:55.601818+00:00 2021-04-19T08:09:58.093899+00:00 0:09:02.492081 18832 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T08:00:53.295228+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-19T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T08:00:35.406788+00:00 2021-04-19T08:00:37.118842+00:00 0:00:01.712054 18831 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-19T08:00:33.247249+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-19T07:00:00+00:00 PythonOperator 2021-04-19T08:00:13.487301+00:00 2021-04-19T08:00:16.506859+00:00 0:00:03.019558 18830 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-19T08:00:11.192202+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-19T06:00:00+00:00 EmrJobFlowSensor 2021-04-19T07:11:16.397584+00:00 2021-04-19T07:21:19.110029+00:00 0:10:02.712445 18829 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T07:11:14.283263+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-19T06:00:00+00:00 EmrJobFlowSensor 2021-04-19T07:11:08.961425+00:00 2021-04-19T07:28:12.860891+00:00 0:17:03.899466 18828 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T07:11:06.255937+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-19T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T07:10:54.511548+00:00 2021-04-19T07:10:56.331500+00:00 0:00:01.819952 18827 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T07:10:52.120076+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-19T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T07:10:46.625287+00:00 2021-04-19T07:10:48.612225+00:00 0:00:01.986938 18826 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T07:10:44.174166+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-19T06:00:00+00:00 PythonOperator 2021-04-19T07:10:34.401771+00:00 2021-04-19T07:10:38.054224+00:00 0:00:03.652453 18825 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T07:10:32.099259+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-19T06:00:00+00:00 PythonOperator 2021-04-19T07:10:26.375319+00:00 2021-04-19T07:10:29.357374+00:00 0:00:02.982055 18824 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T07:10:24.159732+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-19T06:00:00+00:00 TriggerDagRunOperator 2021-04-19T07:10:10.500741+00:00 2021-04-19T07:10:10.930406+00:00 0:00:00.429665 18823 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T07:10:08.086592+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-19T06:00:00+00:00 TriggerDagRunOperator 2021-04-19T07:10:10.537454+00:00 2021-04-19T07:10:11.084321+00:00 0:00:00.546867 18822 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T07:10:08.086562+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-19T06:05:00+00:00 EmrJobFlowSensor 2021-04-19T07:05:49.064551+00:00 2021-04-19T07:13:51.565892+00:00 0:08:02.501341 18820 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T07:05:46.884156+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-19T06:05:00+00:00 EmrCreateJobFlowOperator 2021-04-19T07:05:26.985108+00:00 2021-04-19T07:05:28.674317+00:00 0:00:01.689209 18819 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T07:05:24.861123+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-19T06:05:00+00:00 PythonOperator 2021-04-19T07:05:06.991879+00:00 2021-04-19T07:05:10.104139+00:00 0:00:03.112260 18818 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T07:05:04.838563+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-19T06:00:00+00:00 EmrJobFlowSensor 2021-04-19T07:00:48.873492+00:00 2021-04-19T07:09:51.809454+00:00 0:09:02.935962 18817 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T07:00:46.486728+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-19T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T07:00:24.998433+00:00 2021-04-19T07:00:26.831001+00:00 0:00:01.832568 18816 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-19T07:00:22.546813+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-19T06:00:00+00:00 PythonOperator 2021-04-19T07:00:05.610096+00:00 2021-04-19T07:00:08.774687+00:00 0:00:03.164591 18815 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-19T07:00:02.443849+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-19T05:00:00+00:00 EmrJobFlowSensor 2021-04-19T06:11:47.833286+00:00 2021-04-19T06:20:50.293479+00:00 0:09:02.460193 18814 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T06:11:45.449960+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-19T05:00:00+00:00 EmrJobFlowSensor 2021-04-19T06:11:29.474708+00:00 2021-04-19T06:21:32.220805+00:00 0:10:02.746097 18813 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T06:11:27.329710+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-19T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T06:11:13.732471+00:00 2021-04-19T06:11:15.469170+00:00 0:00:01.736699 18812 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T06:11:11.315784+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-19T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T06:11:05.491354+00:00 2021-04-19T06:11:07.164072+00:00 0:00:01.672718 18811 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T06:11:03.310860+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-19T05:00:00+00:00 PythonOperator 2021-04-19T06:10:51.510567+00:00 2021-04-19T06:10:54.427204+00:00 0:00:02.916637 18810 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T06:10:49.298515+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-19T05:00:00+00:00 PythonOperator 2021-04-19T06:10:41.900985+00:00 2021-04-19T06:10:45.121859+00:00 0:00:03.220874 18809 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T06:10:39.355813+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-19T05:00:00+00:00 TriggerDagRunOperator 2021-04-19T06:10:29.840565+00:00 2021-04-19T06:10:30.358942+00:00 0:00:00.518377 18808 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T06:10:27.290901+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-19T05:00:00+00:00 TriggerDagRunOperator 2021-04-19T06:10:29.758133+00:00 2021-04-19T06:10:30.222852+00:00 0:00:00.464719 18807 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T06:10:27.290859+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-19T05:05:00+00:00 EmrJobFlowSensor 2021-04-19T06:09:57.337725+00:00 2021-04-19T06:17:59.759562+00:00 0:08:02.421837 18806 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T06:09:55.202846+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-19T05:05:00+00:00 EmrCreateJobFlowOperator 2021-04-19T06:09:37.454435+00:00 2021-04-19T06:09:39.114907+00:00 0:00:01.660472 18805 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T06:09:35.191487+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-19T05:05:00+00:00 PythonOperator 2021-04-19T06:09:15.758422+00:00 2021-04-19T06:09:19.014303+00:00 0:00:03.255881 18804 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T06:09:13.169635+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-19T05:00:00+00:00 EmrJobFlowSensor 2021-04-19T06:01:08.924701+00:00 2021-04-19T06:10:11.651459+00:00 0:09:02.726758 18802 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T06:01:06.730208+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-19T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T06:00:36.878197+00:00 2021-04-19T06:00:38.565338+00:00 0:00:01.687141 18801 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-19T06:00:34.707803+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-19T05:00:00+00:00 PythonOperator 2021-04-19T06:00:11.159736+00:00 2021-04-19T06:00:14.182779+00:00 0:00:03.023043 18800 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-19T06:00:08.756338+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-19T04:00:00+00:00 EmrJobFlowSensor 2021-04-19T05:13:36.281894+00:00 2021-04-19T05:30:40.003025+00:00 0:17:03.721131 18799 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T05:13:33.989095+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-19T04:00:00+00:00 EmrJobFlowSensor 2021-04-19T05:13:32.890073+00:00 2021-04-19T05:23:35.631454+00:00 0:10:02.741381 18798 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T05:13:29.972465+00:00 2 default_pool