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-05-03T16:00:00+00:00 PythonOperator 2021-05-03T17:11:28.675106+00:00 2021-05-03T17:11:32.031511+00:00 0:00:03.356405 24081 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T17:11:25.805009+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-03T16:00:00+00:00 PythonOperator 2021-05-03T17:11:24.103671+00:00 2021-05-03T17:11:28.093306+00:00 0:00:03.989635 24080 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T17:11:21.800804+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-03T16:00:00+00:00 TriggerDagRunOperator 2021-05-03T17:11:06.309051+00:00 2021-05-03T17:11:06.878515+00:00 0:00:00.569464 24079 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T17:11:03.844834+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-03T16:00:00+00:00 TriggerDagRunOperator 2021-05-03T17:11:06.212248+00:00 2021-05-03T17:11:06.662604+00:00 0:00:00.450356 24078 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T17:11:03.844783+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-03T16:05:00+00:00 EmrJobFlowSensor 2021-05-03T17:05:57.385068+00:00 2021-05-03T17:13:59.920109+00:00 0:08:02.535041 24077 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T17:05:55.234728+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-03T16:05:00+00:00 EmrCreateJobFlowOperator 2021-05-03T17:05:37.378689+00:00 2021-05-03T17:05:39.108877+00:00 0:00:01.730188 24076 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-03T17:05:35.223407+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-03T16:05:00+00:00 PythonOperator 2021-05-03T17:05:07.381884+00:00 2021-05-03T17:05:10.414559+00:00 0:00:03.032675 24075 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T17:05:05.195523+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-03T16:00:00+00:00 EmrJobFlowSensor 2021-05-03T17:00:47.007405+00:00 2021-05-03T17:10:49.658714+00:00 0:10:02.651309 24074 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T17:00:44.751145+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-03T16:00:00+00:00 EmrCreateJobFlowOperator 2021-05-03T17:00:27.099841+00:00 2021-05-03T17:00:28.870966+00:00 0:00:01.771125 24073 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-03T17:00:24.684735+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-03T16:00:00+00:00 PythonOperator 2021-05-03T17:00:05.354213+00:00 2021-05-03T17:00:08.519013+00:00 0:00:03.164800 24072 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-03T17:00:02.740908+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-03T15:00:00+00:00 EmrJobFlowSensor 2021-05-03T16:12:41.417087+00:00 2021-05-03T16:21:44.088536+00:00 0:09:02.671449 24070 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T16:12:39.215059+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-03T15:00:00+00:00 EmrJobFlowSensor 2021-05-03T16:12:31.430940+00:00 2021-05-03T16:22:34.201102+00:00 0:10:02.770162 24069 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T16:12:29.207973+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-03T15:00:00+00:00 EmrCreateJobFlowOperator 2021-05-03T16:12:13.381307+00:00 2021-05-03T16:12:15.111171+00:00 0:00:01.729864 24068 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-03T16:12:11.193136+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-03T15:00:00+00:00 EmrCreateJobFlowOperator 2021-05-03T16:12:09.522318+00:00 2021-05-03T16:12:11.270059+00:00 0:00:01.747741 24067 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-03T16:12:07.270438+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-03T15:00:00+00:00 PythonOperator 2021-05-03T16:11:53.514850+00:00 2021-05-03T16:11:56.570538+00:00 0:00:03.055688 24066 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T16:11:51.142154+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-03T15:00:00+00:00 PythonOperator 2021-05-03T16:11:47.399050+00:00 2021-05-03T16:11:50.664535+00:00 0:00:03.265485 24065 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T16:11:45.148374+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-03T15:00:00+00:00 TriggerDagRunOperator 2021-05-03T16:11:25.610894+00:00 2021-05-03T16:11:26.174649+00:00 0:00:00.563755 24064 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T16:11:23.123003+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-03T15:00:00+00:00 TriggerDagRunOperator 2021-05-03T16:11:25.374198+00:00 2021-05-03T16:11:25.829256+00:00 0:00:00.455058 24063 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T16:11:23.122972+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-03T15:05:00+00:00 EmrJobFlowSensor 2021-05-03T16:06:02.787843+00:00 2021-05-03T16:15:05.360043+00:00 0:09:02.572200 24062 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T16:06:00.547308+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-03T15:05:00+00:00 EmrCreateJobFlowOperator 2021-05-03T16:05:40.795758+00:00 2021-05-03T16:05:42.435619+00:00 0:00:01.639861 24061 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-03T16:05:38.527806+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-03T15:05:00+00:00 PythonOperator 2021-05-03T16:05:20.565540+00:00 2021-05-03T16:05:23.601352+00:00 0:00:03.035812 24060 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T16:05:18.437884+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-03T15:00:00+00:00 EmrJobFlowSensor 2021-05-03T16:01:00.744495+00:00 2021-05-03T16:11:03.728119+00:00 0:10:02.983624 24059 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T16:00:58.175164+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-03T15:00:00+00:00 EmrCreateJobFlowOperator 2021-05-03T16:00:38.340678+00:00 2021-05-03T16:00:40.033016+00:00 0:00:01.692338 24058 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-03T16:00:36.044152+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-03T15:00:00+00:00 PythonOperator 2021-05-03T16:00:18.352504+00:00 2021-05-03T16:00:21.399473+00:00 0:00:03.046969 24057 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-03T16:00:15.999266+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-03T14:00:00+00:00 EmrJobFlowSensor 2021-05-03T15:11:38.134550+00:00 2021-05-03T15:19:40.665212+00:00 0:08:02.530662 24055 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T15:11:35.840543+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-03T14:00:00+00:00 EmrJobFlowSensor 2021-05-03T15:11:26.006653+00:00 2021-05-03T15:21:28.791814+00:00 0:10:02.785161 24054 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T15:11:23.829580+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-03T14:00:00+00:00 EmrCreateJobFlowOperator 2021-05-03T15:11:10.116903+00:00 2021-05-03T15:11:11.912639+00:00 0:00:01.795736 24053 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-03T15:11:07.814575+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-03T14:00:00+00:00 EmrCreateJobFlowOperator 2021-05-03T15:11:04.002600+00:00 2021-05-03T15:11:05.720521+00:00 0:00:01.717921 24052 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-03T15:11:01.812164+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-03T14:00:00+00:00 PythonOperator 2021-05-03T15:10:48.252349+00:00 2021-05-03T15:10:51.284795+00:00 0:00:03.032446 24051 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T15:10:45.864176+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-03T14:00:00+00:00 PythonOperator 2021-05-03T15:10:42.048364+00:00 2021-05-03T15:10:45.317195+00:00 0:00:03.268831 24050 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T15:10:39.797637+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-03T14:00:00+00:00 TriggerDagRunOperator 2021-05-03T15:10:24.070773+00:00 2021-05-03T15:10:24.619999+00:00 0:00:00.549226 24049 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T15:10:21.744095+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-03T14:00:00+00:00 TriggerDagRunOperator 2021-05-03T15:10:23.993486+00:00 2021-05-03T15:10:24.404867+00:00 0:00:00.411381 24048 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T15:10:21.744128+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-03T14:05:00+00:00 EmrJobFlowSensor 2021-05-03T15:06:09.737576+00:00 2021-05-03T15:14:12.236770+00:00 0:08:02.499194 24047 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T15:06:07.401552+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-03T14:05:00+00:00 EmrCreateJobFlowOperator 2021-05-03T15:05:47.463877+00:00 2021-05-03T15:05:49.115616+00:00 0:00:01.651739 24046 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-03T15:05:45.321339+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-03T14:05:00+00:00 PythonOperator 2021-05-03T15:05:25.701863+00:00 2021-05-03T15:05:28.752383+00:00 0:00:03.050520 24045 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T15:05:23.366419+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-03T14:00:00+00:00 EmrJobFlowSensor 2021-05-03T15:01:07.319392+00:00 2021-05-03T15:10:09.986973+00:00 0:09:02.667581 24044 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T15:01:04.961653+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-03T14:00:00+00:00 EmrCreateJobFlowOperator 2021-05-03T15:00:45.248470+00:00 2021-05-03T15:00:46.937665+00:00 0:00:01.689195 24043 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-03T15:00:42.868081+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-03T14:00:00+00:00 PythonOperator 2021-05-03T15:00:23.665381+00:00 2021-05-03T15:00:26.759754+00:00 0:00:03.094373 24042 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-03T15:00:20.852280+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-03T13:00:00+00:00 EmrJobFlowSensor 2021-05-03T14:11:18.945483+00:00 2021-05-03T14:20:21.505135+00:00 0:09:02.559652 24040 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T14:11:16.598097+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-03T13:00:00+00:00 EmrJobFlowSensor 2021-05-03T14:11:12.914134+00:00 2021-05-03T14:20:15.498900+00:00 0:09:02.584766 24039 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T14:11:10.592132+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-03T13:00:00+00:00 EmrCreateJobFlowOperator 2021-05-03T14:10:59.256778+00:00 2021-05-03T14:11:00.984959+00:00 0:00:01.728181 24038 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-03T14:10:56.532994+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-03T13:00:00+00:00 EmrCreateJobFlowOperator 2021-05-03T14:10:50.793515+00:00 2021-05-03T14:10:52.478553+00:00 0:00:01.685038 24037 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-03T14:10:48.525981+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-03T13:00:00+00:00 PythonOperator 2021-05-03T14:10:36.899237+00:00 2021-05-03T14:10:40.176123+00:00 0:00:03.276886 24036 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T14:10:34.574649+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-03T13:00:00+00:00 PythonOperator 2021-05-03T14:10:28.860291+00:00 2021-05-03T14:10:31.858775+00:00 0:00:02.998484 24035 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T14:10:26.507107+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-03T13:00:00+00:00 TriggerDagRunOperator 2021-05-03T14:10:25.203312+00:00 2021-05-03T14:10:25.746547+00:00 0:00:00.543235 24034 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T14:10:22.566977+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-03T13:00:00+00:00 TriggerDagRunOperator 2021-05-03T14:10:25.112403+00:00 2021-05-03T14:10:25.523811+00:00 0:00:00.411408 24033 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T14:10:22.566899+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-03T13:05:00+00:00 EmrJobFlowSensor 2021-05-03T14:06:12.408543+00:00 2021-05-03T14:15:15.147392+00:00 0:09:02.738849 24032 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T14:06:10.106029+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-03T13:05:00+00:00 EmrCreateJobFlowOperator 2021-05-03T14:05:50.356331+00:00 2021-05-03T14:05:51.995912+00:00 0:00:01.639581 24031 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-03T14:05:48.087045+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-03T13:05:00+00:00 PythonOperator 2021-05-03T14:05:20.293404+00:00 2021-05-03T14:05:23.242599+00:00 0:00:02.949195 24030 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T14:05:18.059531+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-03T13:00:00+00:00 EmrJobFlowSensor 2021-05-03T14:01:09.852122+00:00 2021-05-03T14:10:12.637439+00:00 0:09:02.785317 24029 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T14:01:07.573612+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-03T13:00:00+00:00 EmrCreateJobFlowOperator 2021-05-03T14:00:49.839626+00:00 2021-05-03T14:00:51.646057+00:00 0:00:01.806431 24028 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-03T14:00:47.520055+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-03T13:00:00+00:00 PythonOperator 2021-05-03T14:00:28.487591+00:00 2021-05-03T14:00:31.641197+00:00 0:00:03.153606 24027 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-03T14:00:25.555863+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-03T12:00:00+00:00 EmrJobFlowSensor 2021-05-03T13:11:28.965291+00:00 2021-05-03T13:21:31.743421+00:00 0:10:02.778130 24025 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T13:11:26.783645+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-03T12:00:00+00:00 EmrJobFlowSensor 2021-05-03T13:11:10.928464+00:00 2021-05-03T13:21:13.823771+00:00 0:10:02.895307 24024 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T13:11:08.756632+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-03T12:00:00+00:00 EmrCreateJobFlowOperator 2021-05-03T13:11:07.141224+00:00 2021-05-03T13:11:08.849139+00:00 0:00:01.707915 24023 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-03T13:11:04.844018+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-03T12:00:00+00:00 EmrCreateJobFlowOperator 2021-05-03T13:10:49.417670+00:00 2021-05-03T13:10:51.104086+00:00 0:00:01.686416 24022 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-03T13:10:46.694954+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-03T12:00:00+00:00 PythonOperator 2021-05-03T13:10:45.038313+00:00 2021-05-03T13:10:48.607536+00:00 0:00:03.569223 24021 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T13:10:42.762765+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-03T12:00:00+00:00 PythonOperator 2021-05-03T13:10:26.843633+00:00 2021-05-03T13:10:30.181512+00:00 0:00:03.337879 24020 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T13:10:24.622746+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-03T12:00:00+00:00 TriggerDagRunOperator 2021-05-03T13:10:23.035691+00:00 2021-05-03T13:10:23.561504+00:00 0:00:00.525813 24019 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T13:10:20.619700+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-03T12:00:00+00:00 TriggerDagRunOperator 2021-05-03T13:10:22.875668+00:00 2021-05-03T13:10:23.305732+00:00 0:00:00.430064 24018 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T13:10:20.619668+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-03T12:05:00+00:00 EmrJobFlowSensor 2021-05-03T13:05:56.785599+00:00 2021-05-03T13:14:59.317893+00:00 0:09:02.532294 24017 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T13:05:54.272663+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-03T12:05:00+00:00 EmrCreateJobFlowOperator 2021-05-03T13:05:36.637830+00:00 2021-05-03T13:05:38.435663+00:00 0:00:01.797833 24016 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-03T13:05:34.185420+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-03T12:05:00+00:00 PythonOperator 2021-05-03T13:05:14.503340+00:00 2021-05-03T13:05:17.559238+00:00 0:00:03.055898 24015 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T13:05:12.171199+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-03T12:00:00+00:00 EmrJobFlowSensor 2021-05-03T13:01:08.001807+00:00 2021-05-03T13:10:10.548373+00:00 0:09:02.546566 24014 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T13:01:05.838213+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-03T12:00:00+00:00 EmrCreateJobFlowOperator 2021-05-03T13:00:46.144364+00:00 2021-05-03T13:00:47.831764+00:00 0:00:01.687400 24013 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-03T13:00:43.872391+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-03T12:00:00+00:00 PythonOperator 2021-05-03T13:00:24.687924+00:00 2021-05-03T13:00:27.751518+00:00 0:00:03.063594 24012 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-03T13:00:21.860927+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-03T11:00:00+00:00 EmrJobFlowSensor 2021-05-03T12:11:17.390543+00:00 2021-05-03T12:21:20.143080+00:00 0:10:02.752537 24010 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T12:11:15.223086+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-03T11:00:00+00:00 EmrJobFlowSensor 2021-05-03T12:11:13.419999+00:00 2021-05-03T12:19:15.953015+00:00 0:08:02.533016 24009 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T12:11:11.221066+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-03T11:00:00+00:00 EmrCreateJobFlowOperator 2021-05-03T12:10:57.468708+00:00 2021-05-03T12:10:59.308768+00:00 0:00:01.840060 24008 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-03T12:10:55.208204+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-03T11:00:00+00:00 EmrCreateJobFlowOperator 2021-05-03T12:10:53.388706+00:00 2021-05-03T12:10:55.205544+00:00 0:00:01.816838 24007 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-03T12:10:51.203667+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-03T11:00:00+00:00 PythonOperator 2021-05-03T12:10:35.585827+00:00 2021-05-03T12:10:38.861052+00:00 0:00:03.275225 24006 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T12:10:33.190254+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-03T11:00:00+00:00 PythonOperator 2021-05-03T12:10:31.395251+00:00 2021-05-03T12:10:34.419293+00:00 0:00:03.024042 24005 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T12:10:29.184706+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-03T11:00:00+00:00 TriggerDagRunOperator 2021-05-03T12:10:15.710379+00:00 2021-05-03T12:10:16.142160+00:00 0:00:00.431781 24004 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T12:10:13.183528+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-03T11:00:00+00:00 TriggerDagRunOperator 2021-05-03T12:10:15.704781+00:00 2021-05-03T12:10:16.250992+00:00 0:00:00.546211 24003 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T12:10:13.183563+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-03T11:05:00+00:00 EmrJobFlowSensor 2021-05-03T12:05:52.950992+00:00 2021-05-03T12:13:55.372826+00:00 0:08:02.421834 24002 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T12:05:50.661100+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-03T11:05:00+00:00 EmrCreateJobFlowOperator 2021-05-03T12:05:30.935463+00:00 2021-05-03T12:05:32.592127+00:00 0:00:01.656664 24001 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-03T12:05:28.657011+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-03T11:05:00+00:00 PythonOperator 2021-05-03T12:05:10.928434+00:00 2021-05-03T12:05:13.979452+00:00 0:00:03.051018 24000 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T12:05:08.501573+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-03T11:00:00+00:00 EmrJobFlowSensor 2021-05-03T12:00:54.390648+00:00 2021-05-03T12:09:57.054966+00:00 0:09:02.664318 23999 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T12:00:52.120105+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-03T11:00:00+00:00 EmrCreateJobFlowOperator 2021-05-03T12:00:32.311631+00:00 2021-05-03T12:00:34.008799+00:00 0:00:01.697168 23998 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-03T12:00:30.100613+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-03T11:00:00+00:00 PythonOperator 2021-05-03T12:00:10.437916+00:00 2021-05-03T12:00:13.476308+00:00 0:00:03.038392 23997 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-03T12:00:08.076038+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-03T10:00:00+00:00 EmrJobFlowSensor 2021-05-03T11:14:30.027448+00:00 2021-05-03T11:23:32.657922+00:00 0:09:02.630474 23996 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T11:14:27.784577+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-03T10:00:00+00:00 EmrJobFlowSensor 2021-05-03T11:14:21.933861+00:00 2021-05-03T11:24:24.707223+00:00 0:10:02.773362 23995 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T11:14:19.766426+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-03T10:00:00+00:00 EmrCreateJobFlowOperator 2021-05-03T11:14:10.577399+00:00 2021-05-03T11:14:12.412118+00:00 0:00:01.834719 23994 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-03T11:14:07.755982+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-03T10:00:00+00:00 EmrCreateJobFlowOperator 2021-05-03T11:14:02.115745+00:00 2021-05-03T11:14:04.002503+00:00 0:00:01.886758 23993 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-03T11:13:59.750541+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-03T10:00:00+00:00 PythonOperator 2021-05-03T11:10:40.515606+00:00 2021-05-03T11:10:43.546763+00:00 0:00:03.031157 23991 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T11:10:38.043867+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-03T10:00:00+00:00 PythonOperator 2021-05-03T11:10:40.418436+00:00 2021-05-03T11:10:43.666605+00:00 0:00:03.248169 23990 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T11:10:38.043815+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-03T10:00:00+00:00 TriggerDagRunOperator 2021-05-03T11:10:30.670688+00:00 2021-05-03T11:10:31.199323+00:00 0:00:00.528635 23989 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T11:10:27.617869+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-03T10:00:00+00:00 TriggerDagRunOperator 2021-05-03T11:10:30.424859+00:00 2021-05-03T11:10:30.872919+00:00 0:00:00.448060 23988 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T11:10:27.617836+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-03T10:05:00+00:00 EmrJobFlowSensor 2021-05-03T11:06:05.601161+00:00 2021-05-03T11:14:08.136876+00:00 0:08:02.535715 23987 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T11:06:03.261622+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-03T10:05:00+00:00 EmrCreateJobFlowOperator 2021-05-03T11:05:41.450043+00:00 2021-05-03T11:05:43.179527+00:00 0:00:01.729484 23986 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-03T11:05:39.242235+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-03T10:05:00+00:00 PythonOperator 2021-05-03T11:05:19.384195+00:00 2021-05-03T11:05:22.411560+00:00 0:00:03.027365 23985 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T11:05:17.221246+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-03T10:00:00+00:00 EmrJobFlowSensor 2021-05-03T11:01:03.039972+00:00 2021-05-03T11:10:05.737358+00:00 0:09:02.697386 23984 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T11:01:00.788277+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-03T10:00:00+00:00 EmrCreateJobFlowOperator 2021-05-03T11:00:40.906190+00:00 2021-05-03T11:00:42.650798+00:00 0:00:01.744608 23983 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-03T11:00:38.773702+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-03T10:00:00+00:00 PythonOperator 2021-05-03T11:00:16.922240+00:00 2021-05-03T11:00:19.958570+00:00 0:00:03.036330 23982 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-03T11:00:14.695478+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-03T09:00:00+00:00 EmrJobFlowSensor 2021-05-03T10:11:56.014689+00:00 2021-05-03T10:21:58.789485+00:00 0:10:02.774796 23981 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T10:11:53.853143+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-03T09:00:00+00:00 EmrJobFlowSensor 2021-05-03T10:11:44.016960+00:00 2021-05-03T10:20:46.606250+00:00 0:09:02.589290 23980 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T10:11:41.840941+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-03T09:00:00+00:00 EmrCreateJobFlowOperator 2021-05-03T10:11:34.141329+00:00 2021-05-03T10:11:35.967005+00:00 0:00:01.825676 23979 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-03T10:11:31.828854+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-03T09:00:00+00:00 EmrCreateJobFlowOperator 2021-05-03T10:11:22.057433+00:00 2021-05-03T10:11:23.916500+00:00 0:00:01.859067 23978 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-03T10:11:19.818654+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-03T09:00:00+00:00 PythonOperator 2021-05-03T10:11:12.140527+00:00 2021-05-03T10:11:15.424548+00:00 0:00:03.284021 23977 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T10:11:09.810775+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-03T09:00:00+00:00 PythonOperator 2021-05-03T10:11:00.301546+00:00 2021-05-03T10:11:03.315800+00:00 0:00:03.014254 23976 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T10:10:57.858291+00:00 2 default_pool