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-07-13T14:00:00+00:00 PythonOperator 2021-07-14T17:47:15.115358+00:00 2021-07-14T17:47:18.827827+00:00 0:00:03.712469 53449 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-14T17:47:12.649107+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-13T13:00:00+00:00 EmrCreateJobFlowOperator 2021-07-14T17:46:35.181395+00:00 2021-07-14T17:46:36.839681+00:00 0:00:01.658286 53448 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-14T17:46:32.558595+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-13T13:00:00+00:00 PythonOperator 2021-07-14T17:36:06.938844+00:00 2021-07-14T17:36:10.658986+00:00 0:00:03.720142 53446 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-14T17:36:04.611232+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-13T12:00:00+00:00 EmrJobFlowSensor 2021-07-14T17:36:06.848785+00:00 2021-07-14T17:46:10.102376+00:00 0:10:03.253591 53445 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-14T17:36:04.611259+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-13T12:00:00+00:00 EmrCreateJobFlowOperator 2021-07-14T17:35:42.906502+00:00 2021-07-14T17:35:44.638849+00:00 0:00:01.732347 53444 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-14T17:35:40.590594+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-13T12:00:00+00:00 PythonOperator 2021-07-14T17:25:34.266494+00:00 2021-07-14T17:25:37.693324+00:00 0:00:03.426830 53443 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-14T17:25:31.491195+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-13T11:00:00+00:00 EmrJobFlowSensor 2021-07-14T17:25:33.895655+00:00 2021-07-14T17:35:36.894994+00:00 0:10:02.999339 53442 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-14T17:25:31.491223+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-13T11:00:00+00:00 EmrCreateJobFlowOperator 2021-07-14T17:25:11.494300+00:00 2021-07-14T17:25:13.217902+00:00 0:00:01.723602 53441 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-14T17:25:09.394902+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-13T11:00:00+00:00 PythonOperator 2021-07-14T17:14:46.770371+00:00 2021-07-14T17:14:50.494348+00:00 0:00:03.723977 53440 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-14T17:14:44.403161+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-13T10:00:00+00:00 EmrJobFlowSensor 2021-07-14T17:14:46.719105+00:00 2021-07-14T17:24:49.890454+00:00 0:10:03.171349 53439 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-14T17:14:44.403202+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-13T10:00:00+00:00 EmrCreateJobFlowOperator 2021-07-14T17:14:22.600256+00:00 2021-07-14T17:14:24.324626+00:00 0:00:01.724370 53438 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-14T17:14:20.359851+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-14T16:00:00+00:00 EmrJobFlowSensor 2021-07-14T17:10:24.295396+00:00 2021-07-14T17:20:27.266122+00:00 0:10:02.970726 53437 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-14T17:10:21.754905+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-14T16:00:00+00:00 EmrCreateJobFlowOperator 2021-07-14T17:10:02.107854+00:00 2021-07-14T17:10:03.843884+00:00 0:00:01.736030 53436 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-14T17:09:59.765913+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-14T16:00:00+00:00 PythonOperator 2021-07-14T17:09:42.456949+00:00 2021-07-14T17:09:46.430483+00:00 0:00:03.973534 53435 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-14T17:09:39.746206+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-07-14T16:00:00+00:00 TriggerDagRunOperator 2021-07-14T17:09:34.126114+00:00 2021-07-14T17:09:34.656243+00:00 0:00:00.530129 53434 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-14T17:09:31.637315+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-07-14T16:00:00+00:00 TriggerDagRunOperator 2021-07-14T17:09:34.006735+00:00 2021-07-14T17:09:34.516955+00:00 0:00:00.510220 53433 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-14T17:09:31.637343+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-07-14T16:05:00+00:00 EmrJobFlowSensor 2021-07-14T17:06:01.772572+00:00 2021-07-14T17:15:04.613571+00:00 0:09:02.840999 53432 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-14T17:05:59.447802+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-07-14T16:05:00+00:00 EmrCreateJobFlowOperator 2021-07-14T17:05:39.811930+00:00 2021-07-14T17:05:41.431653+00:00 0:00:01.619723 53431 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-14T17:05:37.344258+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-07-14T16:05:00+00:00 PythonOperator 2021-07-14T17:05:17.385110+00:00 2021-07-14T17:05:20.827713+00:00 0:00:03.442603 53430 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-14T17:05:15.227855+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-13T09:00:00+00:00 EmrJobFlowSensor 2021-07-14T17:04:03.454723+00:00 2021-07-14T17:14:06.575542+00:00 0:10:03.120819 53429 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-14T17:04:01.085540+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-13T10:00:00+00:00 PythonOperator 2021-07-14T17:04:03.287888+00:00 2021-07-14T17:04:07.199817+00:00 0:00:03.911929 53428 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-14T17:04:01.085512+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-13T09:00:00+00:00 EmrCreateJobFlowOperator 2021-07-14T17:03:39.359639+00:00 2021-07-14T17:03:41.116027+00:00 0:00:01.756388 53427 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-14T17:03:37.014011+00:00 2 default_pool
success livepop-shuffle-aggregator-modeltransform_v002 check_cluster_status 2021-07-14T16:00:00+00:00 EmrJobFlowSensor 2021-07-14T17:01:12.914734+00:00 2021-07-14T17:15:16.294245+00:00 0:14:03.379511 53426 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-14T17:01:10.756416+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-07-14T16:00:00+00:00 EmrJobFlowSensor 2021-07-14T17:01:05.076767+00:00 2021-07-14T17:09:07.637956+00:00 0:08:02.561189 53425 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-14T17:01:02.776716+00:00 2 default_pool
success livepop-shuffle-aggregator-modeltransform_v002 create_cluster_and_add_emr_steps 2021-07-14T16:00:00+00:00 EmrCreateJobFlowOperator 2021-07-14T17:00:49.089929+00:00 2021-07-14T17:00:50.806388+00:00 0:00:01.716459 53424 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-14T17:00:46.768816+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-07-14T16:00:00+00:00 EmrCreateJobFlowOperator 2021-07-14T17:00:43.005630+00:00 2021-07-14T17:00:44.693749+00:00 0:00:01.688119 53423 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-07-14T17:00:40.762002+00:00 2 default_pool
success livepop-shuffle-aggregator-modeltransform_v002 create_emr_steps 2021-07-14T16:00:00+00:00 PythonOperator 2021-07-14T17:00:26.926640+00:00 2021-07-14T17:00:31.140200+00:00 0:00:04.213560 53422 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-14T17:00:24.657334+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-07-14T16:00:00+00:00 PythonOperator 2021-07-14T17:00:20.820798+00:00 2021-07-14T17:00:24.694723+00:00 0:00:03.873925 53421 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-07-14T17:00:18.653289+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-13T08:00:00+00:00 EmrJobFlowSensor 2021-07-14T16:54:24.572008+00:00 2021-07-14T17:03:27.579279+00:00 0:09:03.007271 53420 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-14T16:54:22.006306+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-13T09:00:00+00:00 PythonOperator 2021-07-14T16:54:24.285570+00:00 2021-07-14T16:54:28.196625+00:00 0:00:03.911055 53419 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-14T16:54:22.006278+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-13T08:00:00+00:00 EmrCreateJobFlowOperator 2021-07-14T16:54:00.392894+00:00 2021-07-14T16:54:02.259972+00:00 0:00:01.867078 53418 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-14T16:53:58.062608+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-13T07:00:00+00:00 EmrJobFlowSensor 2021-07-14T16:43:51.438036+00:00 2021-07-14T16:53:54.645753+00:00 0:10:03.207717 53417 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-14T16:43:49.147366+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-13T08:00:00+00:00 PythonOperator 2021-07-14T16:43:51.326148+00:00 2021-07-14T16:43:55.201837+00:00 0:00:03.875689 53416 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-14T16:43:49.147326+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-13T07:00:00+00:00 EmrCreateJobFlowOperator 2021-07-14T16:43:27.514325+00:00 2021-07-14T16:43:29.211122+00:00 0:00:01.696797 53415 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-14T16:43:25.102800+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-13T07:00:00+00:00 PythonOperator 2021-07-14T16:29:43.779872+00:00 2021-07-14T16:29:47.746197+00:00 0:00:03.966325 53413 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-14T16:29:41.414221+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-13T06:00:00+00:00 EmrJobFlowSensor 2021-07-14T16:29:43.671241+00:00 2021-07-14T16:38:46.647043+00:00 0:09:02.975802 53412 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-14T16:29:41.414251+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-13T06:00:00+00:00 EmrCreateJobFlowOperator 2021-07-14T16:29:20.100999+00:00 2021-07-14T16:29:21.915027+00:00 0:00:01.814028 53411 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-14T16:29:17.459797+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-13T05:00:00+00:00 EmrJobFlowSensor 2021-07-14T16:19:04.656357+00:00 2021-07-14T16:29:07.811280+00:00 0:10:03.154923 53410 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-14T16:19:02.246709+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-13T06:00:00+00:00 PythonOperator 2021-07-14T16:19:04.550157+00:00 2021-07-14T16:19:08.300650+00:00 0:00:03.750493 53409 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-14T16:19:02.246667+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-13T05:00:00+00:00 EmrCreateJobFlowOperator 2021-07-14T16:18:42.426533+00:00 2021-07-14T16:18:44.116470+00:00 0:00:01.689937 53408 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-14T16:18:40.218799+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-14T15:00:00+00:00 EmrJobFlowSensor 2021-07-14T16:12:19.977248+00:00 2021-07-14T16:23:23.309554+00:00 0:11:03.332306 53407 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-14T16:12:17.587894+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-14T15:00:00+00:00 EmrCreateJobFlowOperator 2021-07-14T16:11:57.690596+00:00 2021-07-14T16:11:59.407355+00:00 0:00:01.716759 53406 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-14T16:11:55.523416+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-14T15:00:00+00:00 PythonOperator 2021-07-14T16:11:35.928747+00:00 2021-07-14T16:11:39.682755+00:00 0:00:03.754008 53405 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-14T16:11:33.564800+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-07-14T15:00:00+00:00 TriggerDagRunOperator 2021-07-14T16:11:17.875596+00:00 2021-07-14T16:11:18.404534+00:00 0:00:00.528938 53404 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-14T16:11:15.495141+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-07-14T15:00:00+00:00 TriggerDagRunOperator 2021-07-14T16:11:17.797723+00:00 2021-07-14T16:11:18.204828+00:00 0:00:00.407105 53403 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-14T16:11:15.495110+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-13T04:00:00+00:00 EmrJobFlowSensor 2021-07-14T16:10:20.087248+00:00 2021-07-14T16:18:22.762561+00:00 0:08:02.675313 53402 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-14T16:10:17.424185+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-13T05:00:00+00:00 PythonOperator 2021-07-14T16:10:19.821356+00:00 2021-07-14T16:10:23.677158+00:00 0:00:03.855802 53401 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-14T16:10:17.424150+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-13T04:00:00+00:00 EmrCreateJobFlowOperator 2021-07-14T16:09:57.694632+00:00 2021-07-14T16:09:59.347822+00:00 0:00:01.653190 53400 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-14T16:09:55.471994+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-07-14T15:05:00+00:00 EmrJobFlowSensor 2021-07-14T16:06:05.332015+00:00 2021-07-14T16:15:07.981771+00:00 0:09:02.649756 53399 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-14T16:06:02.991850+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-07-14T15:05:00+00:00 EmrCreateJobFlowOperator 2021-07-14T16:05:45.273369+00:00 2021-07-14T16:05:46.988369+00:00 0:00:01.715000 53398 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-14T16:05:42.921582+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-07-14T15:05:00+00:00 PythonOperator 2021-07-14T16:05:23.156705+00:00 2021-07-14T16:05:27.164875+00:00 0:00:04.008170 53397 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-14T16:05:20.902222+00:00 2 default_pool
success livepop-shuffle-aggregator-modeltransform_v002 check_cluster_status 2021-07-14T15:00:00+00:00 EmrJobFlowSensor 2021-07-14T16:00:58.807404+00:00 2021-07-14T16:15:02.529675+00:00 0:14:03.722271 53396 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-14T16:00:56.391689+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-07-14T15:00:00+00:00 EmrJobFlowSensor 2021-07-14T16:00:54.721360+00:00 2021-07-14T16:10:57.738968+00:00 0:10:03.017608 53395 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-14T16:00:52.452653+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-07-14T15:00:00+00:00 EmrCreateJobFlowOperator 2021-07-14T16:00:32.534263+00:00 2021-07-14T16:00:34.373945+00:00 0:00:01.839682 53394 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-07-14T16:00:30.321078+00:00 2 default_pool
success livepop-shuffle-aggregator-modeltransform_v002 create_cluster_and_add_emr_steps 2021-07-14T15:00:00+00:00 EmrCreateJobFlowOperator 2021-07-14T16:00:32.010529+00:00 2021-07-14T16:00:33.698005+00:00 0:00:01.687476 53393 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-14T16:00:28.378529+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-13T03:00:00+00:00 EmrJobFlowSensor 2021-07-14T16:00:26.668736+00:00 2021-07-14T16:09:29.420986+00:00 0:09:02.752250 53392 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-14T16:00:24.317711+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-13T04:00:00+00:00 PythonOperator 2021-07-14T16:00:26.501417+00:00 2021-07-14T16:00:31.546603+00:00 0:00:05.045186 53391 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-14T16:00:24.317681+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-07-14T15:00:00+00:00 PythonOperator 2021-07-14T16:00:08.581784+00:00 2021-07-14T16:00:12.078474+00:00 0:00:03.496690 53390 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-07-14T16:00:06.301838+00:00 2 default_pool
success livepop-shuffle-aggregator-modeltransform_v002 create_emr_steps 2021-07-14T15:00:00+00:00 PythonOperator 2021-07-14T16:00:06.695814+00:00 2021-07-14T16:00:11.053063+00:00 0:00:04.357249 53389 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-14T16:00:04.306108+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-13T03:00:00+00:00 EmrCreateJobFlowOperator 2021-07-14T16:00:02.607053+00:00 2021-07-14T16:00:04.391010+00:00 0:00:01.783957 53388 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-14T16:00:00.326518+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-13T03:00:00+00:00 PythonOperator 2021-07-14T15:50:33.648324+00:00 2021-07-14T15:50:37.325596+00:00 0:00:03.677272 53387 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-14T15:50:31.284173+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-13T02:00:00+00:00 EmrJobFlowSensor 2021-07-14T15:50:33.438012+00:00 2021-07-14T15:59:36.374531+00:00 0:09:02.936519 53386 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-14T15:50:31.284204+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-13T02:00:00+00:00 EmrCreateJobFlowOperator 2021-07-14T15:50:09.317140+00:00 2021-07-14T15:50:11.007154+00:00 0:00:01.690014 53385 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-14T15:50:07.189051+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-13T01:00:00+00:00 EmrJobFlowSensor 2021-07-14T15:41:52.435708+00:00 2021-07-14T15:49:55.130574+00:00 0:08:02.694866 53384 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-14T15:41:50.045930+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-13T02:00:00+00:00 PythonOperator 2021-07-14T15:41:52.371989+00:00 2021-07-14T15:41:55.855590+00:00 0:00:03.483601 53383 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-14T15:41:50.045894+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-13T01:00:00+00:00 EmrCreateJobFlowOperator 2021-07-14T15:41:28.228716+00:00 2021-07-14T15:41:30.069671+00:00 0:00:01.840955 53382 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-14T15:41:26.014592+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-13T00:00:00+00:00 EmrJobFlowSensor 2021-07-14T15:32:05.436362+00:00 2021-07-14T15:41:09.298780+00:00 0:09:03.862418 53381 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-14T15:32:03.065750+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-13T01:00:00+00:00 PythonOperator 2021-07-14T15:32:05.277077+00:00 2021-07-14T15:32:09.192723+00:00 0:00:03.915646 53380 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-14T15:32:03.065716+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-14T14:00:00+00:00 EmrJobFlowSensor 2021-07-14T15:31:55.377708+00:00 2021-07-14T15:43:58.708095+00:00 0:12:03.330387 53379 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-14T15:31:53.056474+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-13T00:00:00+00:00 EmrCreateJobFlowOperator 2021-07-14T15:31:43.485590+00:00 2021-07-14T15:31:45.416457+00:00 0:00:01.930867 53378 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-14T15:31:41.046628+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-14T14:00:00+00:00 EmrCreateJobFlowOperator 2021-07-14T15:31:35.707332+00:00 2021-07-14T15:31:37.554413+00:00 0:00:01.847081 53377 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-14T15:31:32.996597+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-14T14:00:00+00:00 PythonOperator 2021-07-14T15:10:44.226099+00:00 2021-07-14T15:10:48.274108+00:00 0:00:04.048009 53375 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-14T15:10:41.953061+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-07-14T14:00:00+00:00 TriggerDagRunOperator 2021-07-14T15:10:26.591417+00:00 2021-07-14T15:10:27.131459+00:00 0:00:00.540042 53374 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-14T15:10:24.049919+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-07-14T14:00:00+00:00 TriggerDagRunOperator 2021-07-14T15:10:26.414392+00:00 2021-07-14T15:10:26.792194+00:00 0:00:00.377802 53373 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-14T15:10:24.049881+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-12T23:00:00+00:00 EmrJobFlowSensor 2021-07-14T15:06:56.133981+00:00 2021-07-14T15:16:59.069070+00:00 0:10:02.935089 53372 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-14T15:06:53.626020+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-13T00:00:00+00:00 PythonOperator 2021-07-14T15:06:55.904366+00:00 2021-07-14T15:06:59.664742+00:00 0:00:03.760376 53371 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-14T15:06:53.625987+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-12T23:00:00+00:00 EmrCreateJobFlowOperator 2021-07-14T15:06:34.134097+00:00 2021-07-14T15:06:35.990438+00:00 0:00:01.856341 53370 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-14T15:06:31.615777+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-07-14T14:05:00+00:00 EmrJobFlowSensor 2021-07-14T15:05:59.896525+00:00 2021-07-14T15:15:02.591675+00:00 0:09:02.695150 53369 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-14T15:05:57.564747+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-07-14T14:05:00+00:00 EmrCreateJobFlowOperator 2021-07-14T15:05:37.746435+00:00 2021-07-14T15:05:39.467350+00:00 0:00:01.720915 53368 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-14T15:05:35.517673+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-07-14T14:05:00+00:00 PythonOperator 2021-07-14T15:05:15.696429+00:00 2021-07-14T15:05:19.428617+00:00 0:00:03.732188 53367 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-14T15:05:13.496004+00:00 2 default_pool
success livepop-shuffle-aggregator-modeltransform_v002 check_cluster_status 2021-07-14T14:00:00+00:00 EmrJobFlowSensor 2021-07-14T15:01:05.162865+00:00 2021-07-14T15:14:08.391882+00:00 0:13:03.229017 53366 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-14T15:01:03.004461+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-07-14T14:00:00+00:00 EmrJobFlowSensor 2021-07-14T15:01:03.387493+00:00 2021-07-14T15:10:06.293058+00:00 0:09:02.905565 53365 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-14T15:01:01.002554+00:00 2 default_pool
success livepop-shuffle-aggregator-modeltransform_v002 create_cluster_and_add_emr_steps 2021-07-14T14:00:00+00:00 EmrCreateJobFlowOperator 2021-07-14T15:00:41.760663+00:00 2021-07-14T15:00:43.581929+00:00 0:00:01.821266 53364 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-14T15:00:38.985287+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-07-14T14:00:00+00:00 EmrCreateJobFlowOperator 2021-07-14T15:00:39.450641+00:00 2021-07-14T15:00:41.434250+00:00 0:00:01.983609 53363 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-07-14T15:00:37.055424+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-07-14T14:00:00+00:00 PythonOperator 2021-07-14T15:00:19.404526+00:00 2021-07-14T15:00:22.973716+00:00 0:00:03.569190 53362 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-07-14T15:00:16.901313+00:00 2 default_pool
success livepop-shuffle-aggregator-modeltransform_v002 create_emr_steps 2021-07-14T14:00:00+00:00 PythonOperator 2021-07-14T15:00:19.245955+00:00 2021-07-14T15:00:23.317083+00:00 0:00:04.071128 53361 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-14T15:00:16.901344+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-12T23:00:00+00:00 PythonOperator 2021-07-14T14:57:10.786069+00:00 2021-07-14T14:57:14.774881+00:00 0:00:03.988812 53360 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-14T14:57:08.491516+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-12T22:00:00+00:00 EmrJobFlowSensor 2021-07-14T14:57:10.824084+00:00 2021-07-14T15:06:13.883004+00:00 0:09:03.058920 53359 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-14T14:57:08.491576+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-12T22:00:00+00:00 EmrCreateJobFlowOperator 2021-07-14T14:56:46.769389+00:00 2021-07-14T14:56:48.750447+00:00 0:00:01.981058 53358 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-14T14:56:44.413166+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-12T22:00:00+00:00 PythonOperator 2021-07-14T14:47:38.060788+00:00 2021-07-14T14:47:41.838418+00:00 0:00:03.777630 53357 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-14T14:47:35.587519+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-12T21:00:00+00:00 EmrJobFlowSensor 2021-07-14T14:47:38.032298+00:00 2021-07-14T14:56:40.957622+00:00 0:09:02.925324 53356 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-14T14:47:35.587548+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-12T21:00:00+00:00 EmrCreateJobFlowOperator 2021-07-14T14:47:13.886854+00:00 2021-07-14T14:47:15.817293+00:00 0:00:01.930439 53355 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-14T14:47:11.513214+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-12T20:00:00+00:00 EmrJobFlowSensor 2021-07-14T14:36:52.939367+00:00 2021-07-14T14:46:56.014348+00:00 0:10:03.074981 53354 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-14T14:36:50.427908+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-12T21:00:00+00:00 PythonOperator 2021-07-14T14:36:52.813209+00:00 2021-07-14T14:36:56.323028+00:00 0:00:03.509819 53353 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-14T14:36:50.427879+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-12T20:00:00+00:00 EmrCreateJobFlowOperator 2021-07-14T14:36:28.771847+00:00 2021-07-14T14:36:30.458923+00:00 0:00:01.687076 53352 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-14T14:36:26.410342+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-12T19:00:00+00:00 EmrJobFlowSensor 2021-07-14T14:28:10.139550+00:00 2021-07-14T14:36:12.958208+00:00 0:08:02.818658 53351 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-14T14:28:07.790379+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-12T20:00:00+00:00 PythonOperator 2021-07-14T14:28:10.099424+00:00 2021-07-14T14:28:13.952798+00:00 0:00:03.853374 53350 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-14T14:28:07.790348+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-12T19:00:00+00:00 EmrCreateJobFlowOperator 2021-07-14T14:26:51.829104+00:00 2021-07-14T14:26:53.667523+00:00 0:00:01.838419 53349 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-14T14:26:49.613995+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-12T19:00:00+00:00 PythonOperator 2021-07-14T14:18:14.983589+00:00 2021-07-14T14:18:18.605833+00:00 0:00:03.622244 53348 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-14T14:18:12.545649+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-12T18:00:00+00:00 EmrJobFlowSensor 2021-07-14T14:18:14.826565+00:00 2021-07-14T14:26:17.670332+00:00 0:08:02.843767 53347 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-14T14:18:12.545681+00:00 2 default_pool