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-04-16T20:05:00+00:00 EmrJobFlowSensor 2021-04-16T21:05:51.813958+00:00 2021-04-16T21:14:54.478556+00:00 0:09:02.664598 17952 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T21:05:49.632492+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-16T20:05:00+00:00 EmrCreateJobFlowOperator 2021-04-16T21:05:25.791422+00:00 2021-04-16T21:05:27.464005+00:00 0:00:01.672583 17951 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T21:05:23.612689+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-16T20:05:00+00:00 PythonOperator 2021-04-16T21:05:05.869612+00:00 2021-04-16T21:05:08.772610+00:00 0:00:02.902998 17950 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T21:05:03.587656+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-16T20:00:00+00:00 EmrJobFlowSensor 2021-04-16T21:01:01.895392+00:00 2021-04-16T21:09:04.552786+00:00 0:08:02.657394 17949 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T21:00:59.166299+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-16T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T21:00:39.820884+00:00 2021-04-16T21:00:41.707118+00:00 0:00:01.886234 17948 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-16T21:00:37.152472+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-16T20:00:00+00:00 PythonOperator 2021-04-16T21:00:17.310636+00:00 2021-04-16T21:00:20.237209+00:00 0:00:02.926573 17947 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-16T21:00:15.033987+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-16T19:00:00+00:00 EmrJobFlowSensor 2021-04-16T20:22:12.116849+00:00 2021-04-16T20:22:13.713246+00:00 0:00:01.596397 17945 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T20:22:09.855514+00:00 3 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-16T19:00:00+00:00 EmrJobFlowSensor 2021-04-16T20:22:02.147045+00:00 2021-04-16T20:22:03.653769+00:00 0:00:01.506724 17944 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T20:21:59.851245+00:00 3 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-16T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T20:10:12.694062+00:00 2021-04-16T20:10:14.533651+00:00 0:00:01.839589 17941 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T20:10:10.422841+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-16T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T20:10:02.575595+00:00 2021-04-16T20:10:04.414380+00:00 0:00:01.838785 17940 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T20:10:00.405127+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-16T19:00:00+00:00 PythonOperator 2021-04-16T20:09:52.977761+00:00 2021-04-16T20:09:56.361571+00:00 0:00:03.383810 17939 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T20:09:50.460222+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-16T19:00:00+00:00 PythonOperator 2021-04-16T20:09:40.597462+00:00 2021-04-16T20:09:43.485727+00:00 0:00:02.888265 17938 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T20:09:38.390457+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-16T19:00:00+00:00 TriggerDagRunOperator 2021-04-16T20:09:31.153781+00:00 2021-04-16T20:09:31.699922+00:00 0:00:00.546141 17937 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T20:09:28.464637+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-16T19:00:00+00:00 TriggerDagRunOperator 2021-04-16T20:09:31.054234+00:00 2021-04-16T20:09:31.498321+00:00 0:00:00.444087 17936 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T20:09:28.464691+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-16T19:05:00+00:00 EmrJobFlowSensor 2021-04-16T20:05:58.102875+00:00 2021-04-16T20:15:00.622465+00:00 0:09:02.519590 17935 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T20:05:55.994936+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-16T19:05:00+00:00 EmrCreateJobFlowOperator 2021-04-16T20:05:36.319106+00:00 2021-04-16T20:05:38.009751+00:00 0:00:01.690645 17934 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T20:05:34.049597+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-16T19:05:00+00:00 PythonOperator 2021-04-16T20:05:15.136773+00:00 2021-04-16T20:05:18.000538+00:00 0:00:02.863765 17933 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T20:05:11.985079+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-16T19:00:00+00:00 EmrJobFlowSensor 2021-04-16T20:01:03.965920+00:00 2021-04-16T20:09:06.560666+00:00 0:08:02.594746 17932 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T20:01:01.620407+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-16T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T20:00:40.010013+00:00 2021-04-16T20:00:41.712559+00:00 0:00:01.702546 17931 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-16T20:00:37.664296+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-16T19:00:00+00:00 PythonOperator 2021-04-16T20:00:18.111485+00:00 2021-04-16T20:00:21.074635+00:00 0:00:02.963150 17930 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-16T20:00:15.650421+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-16T18:00:00+00:00 EmrJobFlowSensor 2021-04-16T19:10:59.464208+00:00 2021-04-16T19:21:02.151380+00:00 0:10:02.687172 17928 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T19:10:57.174228+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-16T18:00:00+00:00 EmrJobFlowSensor 2021-04-16T19:10:51.303132+00:00 2021-04-16T19:20:54.160945+00:00 0:10:02.857813 17927 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T19:10:49.165392+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-16T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T19:10:39.603579+00:00 2021-04-16T19:10:41.317362+00:00 0:00:01.713783 17926 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T19:10:37.155153+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-16T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T19:10:31.856246+00:00 2021-04-16T19:10:33.518362+00:00 0:00:01.662116 17925 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T19:10:29.169336+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-16T18:00:00+00:00 PythonOperator 2021-04-16T19:10:17.388006+00:00 2021-04-16T19:10:20.887936+00:00 0:00:03.499930 17924 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T19:10:15.099915+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-16T18:00:00+00:00 PythonOperator 2021-04-16T19:10:09.567135+00:00 2021-04-16T19:10:12.428094+00:00 0:00:02.860959 17923 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T19:10:07.158295+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-16T18:00:00+00:00 TriggerDagRunOperator 2021-04-16T19:10:03.828864+00:00 2021-04-16T19:10:04.274128+00:00 0:00:00.445264 17922 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T19:10:01.156725+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-16T18:00:00+00:00 TriggerDagRunOperator 2021-04-16T19:10:03.837504+00:00 2021-04-16T19:10:04.442519+00:00 0:00:00.605015 17921 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T19:10:01.156674+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-16T18:05:00+00:00 EmrJobFlowSensor 2021-04-16T19:05:56.792625+00:00 2021-04-16T19:14:59.315663+00:00 0:09:02.523038 17920 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T19:05:54.647397+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-16T18:05:00+00:00 EmrCreateJobFlowOperator 2021-04-16T19:05:34.882062+00:00 2021-04-16T19:05:36.689750+00:00 0:00:01.807688 17919 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T19:05:32.651293+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-16T18:05:00+00:00 PythonOperator 2021-04-16T19:05:12.924109+00:00 2021-04-16T19:05:15.804246+00:00 0:00:02.880137 17918 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T19:05:10.598223+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-16T18:00:00+00:00 EmrJobFlowSensor 2021-04-16T19:00:52.694838+00:00 2021-04-16T19:09:55.419939+00:00 0:09:02.725101 17917 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T19:00:50.059274+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-16T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T19:00:28.868541+00:00 2021-04-16T19:00:30.555485+00:00 0:00:01.686944 17916 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-16T19:00:26.043622+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-16T18:00:00+00:00 PythonOperator 2021-04-16T19:00:08.342826+00:00 2021-04-16T19:00:11.344698+00:00 0:00:03.001872 17915 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-16T19:00:05.987444+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-16T17:00:00+00:00 EmrJobFlowSensor 2021-04-16T18:10:07.146427+00:00 2021-04-16T18:20:09.981688+00:00 0:10:02.835261 17913 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T18:10:04.790434+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-16T17:00:00+00:00 EmrJobFlowSensor 2021-04-16T18:09:54.925490+00:00 2021-04-16T18:19:57.649772+00:00 0:10:02.724282 17912 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T18:09:52.729165+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-16T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T18:09:46.905756+00:00 2021-04-16T18:09:49.339570+00:00 0:00:02.433814 17911 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T18:09:44.723199+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-16T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T18:09:32.949845+00:00 2021-04-16T18:09:34.723884+00:00 0:00:01.774039 17910 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T18:09:30.708617+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-16T17:00:00+00:00 PythonOperator 2021-04-16T18:09:25.248903+00:00 2021-04-16T18:09:28.370419+00:00 0:00:03.121516 17909 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T18:09:22.701779+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-16T17:00:00+00:00 PythonOperator 2021-04-16T18:09:13.260752+00:00 2021-04-16T18:09:16.167116+00:00 0:00:02.906364 17908 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T18:09:10.690195+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-16T17:00:00+00:00 TriggerDagRunOperator 2021-04-16T18:09:07.160451+00:00 2021-04-16T18:09:07.572129+00:00 0:00:00.411678 17907 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T18:09:04.746804+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-16T17:00:00+00:00 TriggerDagRunOperator 2021-04-16T18:09:06.976858+00:00 2021-04-16T18:09:07.545779+00:00 0:00:00.568921 17906 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T18:09:04.746834+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-16T17:05:00+00:00 EmrJobFlowSensor 2021-04-16T18:06:10.567694+00:00 2021-04-16T18:15:13.097467+00:00 0:09:02.529773 17905 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T18:06:08.408741+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-16T17:05:00+00:00 EmrCreateJobFlowOperator 2021-04-16T18:05:48.727696+00:00 2021-04-16T18:05:50.420954+00:00 0:00:01.693258 17904 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T18:05:46.451623+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-16T17:05:00+00:00 PythonOperator 2021-04-16T18:05:16.449673+00:00 2021-04-16T18:05:19.308840+00:00 0:00:02.859167 17903 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T18:05:14.360694+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-16T17:00:00+00:00 EmrJobFlowSensor 2021-04-16T18:01:00.441872+00:00 2021-04-16T18:09:03.054964+00:00 0:08:02.613092 17902 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T18:00:58.079013+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-16T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T18:00:34.697177+00:00 2021-04-16T18:00:36.586707+00:00 0:00:01.889530 17901 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-16T18:00:32.006223+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-16T17:00:00+00:00 PythonOperator 2021-04-16T18:00:12.527430+00:00 2021-04-16T18:00:15.466164+00:00 0:00:02.938734 17900 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-16T18:00:09.989832+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-16T16:00:00+00:00 EmrJobFlowSensor 2021-04-16T17:12:24.337890+00:00 2021-04-16T17:21:26.988653+00:00 0:09:02.650763 17898 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T17:12:21.955419+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-16T16:00:00+00:00 EmrJobFlowSensor 2021-04-16T17:12:18.375499+00:00 2021-04-16T17:22:21.195510+00:00 0:10:02.820011 17897 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T17:12:15.959765+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-16T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T17:12:02.236222+00:00 2021-04-16T17:12:04.100886+00:00 0:00:01.864664 17896 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T17:11:59.946840+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-16T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T17:11:58.247028+00:00 2021-04-16T17:12:00.076288+00:00 0:00:01.829260 17895 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T17:11:55.834835+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-16T16:00:00+00:00 PythonOperator 2021-04-16T17:11:41.990301+00:00 2021-04-16T17:11:44.882347+00:00 0:00:02.892046 17894 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T17:11:39.820416+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-16T16:00:00+00:00 PythonOperator 2021-04-16T17:11:36.110201+00:00 2021-04-16T17:11:39.605004+00:00 0:00:03.494803 17893 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T17:11:33.816309+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-16T16:00:00+00:00 TriggerDagRunOperator 2021-04-16T17:11:22.312010+00:00 2021-04-16T17:11:22.877231+00:00 0:00:00.565221 17892 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T17:11:19.860804+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-16T16:00:00+00:00 TriggerDagRunOperator 2021-04-16T17:11:22.224630+00:00 2021-04-16T17:11:22.669449+00:00 0:00:00.444819 17891 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T17:11:19.860774+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-16T16:05:00+00:00 EmrJobFlowSensor 2021-04-16T17:05:59.363018+00:00 2021-04-16T17:15:02.049326+00:00 0:09:02.686308 17890 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T17:05:57.115643+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-16T16:05:00+00:00 EmrCreateJobFlowOperator 2021-04-16T17:05:37.307972+00:00 2021-04-16T17:05:38.945330+00:00 0:00:01.637358 17889 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T17:05:35.097286+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-16T16:05:00+00:00 PythonOperator 2021-04-16T17:05:17.253318+00:00 2021-04-16T17:05:20.202976+00:00 0:00:02.949658 17888 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T17:05:15.058440+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-16T16:00:00+00:00 EmrJobFlowSensor 2021-04-16T17:00:54.536129+00:00 2021-04-16T17:10:57.215410+00:00 0:10:02.679281 17887 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T17:00:52.305596+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-16T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T17:00:32.702892+00:00 2021-04-16T17:00:34.968408+00:00 0:00:02.265516 17886 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-16T17:00:30.282635+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-16T16:00:00+00:00 PythonOperator 2021-04-16T17:00:10.449889+00:00 2021-04-16T17:00:13.383638+00:00 0:00:02.933749 17885 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-16T17:00:08.203967+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-16T15:00:00+00:00 EmrJobFlowSensor 2021-04-16T16:35:53.898606+00:00 2021-04-16T16:45:56.589122+00:00 0:10:02.690516 17884 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T16:35:51.711863+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-16T15:00:00+00:00 EmrJobFlowSensor 2021-04-16T16:35:45.930035+00:00 2021-04-16T16:44:48.699301+00:00 0:09:02.769266 17883 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T16:35:43.710902+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-16T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T16:35:30.261301+00:00 2021-04-16T16:35:31.926702+00:00 0:00:01.665401 17882 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T16:35:27.691979+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-16T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T16:35:18.114507+00:00 2021-04-16T16:35:19.807435+00:00 0:00:01.692928 17881 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T16:35:15.663687+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-16T15:00:00+00:00 PythonOperator 2021-04-16T16:35:05.969082+00:00 2021-04-16T16:35:08.868487+00:00 0:00:02.899405 17880 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T16:35:03.650775+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-16T15:00:00+00:00 PythonOperator 2021-04-16T16:34:55.786190+00:00 2021-04-16T16:34:59.108792+00:00 0:00:03.322602 17879 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T16:34:53.644932+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-16T15:00:00+00:00 TriggerDagRunOperator 2021-04-16T16:34:40.565431+00:00 2021-04-16T16:34:41.001225+00:00 0:00:00.435794 17878 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T16:34:37.683593+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-16T15:00:00+00:00 TriggerDagRunOperator 2021-04-16T16:34:40.394228+00:00 2021-04-16T16:34:40.934574+00:00 0:00:00.540346 17877 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T16:34:37.683627+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-16T15:05:00+00:00 EmrJobFlowSensor 2021-04-16T16:25:32.794026+00:00 2021-04-16T16:34:35.417096+00:00 0:09:02.623070 17876 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T16:25:30.559881+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-16T15:00:00+00:00 EmrJobFlowSensor 2021-04-16T16:25:26.787593+00:00 2021-04-16T16:34:29.510253+00:00 0:09:02.722660 17875 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T16:25:24.531098+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-16T15:05:00+00:00 EmrCreateJobFlowOperator 2021-04-16T16:25:10.731254+00:00 2021-04-16T16:25:12.375170+00:00 0:00:01.643916 17874 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T16:25:08.518104+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-16T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T16:25:06.676669+00:00 2021-04-16T16:25:08.399702+00:00 0:00:01.723033 17873 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-16T16:25:04.515362+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-16T15:05:00+00:00 PythonOperator 2021-04-16T16:24:50.686878+00:00 2021-04-16T16:24:53.602493+00:00 0:00:02.915615 17872 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T16:24:48.502276+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-16T15:00:00+00:00 PythonOperator 2021-04-16T16:24:45.337541+00:00 2021-04-16T16:24:48.431158+00:00 0:00:03.093617 17871 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-16T16:24:42.518989+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-16T14:00:00+00:00 EmrJobFlowSensor 2021-04-16T15:11:17.223349+00:00 2021-04-16T15:19:19.735146+00:00 0:08:02.511797 17869 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T15:11:14.960313+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-16T14:00:00+00:00 EmrJobFlowSensor 2021-04-16T15:11:17.185463+00:00 2021-04-16T15:20:19.934184+00:00 0:09:02.748721 17868 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T15:11:14.960280+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-16T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T15:10:55.197826+00:00 2021-04-16T15:10:56.994933+00:00 0:00:01.797107 17867 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T15:10:52.840681+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-16T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T15:10:55.077970+00:00 2021-04-16T15:10:56.789008+00:00 0:00:01.711038 17866 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T15:10:52.840649+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-16T14:00:00+00:00 PythonOperator 2021-04-16T15:10:35.524408+00:00 2021-04-16T15:10:38.483656+00:00 0:00:02.959248 17865 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T15:10:32.849329+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-16T14:00:00+00:00 PythonOperator 2021-04-16T15:10:35.375526+00:00 2021-04-16T15:10:38.537079+00:00 0:00:03.161553 17864 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T15:10:32.849281+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-16T14:00:00+00:00 TriggerDagRunOperator 2021-04-16T15:10:19.328593+00:00 2021-04-16T15:10:19.745725+00:00 0:00:00.417132 17863 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T15:10:16.849196+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-16T14:00:00+00:00 TriggerDagRunOperator 2021-04-16T15:10:19.166321+00:00 2021-04-16T15:10:19.706724+00:00 0:00:00.540403 17862 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T15:10:16.849146+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-16T14:05:00+00:00 EmrJobFlowSensor 2021-04-16T15:05:58.457564+00:00 2021-04-16T15:15:01.217703+00:00 0:09:02.760139 17861 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T15:05:56.136113+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-16T14:05:00+00:00 EmrCreateJobFlowOperator 2021-04-16T15:05:36.246782+00:00 2021-04-16T15:05:37.906162+00:00 0:00:01.659380 17860 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T15:05:34.115992+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-16T14:05:00+00:00 PythonOperator 2021-04-16T15:05:14.322448+00:00 2021-04-16T15:05:17.174719+00:00 0:00:02.852271 17859 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T15:05:12.093744+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-16T14:00:00+00:00 EmrJobFlowSensor 2021-04-16T15:01:04.160507+00:00 2021-04-16T15:10:06.815398+00:00 0:09:02.654891 17858 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T15:01:01.752081+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-16T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T15:00:41.924476+00:00 2021-04-16T15:00:43.806044+00:00 0:00:01.881568 17857 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-16T15:00:39.733131+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-16T14:00:00+00:00 PythonOperator 2021-04-16T15:00:20.822070+00:00 2021-04-16T15:00:23.794395+00:00 0:00:02.972325 17856 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-16T15:00:17.741887+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-16T13:00:00+00:00 EmrJobFlowSensor 2021-04-16T14:11:18.547156+00:00 2021-04-16T14:21:21.439794+00:00 0:10:02.892638 17854 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T14:11:16.053400+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-16T13:00:00+00:00 EmrJobFlowSensor 2021-04-16T14:11:12.222100+00:00 2021-04-16T14:21:15.178637+00:00 0:10:02.956537 17853 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T14:11:09.986453+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-16T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T14:10:58.227450+00:00 2021-04-16T14:11:00.009005+00:00 0:00:01.781555 17852 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T14:10:55.965445+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-16T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T14:10:50.510943+00:00 2021-04-16T14:10:52.297011+00:00 0:00:01.786068 17851 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T14:10:47.927205+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-16T13:00:00+00:00 PythonOperator 2021-04-16T14:10:36.585602+00:00 2021-04-16T14:10:39.994597+00:00 0:00:03.408995 17850 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T14:10:33.915492+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-16T13:00:00+00:00 PythonOperator 2021-04-16T14:10:30.520722+00:00 2021-04-16T14:10:33.434336+00:00 0:00:02.913614 17849 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T14:10:27.963529+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-16T13:00:00+00:00 TriggerDagRunOperator 2021-04-16T14:10:24.270586+00:00 2021-04-16T14:10:24.718593+00:00 0:00:00.448007 17848 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T14:10:21.907563+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-16T13:00:00+00:00 TriggerDagRunOperator 2021-04-16T14:10:24.207679+00:00 2021-04-16T14:10:24.793360+00:00 0:00:00.585681 17847 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T14:10:21.907534+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-16T13:05:00+00:00 EmrJobFlowSensor 2021-04-16T14:05:59.992143+00:00 2021-04-16T14:15:02.759587+00:00 0:09:02.767444 17846 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T14:05:57.285360+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-16T13:05:00+00:00 EmrCreateJobFlowOperator 2021-04-16T14:05:39.559980+00:00 2021-04-16T14:05:41.214531+00:00 0:00:01.654551 17845 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T14:05:37.266448+00:00 2 default_pool