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-06T06:00:00+00:00 TriggerDagRunOperator 2021-05-06T07:11:17.079817+00:00 2021-05-06T07:11:17.589853+00:00 0:00:00.510036 25015 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T07:11:14.775078+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-06T06:00:00+00:00 TriggerDagRunOperator 2021-05-06T07:11:16.945361+00:00 2021-05-06T07:11:17.362245+00:00 0:00:00.416884 25014 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T07:11:14.775048+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-06T06:05:00+00:00 EmrJobFlowSensor 2021-05-06T07:05:56.461367+00:00 2021-05-06T07:14:58.939536+00:00 0:09:02.478169 25013 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T07:05:54.303907+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-06T06:05:00+00:00 EmrCreateJobFlowOperator 2021-05-06T07:05:34.396194+00:00 2021-05-06T07:05:36.052948+00:00 0:00:01.656754 25012 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-06T07:05:32.234817+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-06T06:05:00+00:00 PythonOperator 2021-05-06T07:05:12.390080+00:00 2021-05-06T07:05:15.496723+00:00 0:00:03.106643 25011 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T07:05:10.209823+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-06T06:00:00+00:00 EmrJobFlowSensor 2021-05-06T07:00:57.876312+00:00 2021-05-06T07:11:00.590591+00:00 0:10:02.714279 25010 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T07:00:55.647308+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-06T06:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T07:00:37.779369+00:00 2021-05-06T07:00:39.493049+00:00 0:00:01.713680 25009 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-06T07:00:35.561632+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-06T06:00:00+00:00 PythonOperator 2021-05-06T07:00:16.181651+00:00 2021-05-06T07:00:19.288190+00:00 0:00:03.106539 25008 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-06T07:00:13.471022+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-06T05:00:00+00:00 EmrJobFlowSensor 2021-05-06T06:10:09.437065+00:00 2021-05-06T06:19:12.045187+00:00 0:09:02.608122 25006 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T06:10:06.905884+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-06T05:00:00+00:00 EmrJobFlowSensor 2021-05-06T06:10:07.189486+00:00 2021-05-06T06:19:10.133622+00:00 0:09:02.944136 25005 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T06:10:04.905790+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-06T05:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T06:09:45.406206+00:00 2021-05-06T06:09:47.106563+00:00 0:00:01.700357 25004 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-06T06:09:42.958147+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-06T05:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T06:09:42.997676+00:00 2021-05-06T06:09:45.100686+00:00 0:00:02.103010 25003 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-06T06:09:40.886115+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-06T05:00:00+00:00 PythonOperator 2021-05-06T06:09:23.108763+00:00 2021-05-06T06:09:26.412210+00:00 0:00:03.303447 25002 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T06:09:20.824125+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-06T05:00:00+00:00 PythonOperator 2021-05-06T06:09:16.920875+00:00 2021-05-06T06:09:19.976884+00:00 0:00:03.056009 25001 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T06:09:14.819672+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-06T05:00:00+00:00 TriggerDagRunOperator 2021-05-06T06:09:01.203339+00:00 2021-05-06T06:09:01.749009+00:00 0:00:00.545670 25000 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T06:08:58.856405+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-06T05:00:00+00:00 TriggerDagRunOperator 2021-05-06T06:09:01.140645+00:00 2021-05-06T06:09:01.592718+00:00 0:00:00.452073 24999 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T06:08:58.856359+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-06T05:05:00+00:00 EmrJobFlowSensor 2021-05-06T06:05:46.452053+00:00 2021-05-06T06:14:49.020844+00:00 0:09:02.568791 24998 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T06:05:44.404260+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-06T05:05:00+00:00 EmrCreateJobFlowOperator 2021-05-06T06:05:24.658240+00:00 2021-05-06T06:05:26.333687+00:00 0:00:01.675447 24997 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-06T06:05:22.397475+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-06T05:05:00+00:00 PythonOperator 2021-05-06T06:05:04.797453+00:00 2021-05-06T06:05:07.784612+00:00 0:00:02.987159 24996 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T06:05:02.370916+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-06T05:00:00+00:00 EmrJobFlowSensor 2021-05-06T06:00:48.184490+00:00 2021-05-06T06:08:50.619499+00:00 0:08:02.435009 24995 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T06:00:45.850865+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-06T05:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T06:00:25.878753+00:00 2021-05-06T06:00:27.588472+00:00 0:00:01.709719 24994 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-06T06:00:23.738850+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-06T05:00:00+00:00 PythonOperator 2021-05-06T06:00:06.161132+00:00 2021-05-06T06:00:09.264965+00:00 0:00:03.103833 24993 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-06T06:00:03.726978+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-06T04:00:00+00:00 EmrJobFlowSensor 2021-05-06T05:12:38.404645+00:00 2021-05-06T05:20:40.948025+00:00 0:08:02.543380 24991 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T05:12:36.214474+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-06T04:00:00+00:00 EmrJobFlowSensor 2021-05-06T05:12:20.584847+00:00 2021-05-06T05:22:23.388933+00:00 0:10:02.804086 24990 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T05:12:18.208174+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-06T04:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T05:12:16.495900+00:00 2021-05-06T05:12:18.172426+00:00 0:00:01.676526 24989 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-06T05:12:14.255218+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-06T04:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T05:12:00.580237+00:00 2021-05-06T05:12:02.368443+00:00 0:00:01.788206 24988 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-06T05:11:58.159976+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-06T04:00:00+00:00 PythonOperator 2021-05-06T05:11:54.389678+00:00 2021-05-06T05:11:57.405283+00:00 0:00:03.015605 24987 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T05:11:51.936218+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-06T04:00:00+00:00 PythonOperator 2021-05-06T05:11:38.200289+00:00 2021-05-06T05:11:41.516480+00:00 0:00:03.316191 24986 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T05:11:35.836367+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-06T04:00:00+00:00 TriggerDagRunOperator 2021-05-06T05:11:32.434888+00:00 2021-05-06T05:11:33.049972+00:00 0:00:00.615084 24985 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T05:11:29.366467+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-06T04:00:00+00:00 TriggerDagRunOperator 2021-05-06T05:11:32.374648+00:00 2021-05-06T05:11:32.761676+00:00 0:00:00.387028 24984 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T05:11:29.366413+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-06T04:05:00+00:00 EmrJobFlowSensor 2021-05-06T05:06:06.795001+00:00 2021-05-06T05:14:09.303803+00:00 0:08:02.508802 24983 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T05:06:04.483105+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-06T04:05:00+00:00 EmrCreateJobFlowOperator 2021-05-06T05:05:46.592997+00:00 2021-05-06T05:05:48.360018+00:00 0:00:01.767021 24982 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-06T05:05:44.385510+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-06T04:05:00+00:00 PythonOperator 2021-05-06T05:05:24.516220+00:00 2021-05-06T05:05:27.544310+00:00 0:00:03.028090 24981 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T05:05:22.307195+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-06T04:00:00+00:00 EmrJobFlowSensor 2021-05-06T05:01:06.296426+00:00 2021-05-06T05:11:09.210550+00:00 0:10:02.914124 24980 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T05:01:03.975557+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-06T04:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T05:00:41.961503+00:00 2021-05-06T05:00:43.655243+00:00 0:00:01.693740 24979 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-06T05:00:39.892071+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-06T04:00:00+00:00 PythonOperator 2021-05-06T05:00:16.080978+00:00 2021-05-06T05:00:19.120840+00:00 0:00:03.039862 24978 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-06T05:00:13.827423+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-06T03:00:00+00:00 EmrJobFlowSensor 2021-05-06T04:22:26.872741+00:00 2021-05-06T04:31:29.696988+00:00 0:09:02.824247 24976 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T04:22:24.610260+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-06T03:00:00+00:00 EmrJobFlowSensor 2021-05-06T04:22:18.697770+00:00 2021-05-06T04:31:21.286841+00:00 0:09:02.589071 24975 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T04:22:16.600651+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-06T03:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T04:22:04.876449+00:00 2021-05-06T04:22:06.567854+00:00 0:00:01.691405 24974 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-06T04:22:02.654134+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-06T03:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T04:21:57.145828+00:00 2021-05-06T04:21:59.011673+00:00 0:00:01.865845 24973 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-06T04:21:54.590074+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-06T03:00:00+00:00 PythonOperator 2021-05-06T04:21:43.000586+00:00 2021-05-06T04:21:46.299856+00:00 0:00:03.299270 24972 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T04:21:40.501398+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-06T03:00:00+00:00 PythonOperator 2021-05-06T04:21:34.596796+00:00 2021-05-06T04:21:37.652942+00:00 0:00:03.056146 24971 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T04:21:32.495646+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-06T03:00:00+00:00 TriggerDagRunOperator 2021-05-06T04:21:20.712241+00:00 2021-05-06T04:21:21.243719+00:00 0:00:00.531478 24970 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T04:21:18.491891+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-06T03:00:00+00:00 TriggerDagRunOperator 2021-05-06T04:21:20.629908+00:00 2021-05-06T04:21:21.022184+00:00 0:00:00.392276 24969 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T04:21:18.491864+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-06T03:05:00+00:00 EmrJobFlowSensor 2021-05-06T04:06:05.038668+00:00 2021-05-06T04:15:07.644850+00:00 0:09:02.606182 24968 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T04:06:02.687383+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-06T03:05:00+00:00 EmrCreateJobFlowOperator 2021-05-06T04:05:40.979728+00:00 2021-05-06T04:05:42.689227+00:00 0:00:01.709499 24967 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-06T04:05:38.663586+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-06T03:05:00+00:00 PythonOperator 2021-05-06T04:05:20.958356+00:00 2021-05-06T04:05:23.998433+00:00 0:00:03.040077 24966 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T04:05:18.589180+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-06T03:00:00+00:00 EmrJobFlowSensor 2021-05-06T04:00:52.489360+00:00 2021-05-06T04:20:56.800477+00:00 0:20:04.311117 24965 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T04:00:49.956837+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-06T03:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T04:00:30.315976+00:00 2021-05-06T04:00:32.004628+00:00 0:00:01.688652 24964 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-06T04:00:27.858072+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-06T03:00:00+00:00 PythonOperator 2021-05-06T04:00:10.376260+00:00 2021-05-06T04:00:13.427734+00:00 0:00:03.051474 24963 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-06T04:00:07.677690+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-06T02:00:00+00:00 EmrJobFlowSensor 2021-05-06T03:11:25.362626+00:00 2021-05-06T03:20:28.152758+00:00 0:09:02.790132 24961 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T03:11:22.553934+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-06T02:00:00+00:00 EmrJobFlowSensor 2021-05-06T03:11:16.833587+00:00 2021-05-06T03:21:19.670595+00:00 0:10:02.837008 24960 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T03:11:14.491718+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-06T02:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T03:11:02.847536+00:00 2021-05-06T03:11:04.662387+00:00 0:00:01.814851 24959 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-06T03:11:00.455967+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-06T02:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T03:10:54.756089+00:00 2021-05-06T03:10:56.501822+00:00 0:00:01.745733 24958 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-06T03:10:52.384484+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-06T02:00:00+00:00 PythonOperator 2021-05-06T03:10:40.697942+00:00 2021-05-06T03:10:43.747312+00:00 0:00:03.049370 24957 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T03:10:38.372144+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-06T02:00:00+00:00 PythonOperator 2021-05-06T03:10:34.665917+00:00 2021-05-06T03:10:38.005368+00:00 0:00:03.339451 24956 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T03:10:32.288465+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-06T02:00:00+00:00 TriggerDagRunOperator 2021-05-06T03:10:22.529541+00:00 2021-05-06T03:10:23.088868+00:00 0:00:00.559327 24955 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T03:10:20.269012+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-06T02:00:00+00:00 TriggerDagRunOperator 2021-05-06T03:10:22.451574+00:00 2021-05-06T03:10:22.841449+00:00 0:00:00.389875 24954 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T03:10:20.268978+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-06T02:05:00+00:00 EmrJobFlowSensor 2021-05-06T03:05:48.276878+00:00 2021-05-06T03:15:51.093655+00:00 0:10:02.816777 24953 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T03:05:45.714495+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-06T02:05:00+00:00 EmrCreateJobFlowOperator 2021-05-06T03:05:25.908439+00:00 2021-05-06T03:05:27.530684+00:00 0:00:01.622245 24952 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-06T03:05:23.706599+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-06T02:05:00+00:00 PythonOperator 2021-05-06T03:05:05.826125+00:00 2021-05-06T03:05:08.934567+00:00 0:00:03.108442 24951 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T03:05:03.628215+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-06T02:00:00+00:00 EmrJobFlowSensor 2021-05-06T03:01:05.735859+00:00 2021-05-06T03:10:08.571495+00:00 0:09:02.835636 24950 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T03:01:03.153485+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-06T02:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T03:00:43.251695+00:00 2021-05-06T03:00:44.931573+00:00 0:00:01.679878 24949 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-06T03:00:41.024993+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-06T02:00:00+00:00 PythonOperator 2021-05-06T03:00:21.197883+00:00 2021-05-06T03:00:24.340443+00:00 0:00:03.142560 24948 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-06T03:00:19.010061+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-06T01:00:00+00:00 EmrJobFlowSensor 2021-05-06T02:11:14.827901+00:00 2021-05-06T02:19:17.387049+00:00 0:08:02.559148 24946 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T02:11:12.535684+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-06T01:00:00+00:00 EmrJobFlowSensor 2021-05-06T02:11:10.699768+00:00 2021-05-06T02:21:13.423942+00:00 0:10:02.724174 24945 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T02:11:08.525459+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-06T01:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T02:10:53.062119+00:00 2021-05-06T02:10:54.840246+00:00 0:00:01.778127 24944 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-06T02:10:50.576692+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-06T01:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T02:10:49.007998+00:00 2021-05-06T02:10:50.685106+00:00 0:00:01.677108 24943 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-06T02:10:46.570272+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-06T01:00:00+00:00 PythonOperator 2021-05-06T02:10:31.200818+00:00 2021-05-06T02:10:34.239885+00:00 0:00:03.039067 24942 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T02:10:28.565568+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-06T01:00:00+00:00 PythonOperator 2021-05-06T02:10:26.581007+00:00 2021-05-06T02:10:29.969044+00:00 0:00:03.388037 24941 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T02:10:24.414606+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-06T01:00:00+00:00 TriggerDagRunOperator 2021-05-06T02:10:08.778267+00:00 2021-05-06T02:10:09.310343+00:00 0:00:00.532076 24940 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T02:10:06.400424+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-06T01:00:00+00:00 TriggerDagRunOperator 2021-05-06T02:10:08.478588+00:00 2021-05-06T02:10:08.928241+00:00 0:00:00.449653 24939 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T02:10:06.400458+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-06T01:05:00+00:00 EmrJobFlowSensor 2021-05-06T02:05:52.056990+00:00 2021-05-06T02:13:54.544447+00:00 0:08:02.487457 24938 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T02:05:49.963714+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-06T01:05:00+00:00 EmrCreateJobFlowOperator 2021-05-06T02:05:30.464585+00:00 2021-05-06T02:05:32.207665+00:00 0:00:01.743080 24937 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-06T02:05:27.747795+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-06T01:05:00+00:00 PythonOperator 2021-05-06T02:05:08.147442+00:00 2021-05-06T02:05:11.201663+00:00 0:00:03.054221 24936 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T02:05:05.671264+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-06T01:00:00+00:00 EmrJobFlowSensor 2021-05-06T02:00:51.026672+00:00 2021-05-06T02:09:53.768971+00:00 0:09:02.742299 24935 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T02:00:48.813567+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-06T01:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T02:00:29.244031+00:00 2021-05-06T02:00:31.069654+00:00 0:00:01.825623 24934 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-06T02:00:26.765704+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-06T01:00:00+00:00 PythonOperator 2021-05-06T02:00:07.399253+00:00 2021-05-06T02:00:10.493298+00:00 0:00:03.094045 24933 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-06T02:00:04.640938+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-06T00:00:00+00:00 EmrJobFlowSensor 2021-05-06T01:11:39.903678+00:00 2021-05-06T01:20:42.515689+00:00 0:09:02.612011 24931 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T01:11:37.707965+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-06T00:00:00+00:00 EmrJobFlowSensor 2021-05-06T01:11:35.893477+00:00 2021-05-06T01:23:38.937480+00:00 0:12:03.044003 24930 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T01:11:33.680842+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-06T00:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T01:11:17.804983+00:00 2021-05-06T01:11:19.561546+00:00 0:00:01.756563 24929 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-06T01:11:15.603349+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-06T00:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T01:11:11.721706+00:00 2021-05-06T01:11:13.444808+00:00 0:00:01.723102 24928 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-06T01:11:09.598278+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-06T00:00:00+00:00 PythonOperator 2021-05-06T01:10:58.203875+00:00 2021-05-06T01:11:01.255662+00:00 0:00:03.051787 24927 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T01:10:55.590668+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-06T00:00:00+00:00 PythonOperator 2021-05-06T01:10:49.869056+00:00 2021-05-06T01:10:53.119281+00:00 0:00:03.250225 24926 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T01:10:47.584206+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-06T00:00:00+00:00 TriggerDagRunOperator 2021-05-06T01:10:32.132666+00:00 2021-05-06T01:10:32.728342+00:00 0:00:00.595676 24925 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T01:10:29.449036+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-06T00:00:00+00:00 TriggerDagRunOperator 2021-05-06T01:10:32.014963+00:00 2021-05-06T01:10:32.426912+00:00 0:00:00.411949 24924 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T01:10:29.449084+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-06T00:05:00+00:00 EmrJobFlowSensor 2021-05-06T01:06:00.947396+00:00 2021-05-06T01:14:03.492508+00:00 0:08:02.545112 24923 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T01:05:58.805356+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-06T00:05:00+00:00 EmrCreateJobFlowOperator 2021-05-06T01:05:38.884685+00:00 2021-05-06T01:05:40.520741+00:00 0:00:01.636056 24922 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-06T01:05:36.746093+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-06T00:05:00+00:00 PythonOperator 2021-05-06T01:05:17.054941+00:00 2021-05-06T01:05:20.048701+00:00 0:00:02.993760 24921 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T01:05:14.667117+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-06T00:00:00+00:00 EmrJobFlowSensor 2021-05-06T01:01:06.669608+00:00 2021-05-06T01:10:09.496726+00:00 0:09:02.827118 24920 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T01:01:04.255812+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-06T00:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T01:00:46.852095+00:00 2021-05-06T01:00:48.652907+00:00 0:00:01.800812 24919 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-06T01:00:44.369503+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-06T00:00:00+00:00 PythonOperator 2021-05-06T01:00:24.507386+00:00 2021-05-06T01:00:27.598317+00:00 0:00:03.090931 24918 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-06T01:00:21.976236+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-05T23:00:00+00:00 EmrJobFlowSensor 2021-05-06T00:12:25.494925+00:00 2021-05-06T00:21:28.035800+00:00 0:09:02.540875 24916 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T00:12:23.232284+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-05T23:00:00+00:00 EmrJobFlowSensor 2021-05-06T00:12:13.321111+00:00 2021-05-06T00:21:15.999891+00:00 0:09:02.678780 24915 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T00:12:11.133021+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-05T23:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T00:12:05.426722+00:00 2021-05-06T00:12:07.235147+00:00 0:00:01.808425 24914 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-06T00:12:03.127318+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-05T23:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T00:11:51.206414+00:00 2021-05-06T00:11:52.911019+00:00 0:00:01.704605 24913 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-06T00:11:49.051635+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-05T23:00:00+00:00 PythonOperator 2021-05-06T00:11:43.239074+00:00 2021-05-06T00:11:46.284763+00:00 0:00:03.045689 24912 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T00:11:41.039878+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-05T23:00:00+00:00 PythonOperator 2021-05-06T00:11:31.564108+00:00 2021-05-06T00:11:34.912071+00:00 0:00:03.347963 24911 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T00:11:29.146346+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-05T23:00:00+00:00 TriggerDagRunOperator 2021-05-06T00:11:25.488747+00:00 2021-05-06T00:11:25.980264+00:00 0:00:00.491517 24910 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T00:11:22.947572+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-05T23:00:00+00:00 TriggerDagRunOperator 2021-05-06T00:11:25.133085+00:00 2021-05-06T00:11:25.534742+00:00 0:00:00.401657 24909 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T00:11:22.947531+00:00 2 default_pool