Task Instances

  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success campaign-history-job_v002 create_emr_steps 2021-04-08T14:00:00+00:00 PythonOperator 2021-04-08T15:11:23.231011+00:00 2021-04-08T15:11:26.189637+00:00 0:00:02.958626 14965 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T15:11:20.763145+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-08T14:00:00+00:00 TriggerDagRunOperator 2021-04-08T15:11:15.720664+00:00 2021-04-08T15:11:16.265585+00:00 0:00:00.544921 14964 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T15:11:12.749368+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-08T14:00:00+00:00 TriggerDagRunOperator 2021-04-08T15:11:15.682374+00:00 2021-04-08T15:11:16.083488+00:00 0:00:00.401114 14963 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T15:11:12.749411+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-08T14:05:00+00:00 EmrJobFlowSensor 2021-04-08T15:05:56.792345+00:00 2021-04-08T15:14:59.335607+00:00 0:09:02.543262 14961 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T15:05:54.561146+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-08T14:05:00+00:00 EmrCreateJobFlowOperator 2021-04-08T15:05:36.715326+00:00 2021-04-08T15:05:38.450704+00:00 0:00:01.735378 14960 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T15:05:34.541600+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-08T14:05:00+00:00 PythonOperator 2021-04-08T15:05:14.790907+00:00 2021-04-08T15:05:17.605013+00:00 0:00:02.814106 14959 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T15:05:12.519438+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-08T14:00:00+00:00 EmrJobFlowSensor 2021-04-08T15:01:06.318607+00:00 2021-04-08T15:11:09.187705+00:00 0:10:02.869098 14958 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T15:01:04.143651+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-08T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T15:00:38.531829+00:00 2021-04-08T15:00:40.258174+00:00 0:00:01.726345 14957 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-08T15:00:36.174302+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-08T14:00:00+00:00 PythonOperator 2021-04-08T15:00:18.405622+00:00 2021-04-08T15:00:21.182009+00:00 0:00:02.776387 14956 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-08T15:00:16.144221+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-08T13:00:00+00:00 EmrJobFlowSensor 2021-04-08T14:19:36.527308+00:00 2021-04-08T14:28:39.054579+00:00 0:09:02.527271 14955 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T14:19:34.302866+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-08T13:00:00+00:00 EmrJobFlowSensor 2021-04-08T14:19:20.517053+00:00 2021-04-08T14:27:23.079315+00:00 0:08:02.562262 14954 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T14:19:18.297961+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-08T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T14:19:14.632689+00:00 2021-04-08T14:19:16.352847+00:00 0:00:01.720158 14953 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T14:19:12.358413+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-08T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T14:18:58.818354+00:00 2021-04-08T14:19:00.531593+00:00 0:00:01.713239 14952 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T14:18:56.350164+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-08T13:00:00+00:00 PythonOperator 2021-04-08T14:18:52.418465+00:00 2021-04-08T14:18:55.332692+00:00 0:00:02.914227 14951 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T14:18:50.238786+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-08T13:00:00+00:00 PythonOperator 2021-04-08T14:18:38.583952+00:00 2021-04-08T14:18:41.338023+00:00 0:00:02.754071 14950 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T14:18:36.229421+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-08T13:00:00+00:00 TriggerDagRunOperator 2021-04-08T14:18:28.961170+00:00 2021-04-08T14:18:29.475522+00:00 0:00:00.514352 14949 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T14:18:26.218409+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-08T13:00:00+00:00 TriggerDagRunOperator 2021-04-08T14:18:28.642508+00:00 2021-04-08T14:18:29.077629+00:00 0:00:00.435121 14948 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T14:18:26.218442+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-08T13:05:00+00:00 EmrJobFlowSensor 2021-04-08T14:08:25.018632+00:00 2021-04-08T14:17:27.647117+00:00 0:09:02.628485 14947 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T14:08:22.823059+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-08T13:00:00+00:00 EmrJobFlowSensor 2021-04-08T14:08:19.293712+00:00 2021-04-08T14:18:22.234580+00:00 0:10:02.940868 14946 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T14:08:16.819495+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-08T13:05:00+00:00 EmrCreateJobFlowOperator 2021-04-08T14:08:03.165031+00:00 2021-04-08T14:08:04.921427+00:00 0:00:01.756396 14945 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T14:08:00.866959+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-08T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T14:07:56.910115+00:00 2021-04-08T14:07:58.600475+00:00 0:00:01.690360 14944 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-08T14:07:54.797455+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-08T13:05:00+00:00 PythonOperator 2021-04-08T14:07:41.008237+00:00 2021-04-08T14:07:43.856112+00:00 0:00:02.847875 14943 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T14:07:38.778254+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-08T13:00:00+00:00 PythonOperator 2021-04-08T14:07:37.201440+00:00 2021-04-08T14:07:39.946466+00:00 0:00:02.745026 14942 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-08T14:07:34.774974+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-08T12:00:00+00:00 EmrJobFlowSensor 2021-04-08T13:12:00.714381+00:00 2021-04-08T13:20:03.165648+00:00 0:08:02.451267 14940 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T13:11:58.276804+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-08T12:00:00+00:00 EmrJobFlowSensor 2021-04-08T13:11:58.288866+00:00 2021-04-08T13:22:01.100506+00:00 0:10:02.811640 14939 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T13:11:56.197115+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-08T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T13:11:38.623696+00:00 2021-04-08T13:11:40.290042+00:00 0:00:01.666346 14938 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T13:11:36.182023+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-08T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T13:11:36.689801+00:00 2021-04-08T13:11:38.557475+00:00 0:00:01.867674 14937 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T13:11:34.183105+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-08T12:00:00+00:00 PythonOperator 2021-04-08T13:11:16.537951+00:00 2021-04-08T13:11:19.625389+00:00 0:00:03.087438 14936 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T13:11:14.114400+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-08T12:00:00+00:00 PythonOperator 2021-04-08T13:11:16.394223+00:00 2021-04-08T13:11:19.203790+00:00 0:00:02.809567 14935 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T13:11:14.114373+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-08T12:00:00+00:00 TriggerDagRunOperator 2021-04-08T13:11:02.558617+00:00 2021-04-08T13:11:03.014645+00:00 0:00:00.456028 14934 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T13:11:00.169699+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-08T12:00:00+00:00 TriggerDagRunOperator 2021-04-08T13:11:02.578331+00:00 2021-04-08T13:11:03.157130+00:00 0:00:00.578799 14933 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T13:11:00.169647+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-08T12:05:00+00:00 EmrJobFlowSensor 2021-04-08T13:06:01.909500+00:00 2021-04-08T13:15:04.512464+00:00 0:09:02.602964 14932 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T13:05:59.747504+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-08T12:05:00+00:00 EmrCreateJobFlowOperator 2021-04-08T13:05:39.866458+00:00 2021-04-08T13:05:41.512821+00:00 0:00:01.646363 14931 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T13:05:37.684286+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-08T12:05:00+00:00 PythonOperator 2021-04-08T13:05:17.990130+00:00 2021-04-08T13:05:20.689802+00:00 0:00:02.699672 14930 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T13:05:15.674758+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-08T12:00:00+00:00 EmrJobFlowSensor 2021-04-08T13:00:53.786838+00:00 2021-04-08T13:10:56.633126+00:00 0:10:02.846288 14929 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T13:00:51.350109+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-08T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T13:00:33.422331+00:00 2021-04-08T13:00:35.194811+00:00 0:00:01.772480 14928 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-08T13:00:31.260198+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-08T12:00:00+00:00 PythonOperator 2021-04-08T13:00:11.515333+00:00 2021-04-08T13:00:14.230576+00:00 0:00:02.715243 14927 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-08T13:00:09.231677+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-08T11:00:00+00:00 EmrJobFlowSensor 2021-04-08T12:12:19.645870+00:00 2021-04-08T12:21:22.437142+00:00 0:09:02.791272 14925 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T12:12:17.135370+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-08T11:00:00+00:00 EmrJobFlowSensor 2021-04-08T12:12:13.315376+00:00 2021-04-08T12:21:16.186505+00:00 0:09:02.871129 14924 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T12:12:11.121908+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-08T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T12:11:57.345469+00:00 2021-04-08T12:11:59.045254+00:00 0:00:01.699785 14923 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T12:11:55.107306+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-08T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T12:11:51.348034+00:00 2021-04-08T12:11:53.188167+00:00 0:00:01.840133 14922 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T12:11:49.104239+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-08T11:00:00+00:00 PythonOperator 2021-04-08T12:11:37.261760+00:00 2021-04-08T12:11:40.201670+00:00 0:00:02.939910 14921 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T12:11:35.095820+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-08T11:00:00+00:00 PythonOperator 2021-04-08T12:11:31.532467+00:00 2021-04-08T12:11:34.347255+00:00 0:00:02.814788 14920 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T12:11:29.146250+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-08T11:00:00+00:00 TriggerDagRunOperator 2021-04-08T12:11:21.347208+00:00 2021-04-08T12:11:21.770026+00:00 0:00:00.422818 14919 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T12:11:19.081855+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-08T11:00:00+00:00 TriggerDagRunOperator 2021-04-08T12:11:21.308393+00:00 2021-04-08T12:11:21.890288+00:00 0:00:00.581895 14918 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T12:11:19.081889+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-08T11:05:00+00:00 EmrJobFlowSensor 2021-04-08T12:06:06.647583+00:00 2021-04-08T12:15:09.292928+00:00 0:09:02.645345 14917 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T12:06:04.495554+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-08T11:05:00+00:00 EmrCreateJobFlowOperator 2021-04-08T12:05:42.598931+00:00 2021-04-08T12:05:44.274880+00:00 0:00:01.675949 14916 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T12:05:40.436583+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-08T11:05:00+00:00 PythonOperator 2021-04-08T12:05:22.542761+00:00 2021-04-08T12:05:25.225534+00:00 0:00:02.682773 14915 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T12:05:20.416626+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-08T11:00:00+00:00 EmrJobFlowSensor 2021-04-08T12:00:56.229623+00:00 2021-04-08T12:10:59.218211+00:00 0:10:02.988588 14914 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T12:00:54.042973+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-08T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T12:00:36.300949+00:00 2021-04-08T12:00:38.051553+00:00 0:00:01.750604 14913 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-08T12:00:34.019225+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-08T11:00:00+00:00 PythonOperator 2021-04-08T12:00:12.828398+00:00 2021-04-08T12:00:15.681294+00:00 0:00:02.852896 14912 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-08T12:00:10.055944+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-08T10:00:00+00:00 EmrJobFlowSensor 2021-04-08T11:12:16.033002+00:00 2021-04-08T11:22:18.995095+00:00 0:10:02.962093 14910 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T11:12:13.647498+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-08T10:00:00+00:00 EmrJobFlowSensor 2021-04-08T11:11:59.900888+00:00 2021-04-08T11:22:02.699456+00:00 0:10:02.798568 14909 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T11:11:57.584282+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-08T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T11:11:53.689253+00:00 2021-04-08T11:11:55.491242+00:00 0:00:01.801989 14908 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T11:11:51.518113+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-08T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T11:11:39.920333+00:00 2021-04-08T11:11:41.716073+00:00 0:00:01.795740 14907 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T11:11:37.516483+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-08T10:00:00+00:00 PythonOperator 2021-04-08T11:11:33.854367+00:00 2021-04-08T11:11:36.888964+00:00 0:00:03.034597 14906 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T11:11:31.497929+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-08T10:00:00+00:00 PythonOperator 2021-04-08T11:11:17.752411+00:00 2021-04-08T11:11:20.498976+00:00 0:00:02.746565 14905 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T11:11:15.426643+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-08T10:00:00+00:00 TriggerDagRunOperator 2021-04-08T11:11:11.939332+00:00 2021-04-08T11:11:12.346651+00:00 0:00:00.407319 14904 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T11:11:09.541092+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-08T10:00:00+00:00 TriggerDagRunOperator 2021-04-08T11:11:11.878617+00:00 2021-04-08T11:11:12.431123+00:00 0:00:00.552506 14903 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T11:11:09.541146+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-08T10:05:00+00:00 EmrJobFlowSensor 2021-04-08T11:05:47.163050+00:00 2021-04-08T11:13:49.719436+00:00 0:08:02.556386 14902 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T11:05:44.764488+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-08T10:05:00+00:00 EmrCreateJobFlowOperator 2021-04-08T11:05:27.010505+00:00 2021-04-08T11:05:28.693653+00:00 0:00:01.683148 14901 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T11:05:24.707448+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-08T10:05:00+00:00 PythonOperator 2021-04-08T11:05:05.178817+00:00 2021-04-08T11:05:08.100345+00:00 0:00:02.921528 14900 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T11:05:02.686266+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-08T10:00:00+00:00 EmrJobFlowSensor 2021-04-08T11:00:46.418777+00:00 2021-04-08T11:10:49.324217+00:00 0:10:02.905440 14899 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T11:00:44.160692+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-08T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T11:00:26.326841+00:00 2021-04-08T11:00:28.183202+00:00 0:00:01.856361 14898 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-08T11:00:24.060927+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-08T10:00:00+00:00 PythonOperator 2021-04-08T11:00:04.898195+00:00 2021-04-08T11:00:07.628822+00:00 0:00:02.730627 14897 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-08T11:00:02.038991+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-08T09:00:00+00:00 EmrJobFlowSensor 2021-04-08T10:13:17.909685+00:00 2021-04-08T10:23:20.632907+00:00 0:10:02.723222 14895 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T10:13:15.749846+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-08T09:00:00+00:00 EmrJobFlowSensor 2021-04-08T10:13:08.572825+00:00 2021-04-08T10:25:11.850813+00:00 0:12:03.277988 14894 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T10:13:05.737500+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-08T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T10:12:56.030554+00:00 2021-04-08T10:12:57.866562+00:00 0:00:01.836008 14893 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T10:12:53.731251+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-08T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T10:12:46.398582+00:00 2021-04-08T10:12:48.083552+00:00 0:00:01.684970 14892 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T10:12:43.741502+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-08T09:00:00+00:00 PythonOperator 2021-04-08T10:12:33.934809+00:00 2021-04-08T10:12:36.650410+00:00 0:00:02.715601 14891 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T10:12:31.707719+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-08T09:00:00+00:00 PythonOperator 2021-04-08T10:12:26.308787+00:00 2021-04-08T10:12:29.395524+00:00 0:00:03.086737 14890 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T10:12:23.789187+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-08T09:00:00+00:00 TriggerDagRunOperator 2021-04-08T10:12:20.159105+00:00 2021-04-08T10:12:20.704261+00:00 0:00:00.545156 14889 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T10:12:17.696508+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-08T09:00:00+00:00 TriggerDagRunOperator 2021-04-08T10:12:20.041757+00:00 2021-04-08T10:12:20.610431+00:00 0:00:00.568674 14888 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T10:12:17.696540+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-08T09:05:00+00:00 EmrJobFlowSensor 2021-04-08T10:05:57.467114+00:00 2021-04-08T10:14:00.073373+00:00 0:08:02.606259 14887 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T10:05:55.060629+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-08T09:05:00+00:00 EmrCreateJobFlowOperator 2021-04-08T10:05:37.144932+00:00 2021-04-08T10:05:38.933049+00:00 0:00:01.788117 14886 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T10:05:34.957289+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-08T09:05:00+00:00 PythonOperator 2021-04-08T10:05:15.259648+00:00 2021-04-08T10:05:18.075392+00:00 0:00:02.815744 14885 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T10:05:12.937594+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-08T09:00:00+00:00 EmrJobFlowSensor 2021-04-08T10:01:06.606849+00:00 2021-04-08T10:12:09.620545+00:00 0:11:03.013696 14884 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T10:01:04.450525+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-08T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T10:00:46.484457+00:00 2021-04-08T10:00:48.289968+00:00 0:00:01.805511 14883 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-08T10:00:44.348341+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-08T09:00:00+00:00 PythonOperator 2021-04-08T10:00:25.186508+00:00 2021-04-08T10:00:28.032683+00:00 0:00:02.846175 14882 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-08T10:00:22.330862+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-08T08:00:00+00:00 EmrJobFlowSensor 2021-04-08T09:12:30.984860+00:00 2021-04-08T09:20:33.552526+00:00 0:08:02.567666 14880 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T09:12:28.671583+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-08T08:00:00+00:00 EmrJobFlowSensor 2021-04-08T09:12:19.110316+00:00 2021-04-08T09:22:21.821459+00:00 0:10:02.711143 14879 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T09:12:16.599047+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-08T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T09:12:06.810641+00:00 2021-04-08T09:12:08.520433+00:00 0:00:01.709792 14878 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T09:12:04.588132+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-08T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T09:11:58.961899+00:00 2021-04-08T09:12:00.703251+00:00 0:00:01.741352 14877 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T09:11:56.649254+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-08T08:00:00+00:00 PythonOperator 2021-04-08T09:11:44.892164+00:00 2021-04-08T09:11:47.632054+00:00 0:00:02.739890 14876 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T09:11:42.559023+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-08T08:00:00+00:00 PythonOperator 2021-04-08T09:11:36.709626+00:00 2021-04-08T09:11:39.670569+00:00 0:00:02.960943 14875 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T09:11:34.549359+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-08T08:00:00+00:00 TriggerDagRunOperator 2021-04-08T09:11:23.171563+00:00 2021-04-08T09:11:23.898363+00:00 0:00:00.726800 14874 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T09:11:20.534666+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-08T08:00:00+00:00 TriggerDagRunOperator 2021-04-08T09:11:22.851328+00:00 2021-04-08T09:11:23.272225+00:00 0:00:00.420897 14873 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T09:11:20.534693+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-08T08:05:00+00:00 EmrJobFlowSensor 2021-04-08T09:05:47.890793+00:00 2021-04-08T09:14:50.480198+00:00 0:09:02.589405 14872 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T09:05:45.763409+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-08T08:05:00+00:00 EmrCreateJobFlowOperator 2021-04-08T09:05:28.042854+00:00 2021-04-08T09:05:29.777606+00:00 0:00:01.734752 14871 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T09:05:25.744006+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-08T08:05:00+00:00 PythonOperator 2021-04-08T09:05:05.857025+00:00 2021-04-08T09:05:08.520967+00:00 0:00:02.663942 14870 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T09:05:03.728818+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-08T08:00:00+00:00 EmrJobFlowSensor 2021-04-08T09:00:57.640184+00:00 2021-04-08T09:11:00.487703+00:00 0:10:02.847519 14869 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T09:00:55.391104+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-08T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T09:00:35.839839+00:00 2021-04-08T09:00:37.542318+00:00 0:00:01.702479 14868 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-08T09:00:33.383933+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-08T08:00:00+00:00 PythonOperator 2021-04-08T09:00:16.162686+00:00 2021-04-08T09:00:19.030737+00:00 0:00:02.868051 14867 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-08T09:00:13.363952+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-08T07:00:00+00:00 EmrJobFlowSensor 2021-04-08T08:13:00.613915+00:00 2021-04-08T08:24:03.522480+00:00 0:11:02.908565 14865 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T08:12:58.307009+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-08T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T08:12:38.641010+00:00 2021-04-08T08:12:40.334430+00:00 0:00:01.693420 14864 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T08:12:36.288081+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-08T07:00:00+00:00 EmrJobFlowSensor 2021-04-08T08:12:26.453854+00:00 2021-04-08T08:21:29.093432+00:00 0:09:02.639578 14863 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T08:12:24.256684+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-08T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T08:12:02.610923+00:00 2021-04-08T08:12:04.308415+00:00 0:00:01.697492 14862 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T08:12:00.234917+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-08T07:00:00+00:00 PythonOperator 2021-04-08T08:11:32.739638+00:00 2021-04-08T08:11:35.444059+00:00 0:00:02.704421 14861 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T08:11:30.249954+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-08T07:00:00+00:00 PythonOperator 2021-04-08T08:11:24.711504+00:00 2021-04-08T08:11:27.819612+00:00 0:00:03.108108 14860 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T08:11:22.255811+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-08T07:00:00+00:00 TriggerDagRunOperator 2021-04-08T08:11:10.539893+00:00 2021-04-08T08:11:11.098472+00:00 0:00:00.558579 14859 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T08:11:08.192641+00:00 2 default_pool