Task Instances

Reset Filters
  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-flow-job_v002 create_emr_steps 2021-05-03T01:00:00+00:00 PythonOperator 2021-05-03T02:00:19.861236+00:00 2021-05-03T02:00:22.891707+00:00 0:00:03.030471 23846 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-03T02:00:17.297841+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-03T00:00:00+00:00 TriggerDagRunOperator 2021-05-03T01:09:09.594402+00:00 2021-05-03T01:09:10.130370+00:00 0:00:00.535968 23838 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T01:09:07.257105+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-03T00:00:00+00:00 TriggerDagRunOperator 2021-05-03T01:09:09.512402+00:00 2021-05-03T01:09:09.920697+00:00 0:00:00.408295 23837 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T01:09:07.257061+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-03T00:00:00+00:00 EmrJobFlowSensor 2021-05-03T01:00:54.422632+00:00 2021-05-03T01:08:57.044993+00:00 0:08:02.622361 23833 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T01:00:52.036217+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-03T00:00:00+00:00 EmrCreateJobFlowOperator 2021-05-03T01:00:32.238497+00:00 2021-05-03T01:00:34.124127+00:00 0:00:01.885630 23832 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-03T01:00:30.020125+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-03T00:00:00+00:00 PythonOperator 2021-05-03T01:00:10.449015+00:00 2021-05-03T01:00:13.493437+00:00 0:00:03.044422 23831 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-03T01:00:07.992141+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-02T23:00:00+00:00 TriggerDagRunOperator 2021-05-03T00:10:26.825239+00:00 2021-05-03T00:10:27.353162+00:00 0:00:00.527923 23823 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T00:10:24.389454+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-02T23:00:00+00:00 TriggerDagRunOperator 2021-05-03T00:10:26.779668+00:00 2021-05-03T00:10:27.209941+00:00 0:00:00.430273 23822 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T00:10:24.389490+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-02T23:00:00+00:00 EmrJobFlowSensor 2021-05-03T00:01:07.510353+00:00 2021-05-03T00:10:10.374508+00:00 0:09:02.864155 23818 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T00:01:05.187927+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-02T23:00:00+00:00 EmrCreateJobFlowOperator 2021-05-03T00:00:45.507140+00:00 2021-05-03T00:00:47.211300+00:00 0:00:01.704160 23817 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-03T00:00:43.158205+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-02T23:00:00+00:00 PythonOperator 2021-05-03T00:00:25.993610+00:00 2021-05-03T00:00:29.131533+00:00 0:00:03.137923 23816 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-03T00:00:23.104101+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-02T22:00:00+00:00 TriggerDagRunOperator 2021-05-02T23:09:11.856311+00:00 2021-05-02T23:09:12.262875+00:00 0:00:00.406564 23808 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T23:09:08.976680+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-02T22:00:00+00:00 TriggerDagRunOperator 2021-05-02T23:09:11.303589+00:00 2021-05-02T23:09:11.910359+00:00 0:00:00.606770 23807 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T23:09:08.976646+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-02T22:00:00+00:00 EmrJobFlowSensor 2021-05-02T23:01:00.725378+00:00 2021-05-02T23:09:03.321311+00:00 0:08:02.595933 23803 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T23:00:58.260077+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-02T22:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T23:00:40.621871+00:00 2021-05-02T23:00:42.370927+00:00 0:00:01.749056 23801 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-02T23:00:38.169996+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-02T22:00:00+00:00 PythonOperator 2021-05-02T23:00:18.325491+00:00 2021-05-02T23:00:21.349504+00:00 0:00:03.024013 23799 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-02T23:00:16.069950+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-02T21:00:00+00:00 TriggerDagRunOperator 2021-05-02T22:10:03.937697+00:00 2021-05-02T22:10:04.463970+00:00 0:00:00.526273 23790 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T22:10:01.509488+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-02T21:00:00+00:00 TriggerDagRunOperator 2021-05-02T22:10:03.793520+00:00 2021-05-02T22:10:04.314393+00:00 0:00:00.520873 23789 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T22:10:01.509455+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-02T21:00:00+00:00 EmrJobFlowSensor 2021-05-02T22:00:48.814561+00:00 2021-05-02T22:09:51.642191+00:00 0:09:02.827630 23785 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T22:00:46.350081+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-02T21:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T22:00:26.595361+00:00 2021-05-02T22:00:28.338929+00:00 0:00:01.743568 23784 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-02T22:00:24.331639+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-02T21:00:00+00:00 PythonOperator 2021-05-02T22:00:04.851484+00:00 2021-05-02T22:00:07.976885+00:00 0:00:03.125401 23783 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-02T22:00:02.316053+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-02T20:00:00+00:00 TriggerDagRunOperator 2021-05-02T21:10:10.308955+00:00 2021-05-02T21:10:10.743104+00:00 0:00:00.434149 23775 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T21:10:07.889082+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-02T20:00:00+00:00 TriggerDagRunOperator 2021-05-02T21:10:10.178693+00:00 2021-05-02T21:10:10.760778+00:00 0:00:00.582085 23774 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T21:10:07.889042+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-02T20:00:00+00:00 EmrJobFlowSensor 2021-05-02T21:00:48.365363+00:00 2021-05-02T21:09:51.179505+00:00 0:09:02.814142 23770 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T21:00:46.059506+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-02T20:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T21:00:28.253822+00:00 2021-05-02T21:00:29.960975+00:00 0:00:01.707153 23769 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-02T21:00:25.989662+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-02T20:00:00+00:00 PythonOperator 2021-05-02T21:00:06.658479+00:00 2021-05-02T21:00:09.673581+00:00 0:00:03.015102 23768 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-02T21:00:03.724356+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-02T19:00:00+00:00 TriggerDagRunOperator 2021-05-02T20:10:21.303306+00:00 2021-05-02T20:10:21.897500+00:00 0:00:00.594194 23760 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T20:10:19.044207+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-02T19:00:00+00:00 TriggerDagRunOperator 2021-05-02T20:10:21.219584+00:00 2021-05-02T20:10:21.638839+00:00 0:00:00.419255 23759 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T20:10:19.044253+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-02T19:00:00+00:00 EmrJobFlowSensor 2021-05-02T20:00:56.086203+00:00 2021-05-02T20:09:58.756915+00:00 0:09:02.670712 23755 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T20:00:53.958805+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-02T19:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T20:00:36.210225+00:00 2021-05-02T20:00:37.963836+00:00 0:00:01.753611 23754 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-02T20:00:33.926634+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-02T19:00:00+00:00 PythonOperator 2021-05-02T20:00:14.729719+00:00 2021-05-02T20:00:17.771555+00:00 0:00:03.041836 23753 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-02T20:00:11.960090+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-02T18:00:00+00:00 TriggerDagRunOperator 2021-05-02T19:10:22.166900+00:00 2021-05-02T19:10:22.749818+00:00 0:00:00.582918 23745 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T19:10:19.857278+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-02T18:00:00+00:00 TriggerDagRunOperator 2021-05-02T19:10:22.051775+00:00 2021-05-02T19:10:22.459786+00:00 0:00:00.408011 23744 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T19:10:19.857242+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-02T18:00:00+00:00 EmrJobFlowSensor 2021-05-02T19:01:01.520875+00:00 2021-05-02T19:10:04.170680+00:00 0:09:02.649805 23740 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T19:00:59.244653+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-02T18:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T19:00:39.586450+00:00 2021-05-02T19:00:41.409741+00:00 0:00:01.823291 23739 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-02T19:00:37.124748+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-02T18:00:00+00:00 PythonOperator 2021-05-02T19:00:17.474789+00:00 2021-05-02T19:00:20.529503+00:00 0:00:03.054714 23738 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-02T19:00:15.107498+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-02T17:00:00+00:00 TriggerDagRunOperator 2021-05-02T18:10:29.043394+00:00 2021-05-02T18:10:29.547553+00:00 0:00:00.504159 23730 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T18:10:26.620621+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-02T17:00:00+00:00 TriggerDagRunOperator 2021-05-02T18:10:28.999033+00:00 2021-05-02T18:10:29.399006+00:00 0:00:00.399973 23729 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T18:10:26.620655+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-02T17:00:00+00:00 EmrJobFlowSensor 2021-05-02T18:01:00.433236+00:00 2021-05-02T18:10:03.157474+00:00 0:09:02.724238 23725 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T18:00:57.944639+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-02T17:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T18:00:38.278948+00:00 2021-05-02T18:00:40.146294+00:00 0:00:01.867346 23724 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-02T18:00:35.775354+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-02T17:00:00+00:00 PythonOperator 2021-05-02T18:00:18.222957+00:00 2021-05-02T18:00:21.284497+00:00 0:00:03.061540 23723 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-02T18:00:15.758701+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-02T16:00:00+00:00 TriggerDagRunOperator 2021-05-02T17:11:42.840690+00:00 2021-05-02T17:11:43.379213+00:00 0:00:00.538523 23715 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T17:11:40.498325+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-02T16:00:00+00:00 TriggerDagRunOperator 2021-05-02T17:11:42.799786+00:00 2021-05-02T17:11:43.330876+00:00 0:00:00.531090 23714 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T17:11:40.498298+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-02T16:00:00+00:00 EmrJobFlowSensor 2021-05-02T17:01:15.822292+00:00 2021-05-02T17:11:18.757773+00:00 0:10:02.935481 23710 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T17:01:13.392796+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-02T16:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T17:00:53.849116+00:00 2021-05-02T17:00:55.672259+00:00 0:00:01.823143 23709 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-02T17:00:51.307964+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-02T16:00:00+00:00 PythonOperator 2021-05-02T17:00:23.554511+00:00 2021-05-02T17:00:26.641607+00:00 0:00:03.087096 23708 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-02T17:00:21.280558+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-02T15:00:00+00:00 TriggerDagRunOperator 2021-05-02T16:11:22.464146+00:00 2021-05-02T16:11:22.999018+00:00 0:00:00.534872 23700 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T16:11:20.217439+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-02T15:00:00+00:00 TriggerDagRunOperator 2021-05-02T16:11:22.420190+00:00 2021-05-02T16:11:22.845980+00:00 0:00:00.425790 23699 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T16:11:20.217472+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-02T15:00:00+00:00 EmrJobFlowSensor 2021-05-02T16:01:01.290376+00:00 2021-05-02T16:11:04.199804+00:00 0:10:02.909428 23695 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T16:00:59.086349+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-02T15:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T16:00:39.305003+00:00 2021-05-02T16:00:41.012517+00:00 0:00:01.707514 23694 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-02T16:00:37.059566+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-02T15:00:00+00:00 PythonOperator 2021-05-02T16:00:19.338605+00:00 2021-05-02T16:00:22.391114+00:00 0:00:03.052509 23693 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-02T16:00:17.016319+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-02T14:00:00+00:00 TriggerDagRunOperator 2021-05-02T15:09:25.220169+00:00 2021-05-02T15:09:25.779592+00:00 0:00:00.559423 23685 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T15:09:22.822294+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-02T14:00:00+00:00 TriggerDagRunOperator 2021-05-02T15:09:25.048913+00:00 2021-05-02T15:09:25.450220+00:00 0:00:00.401307 23684 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T15:09:22.822258+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-02T14:00:00+00:00 EmrJobFlowSensor 2021-05-02T15:01:04.494764+00:00 2021-05-02T15:09:07.211169+00:00 0:08:02.716405 23680 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T15:01:01.869776+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-02T14:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T15:00:42.277889+00:00 2021-05-02T15:00:44.575406+00:00 0:00:02.297517 23679 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-02T15:00:39.879880+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-02T14:00:00+00:00 PythonOperator 2021-05-02T15:00:20.119704+00:00 2021-05-02T15:00:23.140153+00:00 0:00:03.020449 23678 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-02T15:00:17.797837+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-02T13:00:00+00:00 TriggerDagRunOperator 2021-05-02T14:11:09.234111+00:00 2021-05-02T14:11:09.766967+00:00 0:00:00.532856 23670 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T14:11:06.643372+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-02T13:00:00+00:00 TriggerDagRunOperator 2021-05-02T14:11:09.138591+00:00 2021-05-02T14:11:09.566267+00:00 0:00:00.427676 23669 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T14:11:06.643336+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-02T13:00:00+00:00 EmrJobFlowSensor 2021-05-02T14:01:00.367491+00:00 2021-05-02T14:11:03.322102+00:00 0:10:02.954611 23665 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T14:00:57.766367+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-02T13:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T14:00:40.240632+00:00 2021-05-02T14:00:42.056441+00:00 0:00:01.815809 23664 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-02T14:00:37.657042+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-02T13:00:00+00:00 PythonOperator 2021-05-02T14:00:18.057630+00:00 2021-05-02T14:00:21.063670+00:00 0:00:03.006040 23663 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-02T14:00:15.588182+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-02T12:00:00+00:00 TriggerDagRunOperator 2021-05-02T13:11:19.367907+00:00 2021-05-02T13:11:19.889319+00:00 0:00:00.521412 23655 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T13:11:16.667741+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-02T12:00:00+00:00 TriggerDagRunOperator 2021-05-02T13:11:19.131891+00:00 2021-05-02T13:11:19.532779+00:00 0:00:00.400888 23654 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T13:11:16.667701+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-02T12:00:00+00:00 EmrJobFlowSensor 2021-05-02T13:01:00.115225+00:00 2021-05-02T13:11:03.066997+00:00 0:10:02.951772 23650 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T13:00:57.757006+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-02T12:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T13:00:38.063706+00:00 2021-05-02T13:00:39.900269+00:00 0:00:01.836563 23649 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-02T13:00:35.740836+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-02T12:00:00+00:00 PythonOperator 2021-05-02T13:00:16.084956+00:00 2021-05-02T13:00:19.129720+00:00 0:00:03.044764 23648 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-02T13:00:13.700515+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-02T11:00:00+00:00 TriggerDagRunOperator 2021-05-02T12:10:10.503278+00:00 2021-05-02T12:10:10.919298+00:00 0:00:00.416020 23640 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T12:10:08.121801+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-02T11:00:00+00:00 TriggerDagRunOperator 2021-05-02T12:10:10.505953+00:00 2021-05-02T12:10:11.074453+00:00 0:00:00.568500 23639 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T12:10:08.121758+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-02T11:00:00+00:00 EmrJobFlowSensor 2021-05-02T12:00:51.410910+00:00 2021-05-02T12:09:54.160703+00:00 0:09:02.749793 23635 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T12:00:49.261279+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-02T11:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T12:00:29.403177+00:00 2021-05-02T12:00:31.108723+00:00 0:00:01.705546 23634 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-02T12:00:27.241787+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-02T11:00:00+00:00 PythonOperator 2021-05-02T12:00:08.046886+00:00 2021-05-02T12:00:11.189363+00:00 0:00:03.142477 23633 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-02T12:00:05.264945+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-02T10:00:00+00:00 TriggerDagRunOperator 2021-05-02T11:09:12.462550+00:00 2021-05-02T11:09:12.997207+00:00 0:00:00.534657 23625 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T11:09:10.047329+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-02T10:00:00+00:00 TriggerDagRunOperator 2021-05-02T11:09:12.411772+00:00 2021-05-02T11:09:12.935302+00:00 0:00:00.523530 23624 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T11:09:10.047275+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-02T10:00:00+00:00 EmrJobFlowSensor 2021-05-02T11:00:59.612147+00:00 2021-05-02T11:09:02.277283+00:00 0:08:02.665136 23620 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T11:00:57.202364+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-02T10:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T11:00:37.498667+00:00 2021-05-02T11:00:39.209241+00:00 0:00:01.710574 23619 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-02T11:00:35.257714+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-02T10:00:00+00:00 PythonOperator 2021-05-02T11:00:15.468384+00:00 2021-05-02T11:00:18.572994+00:00 0:00:03.104610 23618 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-02T11:00:13.088072+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-02T09:00:00+00:00 TriggerDagRunOperator 2021-05-02T10:11:26.610519+00:00 2021-05-02T10:11:27.095355+00:00 0:00:00.484836 23609 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T10:11:24.142808+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-02T09:00:00+00:00 TriggerDagRunOperator 2021-05-02T10:11:26.505837+00:00 2021-05-02T10:11:27.141572+00:00 0:00:00.635735 23608 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T10:11:24.142839+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-02T09:00:00+00:00 EmrJobFlowSensor 2021-05-02T10:01:01.527082+00:00 2021-05-02T10:11:04.501588+00:00 0:10:02.974506 23604 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T10:00:59.154507+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-02T09:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T10:00:37.515466+00:00 2021-05-02T10:00:39.259187+00:00 0:00:01.743721 23603 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-02T10:00:35.140702+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-02T09:00:00+00:00 PythonOperator 2021-05-02T10:00:15.224736+00:00 2021-05-02T10:00:18.266200+00:00 0:00:03.041464 23602 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-02T10:00:12.996537+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-02T08:00:00+00:00 TriggerDagRunOperator 2021-05-02T09:11:33.634000+00:00 2021-05-02T09:11:34.123490+00:00 0:00:00.489490 23594 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T09:11:31.112418+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-02T08:00:00+00:00 TriggerDagRunOperator 2021-05-02T09:11:33.579447+00:00 2021-05-02T09:11:34.177497+00:00 0:00:00.598050 23593 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T09:11:31.112384+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-02T08:00:00+00:00 EmrJobFlowSensor 2021-05-02T09:01:08.681005+00:00 2021-05-02T09:11:11.624657+00:00 0:10:02.943652 23589 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T09:01:06.120120+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-02T08:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T09:00:42.280315+00:00 2021-05-02T09:00:44.028156+00:00 0:00:01.747841 23588 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-02T09:00:40.091663+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-02T08:00:00+00:00 PythonOperator 2021-05-02T09:00:20.346890+00:00 2021-05-02T09:00:23.463112+00:00 0:00:03.116222 23587 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-02T09:00:18.045882+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-02T07:00:00+00:00 TriggerDagRunOperator 2021-05-02T08:12:43.587504+00:00 2021-05-02T08:12:44.158459+00:00 0:00:00.570955 23580 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T08:12:40.983038+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-02T07:00:00+00:00 TriggerDagRunOperator 2021-05-02T08:12:43.506999+00:00 2021-05-02T08:12:43.961185+00:00 0:00:00.454186 23579 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T08:12:40.982994+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-02T07:00:00+00:00 EmrJobFlowSensor 2021-05-02T08:00:58.130095+00:00 2021-05-02T08:09:00.650466+00:00 0:08:02.520371 23574 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T08:00:55.782094+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-02T07:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T08:00:38.006551+00:00 2021-05-02T08:00:39.768126+00:00 0:00:01.761575 23573 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-02T08:00:35.768030+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-02T07:00:00+00:00 PythonOperator 2021-05-02T08:00:15.917973+00:00 2021-05-02T08:00:19.008205+00:00 0:00:03.090232 23572 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-02T08:00:13.697731+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-02T06:00:00+00:00 TriggerDagRunOperator 2021-05-02T07:11:25.924040+00:00 2021-05-02T07:11:26.450865+00:00 0:00:00.526825 23565 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T07:11:22.944614+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-02T06:00:00+00:00 TriggerDagRunOperator 2021-05-02T07:11:25.750907+00:00 2021-05-02T07:11:26.169256+00:00 0:00:00.418349 23564 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T07:11:22.944569+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-02T06:00:00+00:00 EmrJobFlowSensor 2021-05-02T07:01:06.406789+00:00 2021-05-02T07:11:09.299399+00:00 0:10:02.892610 23559 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T07:01:04.157724+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-02T06:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T07:00:42.417987+00:00 2021-05-02T07:00:44.251039+00:00 0:00:01.833052 23558 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-02T07:00:40.155090+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-02T06:00:00+00:00 PythonOperator 2021-05-02T07:00:22.338835+00:00 2021-05-02T07:00:25.488815+00:00 0:00:03.149980 23557 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-02T07:00:20.069637+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-02T05:00:00+00:00 TriggerDagRunOperator 2021-05-02T06:11:19.453896+00:00 2021-05-02T06:11:19.969370+00:00 0:00:00.515474 23550 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T06:11:16.892992+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-02T05:00:00+00:00 TriggerDagRunOperator 2021-05-02T06:11:19.308172+00:00 2021-05-02T06:11:19.728740+00:00 0:00:00.420568 23549 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T06:11:16.893022+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-02T05:00:00+00:00 EmrJobFlowSensor 2021-05-02T06:01:08.910012+00:00 2021-05-02T06:11:11.856051+00:00 0:10:02.946039 23544 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T06:01:06.552483+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-02T05:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T06:00:46.643736+00:00 2021-05-02T06:00:48.351518+00:00 0:00:01.707782 23543 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-02T06:00:44.460526+00:00 2 default_pool