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 livepop-shuffle-job_v002 check_cluster_status 2021-07-05T19:00:00+00:00 EmrJobFlowSensor 2021-07-05T20:01:08.674394+00:00 2021-07-05T20:11:11.646120+00:00 0:10:02.971726 50269 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-05T20:01:06.518254+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-07-05T19:00:00+00:00 EmrJobFlowSensor 2021-07-05T20:00:59.051411+00:00 2021-07-05T20:10:01.934088+00:00 0:09:02.882677 50268 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-05T20:00:56.565991+00:00 2 default_pool
success livepop-shuffle-job_v002 create_cluster_and_add_emr_steps 2021-07-05T19:00:00+00:00 EmrCreateJobFlowOperator 2021-07-05T20:00:44.960826+00:00 2021-07-05T20:00:46.794908+00:00 0:00:01.834082 50267 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-05T20:00:42.501606+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-07-05T19:00:00+00:00 EmrCreateJobFlowOperator 2021-07-05T20:00:38.701273+00:00 2021-07-05T20:00:40.400468+00:00 0:00:01.699195 50266 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-07-05T20:00:36.493872+00:00 2 default_pool
success livepop-shuffle-job_v002 create_emr_steps 2021-07-05T19:00:00+00:00 PythonOperator 2021-07-05T20:00:22.931647+00:00 2021-07-05T20:00:26.654654+00:00 0:00:03.723007 50265 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-05T20:00:20.432850+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-07-05T19:00:00+00:00 PythonOperator 2021-07-05T20:00:17.073987+00:00 2021-07-05T20:00:20.937676+00:00 0:00:03.863689 50264 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-07-05T20:00:14.433080+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-05T18:00:00+00:00 EmrJobFlowSensor 2021-07-05T19:11:19.622988+00:00 2021-07-05T19:20:22.447454+00:00 0:09:02.824466 50262 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-05T19:11:17.325373+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-05T18:00:00+00:00 EmrJobFlowSensor 2021-07-05T19:11:15.785138+00:00 2021-07-05T19:20:18.528625+00:00 0:09:02.743487 50261 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-05T19:11:13.321553+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-05T18:00:00+00:00 EmrCreateJobFlowOperator 2021-07-05T19:10:56.086123+00:00 2021-07-05T19:10:57.962223+00:00 0:00:01.876100 50260 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-05T19:10:53.304796+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-05T18:00:00+00:00 EmrCreateJobFlowOperator 2021-07-05T19:10:47.516493+00:00 2021-07-05T19:10:49.371585+00:00 0:00:01.855092 50259 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-05T19:10:45.298143+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-05T18:00:00+00:00 PythonOperator 2021-07-05T19:10:27.581086+00:00 2021-07-05T19:10:31.541528+00:00 0:00:03.960442 50258 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-05T19:10:25.287022+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-05T18:00:00+00:00 PythonOperator 2021-07-05T19:10:21.799122+00:00 2021-07-05T19:10:25.526295+00:00 0:00:03.727173 50257 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-05T19:10:19.264495+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-07-05T18:00:00+00:00 TriggerDagRunOperator 2021-07-05T19:10:13.551990+00:00 2021-07-05T19:10:14.140816+00:00 0:00:00.588826 50256 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-05T19:10:11.258322+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-07-05T18:00:00+00:00 TriggerDagRunOperator 2021-07-05T19:10:13.493203+00:00 2021-07-05T19:10:13.928025+00:00 0:00:00.434822 50255 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-05T19:10:11.258288+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-07-05T18:05:00+00:00 EmrJobFlowSensor 2021-07-05T19:06:05.011303+00:00 2021-07-05T19:15:07.568778+00:00 0:09:02.557475 50254 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-05T19:06:02.889322+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-07-05T18:05:00+00:00 EmrCreateJobFlowOperator 2021-07-05T19:05:43.036318+00:00 2021-07-05T19:05:44.810153+00:00 0:00:01.773835 50253 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-05T19:05:40.812729+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-07-05T18:05:00+00:00 PythonOperator 2021-07-05T19:05:20.966258+00:00 2021-07-05T19:05:24.658821+00:00 0:00:03.692563 50252 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-05T19:05:18.799925+00:00 2 default_pool
success livepop-shuffle-job_v002 check_cluster_status 2021-07-05T18:00:00+00:00 EmrJobFlowSensor 2021-07-05T19:00:54.412608+00:00 2021-07-05T19:10:57.423209+00:00 0:10:03.010601 50251 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-05T19:00:52.202350+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-07-05T18:00:00+00:00 EmrJobFlowSensor 2021-07-05T19:00:48.382274+00:00 2021-07-05T19:09:51.071678+00:00 0:09:02.689404 50250 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-05T19:00:46.192888+00:00 2 default_pool
success livepop-shuffle-job_v002 create_cluster_and_add_emr_steps 2021-07-05T18:00:00+00:00 EmrCreateJobFlowOperator 2021-07-05T19:00:32.902503+00:00 2021-07-05T19:00:34.589781+00:00 0:00:01.687278 50249 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-05T19:00:30.187690+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-07-05T18:00:00+00:00 EmrCreateJobFlowOperator 2021-07-05T19:00:28.384323+00:00 2021-07-05T19:00:30.152514+00:00 0:00:01.768191 50248 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-07-05T19:00:26.123252+00:00 2 default_pool
success livepop-shuffle-job_v002 create_emr_steps 2021-07-05T18:00:00+00:00 PythonOperator 2021-07-05T19:00:10.675109+00:00 2021-07-05T19:00:14.162433+00:00 0:00:03.487324 50247 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-05T19:00:08.157424+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-07-05T18:00:00+00:00 PythonOperator 2021-07-05T19:00:06.880916+00:00 2021-07-05T19:00:10.513359+00:00 0:00:03.632443 50246 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-07-05T19:00:04.163602+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-05T17:00:00+00:00 EmrJobFlowSensor 2021-07-05T18:11:27.022980+00:00 2021-07-05T18:21:30.032831+00:00 0:10:03.009851 50244 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-05T18:11:24.885522+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-05T17:00:00+00:00 EmrJobFlowSensor 2021-07-05T18:11:25.101064+00:00 2021-07-05T18:19:27.720762+00:00 0:08:02.619698 50243 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-05T18:11:22.884488+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-05T17:00:00+00:00 EmrCreateJobFlowOperator 2021-07-05T18:11:07.576739+00:00 2021-07-05T18:11:09.321732+00:00 0:00:01.744993 50242 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-05T18:11:04.865666+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-05T17:00:00+00:00 EmrCreateJobFlowOperator 2021-07-05T18:11:05.524945+00:00 2021-07-05T18:11:07.496003+00:00 0:00:01.971058 50241 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-05T18:11:02.864888+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-05T17:00:00+00:00 PythonOperator 2021-07-05T18:10:43.077766+00:00 2021-07-05T18:10:46.900874+00:00 0:00:03.823108 50240 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-05T18:10:40.795954+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-05T17:00:00+00:00 PythonOperator 2021-07-05T18:10:41.170031+00:00 2021-07-05T18:10:44.651836+00:00 0:00:03.481805 50239 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-05T18:10:38.796318+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-07-05T17:00:00+00:00 TriggerDagRunOperator 2021-07-05T18:10:19.256496+00:00 2021-07-05T18:10:19.748004+00:00 0:00:00.491508 50238 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-05T18:10:16.761393+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-07-05T17:00:00+00:00 TriggerDagRunOperator 2021-07-05T18:10:19.108960+00:00 2021-07-05T18:10:19.491144+00:00 0:00:00.382184 50237 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-05T18:10:16.761442+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-07-05T17:05:00+00:00 EmrJobFlowSensor 2021-07-05T18:05:52.537091+00:00 2021-07-05T18:14:55.267792+00:00 0:09:02.730701 50236 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-05T18:05:50.337354+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-07-05T17:05:00+00:00 EmrCreateJobFlowOperator 2021-07-05T18:05:31.029199+00:00 2021-07-05T18:05:32.768032+00:00 0:00:01.738833 50235 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-05T18:05:28.462481+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-07-05T17:05:00+00:00 PythonOperator 2021-07-05T18:05:08.660173+00:00 2021-07-05T18:05:12.353025+00:00 0:00:03.692852 50234 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-05T18:05:06.364010+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-07-05T17:00:00+00:00 EmrJobFlowSensor 2021-07-05T18:01:06.199966+00:00 2021-07-05T18:10:09.057117+00:00 0:09:02.857151 50233 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-05T18:01:03.989989+00:00 2 default_pool
success livepop-shuffle-job_v002 check_cluster_status 2021-07-05T17:00:00+00:00 EmrJobFlowSensor 2021-07-05T18:01:04.193891+00:00 2021-07-05T18:13:07.312058+00:00 0:12:03.118167 50232 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-05T18:01:01.984914+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-07-05T17:00:00+00:00 EmrCreateJobFlowOperator 2021-07-05T18:00:46.258902+00:00 2021-07-05T18:00:48.122294+00:00 0:00:01.863392 50231 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-07-05T18:00:43.916564+00:00 2 default_pool
success livepop-shuffle-job_v002 create_cluster_and_add_emr_steps 2021-07-05T17:00:00+00:00 EmrCreateJobFlowOperator 2021-07-05T18:00:40.380840+00:00 2021-07-05T18:00:42.221157+00:00 0:00:01.840317 50230 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-05T18:00:37.911040+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-07-05T17:00:00+00:00 PythonOperator 2021-07-05T18:00:25.400176+00:00 2021-07-05T18:00:29.121111+00:00 0:00:03.720935 50229 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-07-05T18:00:21.963672+00:00 2 default_pool
success livepop-shuffle-job_v002 create_emr_steps 2021-07-05T17:00:00+00:00 PythonOperator 2021-07-05T18:00:20.444854+00:00 2021-07-05T18:00:25.336859+00:00 0:00:04.892005 50228 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-05T18:00:17.898940+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-05T16:00:00+00:00 EmrJobFlowSensor 2021-07-05T17:11:49.606985+00:00 2021-07-05T17:21:52.499828+00:00 0:10:02.892843 50226 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-05T17:11:47.326655+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-05T16:00:00+00:00 EmrJobFlowSensor 2021-07-05T17:11:45.603680+00:00 2021-07-05T17:21:48.593987+00:00 0:10:02.990307 50225 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-05T17:11:43.319455+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-05T16:00:00+00:00 EmrCreateJobFlowOperator 2021-07-05T17:11:27.430994+00:00 2021-07-05T17:11:29.147325+00:00 0:00:01.716331 50224 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-05T17:11:25.303912+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-05T16:00:00+00:00 EmrCreateJobFlowOperator 2021-07-05T17:11:23.528108+00:00 2021-07-05T17:11:25.396750+00:00 0:00:01.868642 50223 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-05T17:11:21.301088+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-05T16:00:00+00:00 PythonOperator 2021-07-05T17:10:59.581753+00:00 2021-07-05T17:11:03.232121+00:00 0:00:03.650368 50222 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-05T17:10:57.268004+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-05T16:00:00+00:00 PythonOperator 2021-07-05T17:10:47.389156+00:00 2021-07-05T17:10:51.051846+00:00 0:00:03.662690 50221 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-05T17:10:45.256753+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-07-05T16:00:00+00:00 TriggerDagRunOperator 2021-07-05T17:10:27.485522+00:00 2021-07-05T17:10:27.999132+00:00 0:00:00.513610 50220 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-05T17:10:25.201965+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-07-05T16:00:00+00:00 TriggerDagRunOperator 2021-07-05T17:10:27.381074+00:00 2021-07-05T17:10:27.853693+00:00 0:00:00.472619 50219 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-05T17:10:25.201999+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-07-05T16:05:00+00:00 EmrJobFlowSensor 2021-07-05T17:06:15.103267+00:00 2021-07-05T17:15:17.827148+00:00 0:09:02.723881 50218 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-05T17:06:12.698940+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-07-05T16:05:00+00:00 EmrCreateJobFlowOperator 2021-07-05T17:05:50.755981+00:00 2021-07-05T17:05:52.444570+00:00 0:00:01.688589 50217 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-05T17:05:48.654854+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-07-05T16:05:00+00:00 PythonOperator 2021-07-05T17:05:24.747897+00:00 2021-07-05T17:05:28.363917+00:00 0:00:03.616020 50216 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-05T17:05:22.530686+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-07-05T16:00:00+00:00 EmrJobFlowSensor 2021-07-05T17:01:00.819070+00:00 2021-07-05T17:10:03.684900+00:00 0:09:02.865830 50215 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-05T17:00:58.167455+00:00 2 default_pool
success livepop-shuffle-job_v002 check_cluster_status 2021-07-05T16:00:00+00:00 EmrJobFlowSensor 2021-07-05T17:00:50.512345+00:00 2021-07-05T17:11:53.637536+00:00 0:11:03.125191 50214 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-05T17:00:48.010808+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-07-05T16:00:00+00:00 EmrCreateJobFlowOperator 2021-07-05T17:00:38.709231+00:00 2021-07-05T17:00:40.461665+00:00 0:00:01.752434 50213 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-07-05T17:00:36.052691+00:00 2 default_pool
success livepop-shuffle-job_v002 create_cluster_and_add_emr_steps 2021-07-05T16:00:00+00:00 EmrCreateJobFlowOperator 2021-07-05T17:00:30.295358+00:00 2021-07-05T17:00:31.995407+00:00 0:00:01.700049 50212 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-05T17:00:27.989273+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-07-05T16:00:00+00:00 PythonOperator 2021-07-05T17:00:16.659283+00:00 2021-07-05T17:00:20.302593+00:00 0:00:03.643310 50211 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-07-05T17:00:13.983212+00:00 2 default_pool
success livepop-shuffle-job_v002 create_emr_steps 2021-07-05T16:00:00+00:00 PythonOperator 2021-07-05T17:00:08.172856+00:00 2021-07-05T17:00:11.867301+00:00 0:00:03.694445 50210 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-05T17:00:05.920650+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-05T15:00:00+00:00 EmrJobFlowSensor 2021-07-05T16:11:00.107996+00:00 2021-07-05T16:21:03.155673+00:00 0:10:03.047677 50208 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-05T16:10:57.566204+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-05T15:00:00+00:00 EmrJobFlowSensor 2021-07-05T16:10:51.697763+00:00 2021-07-05T16:20:54.499519+00:00 0:10:02.801756 50207 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-05T16:10:49.535259+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-05T15:00:00+00:00 EmrCreateJobFlowOperator 2021-07-05T16:10:37.674863+00:00 2021-07-05T16:10:39.433275+00:00 0:00:01.758412 50206 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-05T16:10:35.524117+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-05T15:00:00+00:00 EmrCreateJobFlowOperator 2021-07-05T16:10:31.684252+00:00 2021-07-05T16:10:33.411407+00:00 0:00:01.727155 50205 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-05T16:10:29.520367+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-05T15:00:00+00:00 PythonOperator 2021-07-05T16:10:17.780104+00:00 2021-07-05T16:10:21.140883+00:00 0:00:03.360779 50204 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-05T16:10:15.507466+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-05T15:00:00+00:00 PythonOperator 2021-07-05T16:10:09.898302+00:00 2021-07-05T16:10:13.935670+00:00 0:00:04.037368 50203 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-05T16:10:07.522262+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-07-05T15:00:00+00:00 TriggerDagRunOperator 2021-07-05T16:10:00.311547+00:00 2021-07-05T16:10:00.804520+00:00 0:00:00.492973 50202 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-05T16:09:57.505169+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-07-05T15:00:00+00:00 TriggerDagRunOperator 2021-07-05T16:09:59.987987+00:00 2021-07-05T16:10:00.531176+00:00 0:00:00.543189 50201 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-05T16:09:57.505127+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-07-05T15:05:00+00:00 EmrJobFlowSensor 2021-07-05T16:05:51.233721+00:00 2021-07-05T16:14:53.913363+00:00 0:09:02.679642 50200 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-05T16:05:49.144615+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-07-05T15:05:00+00:00 EmrCreateJobFlowOperator 2021-07-05T16:05:29.307572+00:00 2021-07-05T16:05:30.926251+00:00 0:00:01.618679 50199 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-05T16:05:27.133307+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-07-05T15:05:00+00:00 PythonOperator 2021-07-05T16:05:09.494677+00:00 2021-07-05T16:05:12.886102+00:00 0:00:03.391425 50198 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-05T16:05:07.110918+00:00 2 default_pool
success livepop-shuffle-job_v002 check_cluster_status 2021-07-05T15:00:00+00:00 EmrJobFlowSensor 2021-07-05T16:00:59.167047+00:00 2021-07-05T16:12:02.059762+00:00 0:11:02.892715 50197 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-05T16:00:56.852215+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-07-05T15:00:00+00:00 EmrJobFlowSensor 2021-07-05T16:00:51.144703+00:00 2021-07-05T16:09:53.965839+00:00 0:09:02.821136 50196 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-05T16:00:48.700263+00:00 2 default_pool
success livepop-shuffle-job_v002 create_cluster_and_add_emr_steps 2021-07-05T15:00:00+00:00 EmrCreateJobFlowOperator 2021-07-05T16:00:36.980407+00:00 2021-07-05T16:00:38.656617+00:00 0:00:01.676210 50195 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-05T16:00:34.688137+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-07-05T15:00:00+00:00 EmrCreateJobFlowOperator 2021-07-05T16:00:31.298217+00:00 2021-07-05T16:00:33.041668+00:00 0:00:01.743451 50194 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-07-05T16:00:28.767118+00:00 2 default_pool
success livepop-shuffle-job_v002 create_emr_steps 2021-07-05T15:00:00+00:00 PythonOperator 2021-07-05T16:00:15.029204+00:00 2021-07-05T16:00:18.772129+00:00 0:00:03.742925 50193 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-05T16:00:12.627437+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-07-05T15:00:00+00:00 PythonOperator 2021-07-05T16:00:08.790882+00:00 2021-07-05T16:00:12.550612+00:00 0:00:03.759730 50192 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-07-05T16:00:06.617960+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-05T14:00:00+00:00 EmrJobFlowSensor 2021-07-05T15:11:12.712467+00:00 2021-07-05T15:21:15.592099+00:00 0:10:02.879632 50186 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-05T15:11:10.499584+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-05T14:00:00+00:00 EmrJobFlowSensor 2021-07-05T15:11:06.808421+00:00 2021-07-05T15:20:09.530277+00:00 0:09:02.721856 50185 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-05T15:11:04.572645+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-05T14:00:00+00:00 EmrCreateJobFlowOperator 2021-07-05T15:10:50.765030+00:00 2021-07-05T15:10:52.572168+00:00 0:00:01.807138 50184 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-05T15:10:48.486524+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-05T14:00:00+00:00 EmrCreateJobFlowOperator 2021-07-05T15:10:44.707004+00:00 2021-07-05T15:10:46.462938+00:00 0:00:01.755934 50183 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-05T15:10:42.445935+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-05T14:00:00+00:00 PythonOperator 2021-07-05T15:10:30.715157+00:00 2021-07-05T15:10:34.695872+00:00 0:00:03.980715 50182 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-05T15:10:28.450846+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-05T14:00:00+00:00 PythonOperator 2021-07-05T15:10:24.668708+00:00 2021-07-05T15:10:28.290620+00:00 0:00:03.621912 50181 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-05T15:10:22.424807+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-07-05T14:00:00+00:00 TriggerDagRunOperator 2021-07-05T15:10:08.785948+00:00 2021-07-05T15:10:09.305644+00:00 0:00:00.519696 50180 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-05T15:10:06.416122+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-07-05T14:00:00+00:00 TriggerDagRunOperator 2021-07-05T15:10:08.750270+00:00 2021-07-05T15:10:09.185400+00:00 0:00:00.435130 50179 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-05T15:10:06.416157+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-07-05T14:05:00+00:00 EmrJobFlowSensor 2021-07-05T15:05:56.289333+00:00 2021-07-05T15:14:59.093755+00:00 0:09:02.804422 50178 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-05T15:05:54.036986+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-07-05T14:05:00+00:00 EmrCreateJobFlowOperator 2021-07-05T15:05:34.574245+00:00 2021-07-05T15:05:36.244712+00:00 0:00:01.670467 50177 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-05T15:05:32.068676+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-07-05T14:05:00+00:00 PythonOperator 2021-07-05T15:05:14.243132+00:00 2021-07-05T15:05:17.899243+00:00 0:00:03.656111 50176 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-05T15:05:12.002951+00:00 2 default_pool
success livepop-shuffle-job_v002 check_cluster_status 2021-07-05T14:00:00+00:00 EmrJobFlowSensor 2021-07-05T15:00:58.106388+00:00 2021-07-05T15:12:01.241814+00:00 0:11:03.135426 50175 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-05T15:00:55.734690+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-07-05T14:00:00+00:00 EmrJobFlowSensor 2021-07-05T15:00:50.074401+00:00 2021-07-05T15:09:52.776117+00:00 0:09:02.701716 50174 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-05T15:00:47.724021+00:00 2 default_pool
success livepop-shuffle-job_v002 create_cluster_and_add_emr_steps 2021-07-05T14:00:00+00:00 EmrCreateJobFlowOperator 2021-07-05T15:00:36.142607+00:00 2021-07-05T15:00:37.860568+00:00 0:00:01.717961 50173 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-05T15:00:33.781372+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-07-05T14:00:00+00:00 EmrCreateJobFlowOperator 2021-07-05T15:00:28.267723+00:00 2021-07-05T15:00:30.072046+00:00 0:00:01.804323 50172 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-07-05T15:00:25.754205+00:00 2 default_pool
success livepop-shuffle-job_v002 create_emr_steps 2021-07-05T14:00:00+00:00 PythonOperator 2021-07-05T15:00:16.159104+00:00 2021-07-05T15:00:19.515506+00:00 0:00:03.356402 50171 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-05T15:00:13.772646+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-07-05T14:00:00+00:00 PythonOperator 2021-07-05T15:00:06.117749+00:00 2021-07-05T15:00:09.905305+00:00 0:00:03.787556 50170 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-07-05T15:00:03.693280+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-05T13:00:00+00:00 EmrJobFlowSensor 2021-07-05T14:11:32.204954+00:00 2021-07-05T14:21:34.986720+00:00 0:10:02.781766 50168 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-05T14:11:29.653617+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-05T13:00:00+00:00 EmrJobFlowSensor 2021-07-05T14:11:21.658665+00:00 2021-07-05T14:21:24.521203+00:00 0:10:02.862538 50167 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-05T14:11:19.489648+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-05T13:00:00+00:00 EmrCreateJobFlowOperator 2021-07-05T14:11:10.119156+00:00 2021-07-05T14:11:11.817293+00:00 0:00:01.698137 50166 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-05T14:11:07.459519+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-05T13:00:00+00:00 EmrCreateJobFlowOperator 2021-07-05T14:11:01.710868+00:00 2021-07-05T14:11:03.392777+00:00 0:00:01.681909 50165 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-05T14:10:59.453349+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-05T13:00:00+00:00 PythonOperator 2021-07-05T14:10:47.624244+00:00 2021-07-05T14:10:51.188779+00:00 0:00:03.564535 50164 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-05T14:10:45.413152+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-05T13:00:00+00:00 PythonOperator 2021-07-05T14:10:39.594928+00:00 2021-07-05T14:10:43.323023+00:00 0:00:03.728095 50163 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-05T14:10:37.416145+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-07-05T13:00:00+00:00 TriggerDagRunOperator 2021-07-05T14:10:21.967875+00:00 2021-07-05T14:10:22.462719+00:00 0:00:00.494844 50162 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-05T14:10:19.389403+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-07-05T13:00:00+00:00 TriggerDagRunOperator 2021-07-05T14:10:21.630688+00:00 2021-07-05T14:10:22.092540+00:00 0:00:00.461852 50161 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-05T14:10:19.389373+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-07-05T13:05:00+00:00 EmrJobFlowSensor 2021-07-05T14:05:55.289375+00:00 2021-07-05T14:14:58.003894+00:00 0:09:02.714519 50160 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-05T14:05:52.978126+00:00 2 default_pool