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 vc-asset-import_v002 check_cluster_status 2021-05-05T23:05:00+00:00 EmrJobFlowSensor 2021-05-06T00:05:56.523608+00:00 2021-05-06T00:14:59.187597+00:00 0:09:02.663989 24908 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T00:05:54.324874+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-05T23:05:00+00:00 EmrCreateJobFlowOperator 2021-05-06T00:05:34.676737+00:00 2021-05-06T00:05:36.354470+00:00 0:00:01.677733 24907 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-06T00:05:32.361194+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-05T23:05:00+00:00 PythonOperator 2021-05-06T00:05:12.513000+00:00 2021-05-06T00:05:15.563867+00:00 0:00:03.050867 24906 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T00:05:10.281269+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-05T23:00:00+00:00 EmrJobFlowSensor 2021-05-06T00:01:04.131622+00:00 2021-05-06T00:11:06.966402+00:00 0:10:02.834780 24905 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T00:01:01.746748+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-05T23:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T00:00:44.108639+00:00 2021-05-06T00:00:45.813626+00:00 0:00:01.704987 24904 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-06T00:00:41.792182+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-05T23:00:00+00:00 PythonOperator 2021-05-06T00:00:08.130699+00:00 2021-05-06T00:00:11.229817+00:00 0:00:03.099118 24903 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-06T00:00:05.647103+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-05T22:00:00+00:00 EmrJobFlowSensor 2021-05-05T23:11:18.230636+00:00 2021-05-05T23:20:20.872858+00:00 0:09:02.642222 24901 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T23:11:15.850811+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-05T22:00:00+00:00 EmrJobFlowSensor 2021-05-05T23:10:59.971011+00:00 2021-05-05T23:21:02.759003+00:00 0:10:02.787992 24900 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T23:10:57.791947+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-05T22:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T23:10:56.125970+00:00 2021-05-05T23:10:57.946265+00:00 0:00:01.820295 24899 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T23:10:53.850470+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-05T22:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T23:10:38.009526+00:00 2021-05-05T23:10:39.826813+00:00 0:00:01.817287 24898 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T23:10:35.692240+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-05T22:00:00+00:00 PythonOperator 2021-05-05T23:10:35.989788+00:00 2021-05-05T23:10:39.335343+00:00 0:00:03.345555 24897 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T23:10:33.785638+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-05T22:00:00+00:00 PythonOperator 2021-05-05T23:10:16.174977+00:00 2021-05-05T23:10:19.265074+00:00 0:00:03.090097 24896 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T23:10:13.633062+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-05T22:00:00+00:00 TriggerDagRunOperator 2021-05-05T23:10:08.118216+00:00 2021-05-05T23:10:08.735429+00:00 0:00:00.617213 24895 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T23:10:05.617893+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-05T22:00:00+00:00 TriggerDagRunOperator 2021-05-05T23:10:07.809376+00:00 2021-05-05T23:10:08.298749+00:00 0:00:00.489373 24894 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T23:10:05.617857+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-05T22:05:00+00:00 EmrJobFlowSensor 2021-05-05T23:05:59.285231+00:00 2021-05-05T23:14:01.733694+00:00 0:08:02.448463 24893 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T23:05:57.109492+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-05T22:05:00+00:00 EmrCreateJobFlowOperator 2021-05-05T23:05:37.178797+00:00 2021-05-05T23:05:38.802540+00:00 0:00:01.623743 24892 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T23:05:35.047997+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-05T22:05:00+00:00 PythonOperator 2021-05-05T23:05:15.377655+00:00 2021-05-05T23:05:18.410152+00:00 0:00:03.032497 24891 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T23:05:13.062899+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-05-04T23:00:00+00:00 EmrJobFlowSensor 2021-05-05T23:01:00.909258+00:00 2021-05-05T23:10:03.528657+00:00 0:09:02.619399 24890 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T23:00:58.668822+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-05T22:00:00+00:00 EmrJobFlowSensor 2021-05-05T23:00:58.983396+00:00 2021-05-05T23:10:01.835616+00:00 0:09:02.852220 24889 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T23:00:56.549699+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-05-04T23:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T23:00:34.660265+00:00 2021-05-05T23:00:36.319851+00:00 0:00:01.659586 24888 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T23:00:32.515959+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-05T22:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T23:00:31.231413+00:00 2021-05-05T23:00:33.031460+00:00 0:00:01.800047 24887 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-05T23:00:28.747980+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-05-04T23:00:00+00:00 PythonOperator 2021-05-05T23:00:10.867760+00:00 2021-05-05T23:00:14.005498+00:00 0:00:03.137738 24886 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T23:00:08.563888+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-05T22:00:00+00:00 PythonOperator 2021-05-05T23:00:09.367639+00:00 2021-05-05T23:00:12.453771+00:00 0:00:03.086132 24885 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-05T23:00:06.561740+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-05T21:00:00+00:00 EmrJobFlowSensor 2021-05-05T22:11:27.988017+00:00 2021-05-05T22:21:30.757503+00:00 0:10:02.769486 24883 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T22:11:25.869993+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-05T21:00:00+00:00 EmrJobFlowSensor 2021-05-05T22:11:16.425996+00:00 2021-05-05T22:19:18.991106+00:00 0:08:02.565110 24882 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T22:11:13.858244+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-05T21:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T22:11:07.989461+00:00 2021-05-05T22:11:09.802782+00:00 0:00:01.813321 24881 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T22:11:05.850917+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-05T21:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T22:10:54.070275+00:00 2021-05-05T22:10:55.778415+00:00 0:00:01.708140 24880 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T22:10:51.828846+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-05T21:00:00+00:00 PythonOperator 2021-05-05T22:10:44.344878+00:00 2021-05-05T22:10:47.616385+00:00 0:00:03.271507 24879 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T22:10:41.875010+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-05T21:00:00+00:00 PythonOperator 2021-05-05T22:10:32.981847+00:00 2021-05-05T22:10:36.043991+00:00 0:00:03.062144 24878 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T22:10:30.044346+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-05T21:00:00+00:00 TriggerDagRunOperator 2021-05-05T22:10:24.217726+00:00 2021-05-05T22:10:24.635118+00:00 0:00:00.417392 24877 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T22:10:21.803356+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-05T21:00:00+00:00 TriggerDagRunOperator 2021-05-05T22:10:24.037609+00:00 2021-05-05T22:10:24.567515+00:00 0:00:00.529906 24876 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T22:10:21.803390+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-05T21:05:00+00:00 EmrJobFlowSensor 2021-05-05T22:05:49.017865+00:00 2021-05-05T22:14:51.593593+00:00 0:09:02.575728 24875 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T22:05:46.828082+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-05T21:05:00+00:00 EmrCreateJobFlowOperator 2021-05-05T22:05:29.066815+00:00 2021-05-05T22:05:30.809107+00:00 0:00:01.742292 24874 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T22:05:26.805622+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-05T21:05:00+00:00 PythonOperator 2021-05-05T22:05:07.024579+00:00 2021-05-05T22:05:10.012780+00:00 0:00:02.988201 24873 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T22:05:04.790374+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-05T21:00:00+00:00 EmrJobFlowSensor 2021-05-05T22:01:02.812572+00:00 2021-05-05T22:10:05.584942+00:00 0:09:02.772370 24872 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T22:01:00.362052+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-05T21:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T22:00:40.500487+00:00 2021-05-05T22:00:42.208033+00:00 0:00:01.707546 24871 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-05T22:00:38.296103+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-05T21:00:00+00:00 PythonOperator 2021-05-05T22:00:20.662006+00:00 2021-05-05T22:00:23.756906+00:00 0:00:03.094900 24870 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-05T22:00:18.240088+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-05T20:00:00+00:00 EmrJobFlowSensor 2021-05-05T21:13:56.604105+00:00 2021-05-05T21:22:59.238867+00:00 0:09:02.634762 24868 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T21:13:54.318759+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-05T20:00:00+00:00 EmrJobFlowSensor 2021-05-05T21:13:52.809373+00:00 2021-05-05T21:23:55.550532+00:00 0:10:02.741159 24867 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T21:13:50.449579+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-05T20:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T21:13:34.739256+00:00 2021-05-05T21:13:36.471588+00:00 0:00:01.732332 24866 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T21:13:32.363176+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-05T20:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T21:13:30.782923+00:00 2021-05-05T21:13:32.491183+00:00 0:00:01.708260 24865 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T21:13:28.361256+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-05T20:00:00+00:00 PythonOperator 2021-05-05T21:13:12.473871+00:00 2021-05-05T21:13:15.743295+00:00 0:00:03.269424 24864 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T21:13:10.194823+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-05T20:00:00+00:00 PythonOperator 2021-05-05T21:13:10.569327+00:00 2021-05-05T21:13:13.649204+00:00 0:00:03.079877 24863 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T21:13:08.258892+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-05T20:00:00+00:00 TriggerDagRunOperator 2021-05-05T21:12:58.957646+00:00 2021-05-05T21:12:59.356312+00:00 0:00:00.398666 24862 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T21:12:56.137887+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-05T20:00:00+00:00 TriggerDagRunOperator 2021-05-05T21:12:58.491849+00:00 2021-05-05T21:12:59.013742+00:00 0:00:00.521893 24861 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T21:12:56.137857+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-05T20:05:00+00:00 EmrJobFlowSensor 2021-05-05T21:06:11.561189+00:00 2021-05-05T21:14:14.084056+00:00 0:08:02.522867 24860 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T21:06:09.448015+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-05T20:05:00+00:00 EmrCreateJobFlowOperator 2021-05-05T21:05:49.776601+00:00 2021-05-05T21:05:51.396813+00:00 0:00:01.620212 24859 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T21:05:47.405437+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-05T20:05:00+00:00 PythonOperator 2021-05-05T21:05:21.491598+00:00 2021-05-05T21:05:24.517451+00:00 0:00:03.025853 24858 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T21:05:19.371800+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-05T20:00:00+00:00 EmrJobFlowSensor 2021-05-05T21:00:50.793045+00:00 2021-05-05T21:12:53.872060+00:00 0:12:03.079015 24857 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T21:00:48.706320+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-05T20:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T21:00:29.129762+00:00 2021-05-05T21:00:30.807338+00:00 0:00:01.677576 24856 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-05T21:00:26.759824+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-05T20:00:00+00:00 PythonOperator 2021-05-05T21:00:07.454388+00:00 2021-05-05T21:00:10.530641+00:00 0:00:03.076253 24855 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-05T21:00:04.759493+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-05T19:00:00+00:00 EmrJobFlowSensor 2021-05-05T20:11:07.406301+00:00 2021-05-05T20:19:09.829347+00:00 0:08:02.423046 24853 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T20:11:05.317634+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-05T19:00:00+00:00 EmrJobFlowSensor 2021-05-05T20:10:59.710794+00:00 2021-05-05T20:21:02.637608+00:00 0:10:02.926814 24852 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T20:10:57.320182+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-05T19:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T20:10:47.924824+00:00 2021-05-05T20:10:49.718237+00:00 0:00:01.793413 24851 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T20:10:45.304923+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-05T19:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T20:10:39.483671+00:00 2021-05-05T20:10:41.150340+00:00 0:00:01.666669 24850 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T20:10:37.298005+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-05T19:00:00+00:00 PythonOperator 2021-05-05T20:10:25.705044+00:00 2021-05-05T20:10:28.761182+00:00 0:00:03.056138 24849 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T20:10:23.355964+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-05T19:00:00+00:00 PythonOperator 2021-05-05T20:10:15.990040+00:00 2021-05-05T20:10:19.300233+00:00 0:00:03.310193 24848 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T20:10:13.242534+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-05T19:00:00+00:00 TriggerDagRunOperator 2021-05-05T20:10:07.742556+00:00 2021-05-05T20:10:08.312105+00:00 0:00:00.569549 24847 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T20:10:05.268325+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-05T19:00:00+00:00 TriggerDagRunOperator 2021-05-05T20:10:07.560698+00:00 2021-05-05T20:10:07.973854+00:00 0:00:00.413156 24846 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T20:10:05.268281+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-05T19:05:00+00:00 EmrJobFlowSensor 2021-05-05T20:06:03.063363+00:00 2021-05-05T20:15:05.681480+00:00 0:09:02.618117 24845 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T20:06:00.565701+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-05T19:05:00+00:00 EmrCreateJobFlowOperator 2021-05-05T20:05:42.601165+00:00 2021-05-05T20:05:44.325883+00:00 0:00:01.724718 24844 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T20:05:40.411082+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-05T19:05:00+00:00 PythonOperator 2021-05-05T20:05:20.582125+00:00 2021-05-05T20:05:23.561807+00:00 0:00:02.979682 24843 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T20:05:18.365391+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-05T19:00:00+00:00 EmrJobFlowSensor 2021-05-05T20:00:55.775002+00:00 2021-05-05T20:09:58.659165+00:00 0:09:02.884163 24842 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T20:00:53.652932+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-05T19:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T20:00:35.835289+00:00 2021-05-05T20:00:37.514192+00:00 0:00:01.678903 24841 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-05T20:00:33.607146+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-05T19:00:00+00:00 PythonOperator 2021-05-05T20:00:14.473035+00:00 2021-05-05T20:00:17.526575+00:00 0:00:03.053540 24840 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-05T20:00:11.680919+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-05T18:00:00+00:00 EmrJobFlowSensor 2021-05-05T19:10:05.292643+00:00 2021-05-05T19:19:07.919188+00:00 0:09:02.626545 24838 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T19:10:02.950041+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-05T18:00:00+00:00 EmrJobFlowSensor 2021-05-05T19:10:03.280945+00:00 2021-05-05T19:19:06.020388+00:00 0:09:02.739443 24837 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T19:10:00.865557+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-05T18:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T19:09:41.298056+00:00 2021-05-05T19:09:43.053285+00:00 0:00:01.755229 24836 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T19:09:38.859936+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-05T18:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T19:09:41.318633+00:00 2021-05-05T19:09:43.249875+00:00 0:00:01.931242 24835 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T19:09:38.859986+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-05T18:00:00+00:00 PythonOperator 2021-05-05T19:09:21.219666+00:00 2021-05-05T19:09:24.297231+00:00 0:00:03.077565 24834 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T19:09:18.747182+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-05T18:00:00+00:00 PythonOperator 2021-05-05T19:09:18.960446+00:00 2021-05-05T19:09:22.626293+00:00 0:00:03.665847 24833 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T19:09:16.745437+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-05T18:00:00+00:00 TriggerDagRunOperator 2021-05-05T19:09:03.187212+00:00 2021-05-05T19:09:03.781803+00:00 0:00:00.594591 24832 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T19:09:00.730805+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-05T18:00:00+00:00 TriggerDagRunOperator 2021-05-05T19:09:02.996193+00:00 2021-05-05T19:09:03.494547+00:00 0:00:00.498354 24831 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T19:09:00.730758+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-05T18:05:00+00:00 EmrJobFlowSensor 2021-05-05T19:05:56.548420+00:00 2021-05-05T19:14:59.113019+00:00 0:09:02.564599 24830 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T19:05:54.232761+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-05T18:05:00+00:00 EmrCreateJobFlowOperator 2021-05-05T19:05:36.413403+00:00 2021-05-05T19:05:38.464475+00:00 0:00:02.051072 24829 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T19:05:34.222181+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-05T18:05:00+00:00 PythonOperator 2021-05-05T19:05:14.583558+00:00 2021-05-05T19:05:17.654015+00:00 0:00:03.070457 24828 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T19:05:12.212686+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-05T18:00:00+00:00 EmrJobFlowSensor 2021-05-05T19:00:49.901696+00:00 2021-05-05T19:08:52.441687+00:00 0:08:02.539991 24827 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T19:00:47.591770+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-05T18:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T19:00:27.896693+00:00 2021-05-05T19:00:29.797716+00:00 0:00:01.901023 24826 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-05T19:00:25.516815+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-05T18:00:00+00:00 PythonOperator 2021-05-05T19:00:07.934793+00:00 2021-05-05T19:00:11.067767+00:00 0:00:03.132974 24825 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-05T19:00:05.491882+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-05T17:00:00+00:00 EmrJobFlowSensor 2021-05-05T18:10:22.127504+00:00 2021-05-05T18:20:24.866556+00:00 0:10:02.739052 24823 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T18:10:20.014444+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-05T17:00:00+00:00 EmrJobFlowSensor 2021-05-05T18:10:18.378864+00:00 2021-05-05T18:19:21.172393+00:00 0:09:02.793529 24822 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T18:10:16.012175+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-05T17:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T18:10:00.452035+00:00 2021-05-05T18:10:02.169933+00:00 0:00:01.717898 24821 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T18:09:58.044208+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-05T17:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T18:09:56.073313+00:00 2021-05-05T18:09:57.846533+00:00 0:00:01.773220 24820 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T18:09:53.934286+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-05T17:00:00+00:00 PythonOperator 2021-05-05T18:09:40.297174+00:00 2021-05-05T18:09:43.302430+00:00 0:00:03.005256 24819 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T18:09:37.922705+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-05T17:00:00+00:00 PythonOperator 2021-05-05T18:09:36.075062+00:00 2021-05-05T18:09:39.346596+00:00 0:00:03.271534 24818 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T18:09:33.919194+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-05T17:00:00+00:00 TriggerDagRunOperator 2021-05-05T18:09:12.207896+00:00 2021-05-05T18:09:12.736204+00:00 0:00:00.528308 24817 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T18:09:09.897723+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-05T17:00:00+00:00 TriggerDagRunOperator 2021-05-05T18:09:11.992157+00:00 2021-05-05T18:09:12.426412+00:00 0:00:00.434255 24816 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T18:09:09.897759+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-05T17:05:00+00:00 EmrJobFlowSensor 2021-05-05T18:06:07.873159+00:00 2021-05-05T18:14:10.330199+00:00 0:08:02.457040 24815 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T18:06:05.679486+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-05T17:05:00+00:00 EmrCreateJobFlowOperator 2021-05-05T18:05:41.688446+00:00 2021-05-05T18:05:43.483811+00:00 0:00:01.795365 24814 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T18:05:39.525892+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-05T17:05:00+00:00 PythonOperator 2021-05-05T18:05:15.930434+00:00 2021-05-05T18:05:18.968817+00:00 0:00:03.038383 24813 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T18:05:13.504225+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-05T17:00:00+00:00 EmrJobFlowSensor 2021-05-05T18:01:03.591327+00:00 2021-05-05T18:09:06.225074+00:00 0:08:02.633747 24812 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T18:01:01.121967+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-05T17:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T18:00:41.195757+00:00 2021-05-05T18:00:42.902503+00:00 0:00:01.706746 24811 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-05T18:00:39.100901+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-05T17:00:00+00:00 PythonOperator 2021-05-05T18:00:19.255668+00:00 2021-05-05T18:00:22.372628+00:00 0:00:03.116960 24810 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-05T18:00:17.088058+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-05T16:00:00+00:00 EmrJobFlowSensor 2021-05-05T17:17:14.761870+00:00 2021-05-05T17:27:17.444437+00:00 0:10:02.682567 24809 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T17:17:12.196721+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-05T16:00:00+00:00 EmrJobFlowSensor 2021-05-05T17:17:12.311069+00:00 2021-05-05T17:27:15.504714+00:00 0:10:03.193645 24808 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T17:17:10.191196+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-05T16:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T17:16:52.567290+00:00 2021-05-05T17:16:54.335566+00:00 0:00:01.768276 24807 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T17:16:50.076485+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-05T16:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T17:16:50.378364+00:00 2021-05-05T17:16:52.019865+00:00 0:00:01.641501 24806 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T17:16:48.079727+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-05T16:05:00+00:00 EmrJobFlowSensor 2021-05-05T17:16:42.080534+00:00 2021-05-05T17:25:44.639064+00:00 0:09:02.558530 24805 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T17:16:40.012629+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-05T16:00:00+00:00 PythonOperator 2021-05-05T17:16:30.566717+00:00 2021-05-05T17:16:34.027840+00:00 0:00:03.461123 24804 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T17:16:28.142060+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-05T16:00:00+00:00 PythonOperator 2021-05-05T17:16:28.170789+00:00 2021-05-05T17:16:31.593248+00:00 0:00:03.422459 24803 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T17:16:25.943895+00:00 2 default_pool