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-03-31T13:00:00+00:00 PythonOperator 2021-03-31T14:00:13.248581+00:00 2021-03-31T14:00:16.004005+00:00 0:00:02.755424 12059 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-31T14:00:11.046014+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-31T12:00:00+00:00 TriggerDagRunOperator 2021-03-31T13:11:33.174975+00:00 2021-03-31T13:11:33.740574+00:00 0:00:00.565599 12052 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T13:11:30.077872+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-31T12:00:00+00:00 TriggerDagRunOperator 2021-03-31T13:11:33.102520+00:00 2021-03-31T13:11:33.615403+00:00 0:00:00.512883 12051 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T13:11:30.077829+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-31T12:00:00+00:00 EmrJobFlowSensor 2021-03-31T13:01:04.320048+00:00 2021-03-31T13:11:07.247382+00:00 0:10:02.927334 12046 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T13:01:02.021234+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-31T12:00:00+00:00 EmrCreateJobFlowOperator 2021-03-31T13:00:42.273793+00:00 2021-03-31T13:00:44.104448+00:00 0:00:01.830655 12045 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-31T13:00:39.995901+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-31T12:00:00+00:00 PythonOperator 2021-03-31T13:00:20.132160+00:00 2021-03-31T13:00:22.871978+00:00 0:00:02.739818 12044 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-31T13:00:17.946779+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-31T11:00:00+00:00 TriggerDagRunOperator 2021-03-31T12:11:15.461405+00:00 2021-03-31T12:11:15.938045+00:00 0:00:00.476640 12037 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T12:11:13.056409+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-31T11:00:00+00:00 TriggerDagRunOperator 2021-03-31T12:11:15.439298+00:00 2021-03-31T12:11:16.047195+00:00 0:00:00.607897 12036 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T12:11:13.056444+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-31T11:00:00+00:00 EmrJobFlowSensor 2021-03-31T12:01:03.045622+00:00 2021-03-31T12:11:05.998534+00:00 0:10:02.952912 12031 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T12:01:00.656721+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-31T11:00:00+00:00 EmrCreateJobFlowOperator 2021-03-31T12:00:40.838755+00:00 2021-03-31T12:00:42.626157+00:00 0:00:01.787402 12030 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-31T12:00:38.565076+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-31T11:00:00+00:00 PythonOperator 2021-03-31T12:00:18.731998+00:00 2021-03-31T12:00:21.436467+00:00 0:00:02.704469 12029 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-31T12:00:16.523779+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-31T10:00:00+00:00 TriggerDagRunOperator 2021-03-31T11:11:06.777982+00:00 2021-03-31T11:11:07.291838+00:00 0:00:00.513856 12022 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T11:11:04.314753+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-31T10:00:00+00:00 TriggerDagRunOperator 2021-03-31T11:11:06.528449+00:00 2021-03-31T11:11:06.967845+00:00 0:00:00.439396 12021 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T11:11:04.314784+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-31T10:00:00+00:00 EmrJobFlowSensor 2021-03-31T11:00:51.540677+00:00 2021-03-31T11:10:54.246163+00:00 0:10:02.705486 12016 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T11:00:49.348444+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-31T10:00:00+00:00 EmrCreateJobFlowOperator 2021-03-31T11:00:29.608955+00:00 2021-03-31T11:00:31.284976+00:00 0:00:01.676021 12015 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-31T11:00:27.329378+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-31T10:00:00+00:00 PythonOperator 2021-03-31T11:00:07.683742+00:00 2021-03-31T11:00:10.438723+00:00 0:00:02.754981 12014 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-31T11:00:05.344373+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-31T09:00:00+00:00 TriggerDagRunOperator 2021-03-31T10:20:51.966006+00:00 2021-03-31T10:20:52.505792+00:00 0:00:00.539786 12010 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T10:20:49.624054+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-31T09:00:00+00:00 TriggerDagRunOperator 2021-03-31T10:20:51.838228+00:00 2021-03-31T10:20:52.254437+00:00 0:00:00.416209 12009 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T10:20:49.624082+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-31T09:00:00+00:00 EmrJobFlowSensor 2021-03-31T10:03:24.546714+00:00 2021-03-31T10:20:28.333125+00:00 0:17:03.786411 11999 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T10:03:22.181849+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-31T09:00:00+00:00 EmrCreateJobFlowOperator 2021-03-31T10:03:02.014425+00:00 2021-03-31T10:03:03.761016+00:00 0:00:01.746591 11998 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-31T10:02:59.668484+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-31T08:00:00+00:00 TriggerDagRunOperator 2021-03-31T10:02:45.211696+00:00 2021-03-31T10:02:45.811230+00:00 0:00:00.599534 11997 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T10:02:39.237017+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-31T09:00:00+00:00 PythonOperator 2021-03-31T10:02:45.133523+00:00 2021-03-31T10:02:48.134475+00:00 0:00:03.000952 11996 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-31T10:02:39.237067+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-31T08:00:00+00:00 TriggerDagRunOperator 2021-03-31T10:02:42.721036+00:00 2021-03-31T10:02:43.457481+00:00 0:00:00.736445 11994 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T10:02:39.237053+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-31T08:00:00+00:00 EmrJobFlowSensor 2021-03-31T09:48:08.964739+00:00 2021-03-31T09:57:11.644518+00:00 0:09:02.679779 11992 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T09:48:06.601311+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-31T08:00:00+00:00 EmrCreateJobFlowOperator 2021-03-31T09:47:47.318217+00:00 2021-03-31T09:47:49.016649+00:00 0:00:01.698432 11990 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-31T09:47:44.594152+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-31T08:00:00+00:00 PythonOperator 2021-03-31T09:47:25.240601+00:00 2021-03-31T09:47:28.075930+00:00 0:00:02.835329 11988 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-31T09:47:22.859483+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-26T12:00:00+00:00 TriggerDagRunOperator 2021-03-26T13:20:12.933503+00:00 2021-03-26T13:20:13.321428+00:00 0:00:00.387925 11874 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T13:20:10.068374+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-26T12:00:00+00:00 TriggerDagRunOperator 2021-03-26T13:20:12.760958+00:00 2021-03-26T13:20:13.274374+00:00 0:00:00.513416 11873 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T13:20:10.068335+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-26T12:00:00+00:00 EmrJobFlowSensor 2021-03-26T13:00:53.835412+00:00 2021-03-26T13:09:56.666557+00:00 0:09:02.831145 11868 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-26T13:00:51.433673+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-26T12:00:00+00:00 EmrCreateJobFlowOperator 2021-03-26T13:00:31.699295+00:00 2021-03-26T13:00:33.395196+00:00 0:00:01.695901 11867 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-26T13:00:29.475150+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-26T12:00:00+00:00 PythonOperator 2021-03-26T13:00:09.649746+00:00 2021-03-26T13:00:12.552502+00:00 0:00:02.902756 11866 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-26T13:00:07.399751+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-26T11:00:00+00:00 TriggerDagRunOperator 2021-03-26T12:17:41.818581+00:00 2021-03-26T12:17:42.313537+00:00 0:00:00.494956 11862 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T12:17:39.461649+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-26T11:00:00+00:00 TriggerDagRunOperator 2021-03-26T12:17:41.713141+00:00 2021-03-26T12:17:42.110789+00:00 0:00:00.397648 11861 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T12:17:39.461605+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-26T11:00:00+00:00 EmrJobFlowSensor 2021-03-26T12:08:22.669544+00:00 2021-03-26T12:17:25.277758+00:00 0:09:02.608214 11860 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-26T12:08:20.464676+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-26T11:00:00+00:00 EmrCreateJobFlowOperator 2021-03-26T12:07:52.652892+00:00 2021-03-26T12:07:54.375413+00:00 0:00:01.722521 11858 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-26T12:07:50.438137+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-26T11:00:00+00:00 PythonOperator 2021-03-26T12:07:30.753936+00:00 2021-03-26T12:07:33.518332+00:00 0:00:02.764396 11856 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-26T12:07:28.455611+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-26T10:00:00+00:00 TriggerDagRunOperator 2021-03-26T11:11:24.629692+00:00 2021-03-26T11:11:25.053856+00:00 0:00:00.424164 11850 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T11:11:22.063828+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-26T10:00:00+00:00 TriggerDagRunOperator 2021-03-26T11:11:24.562931+00:00 2021-03-26T11:11:25.097543+00:00 0:00:00.534612 11849 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T11:11:22.063787+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-26T10:00:00+00:00 EmrJobFlowSensor 2021-03-26T11:00:59.046040+00:00 2021-03-26T11:11:01.846930+00:00 0:10:02.800890 11845 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-26T11:00:56.906493+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-26T10:00:00+00:00 EmrCreateJobFlowOperator 2021-03-26T11:00:39.067632+00:00 2021-03-26T11:00:40.749524+00:00 0:00:01.681892 11844 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-26T11:00:36.887175+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-26T10:00:00+00:00 PythonOperator 2021-03-26T11:00:15.370862+00:00 2021-03-26T11:00:18.245979+00:00 0:00:02.875117 11843 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-26T11:00:12.809792+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-26T09:00:00+00:00 TriggerDagRunOperator 2021-03-26T10:11:10.189212+00:00 2021-03-26T10:11:10.665394+00:00 0:00:00.476182 11838 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T10:11:07.510148+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-26T09:00:00+00:00 TriggerDagRunOperator 2021-03-26T10:11:10.118258+00:00 2021-03-26T10:11:10.697544+00:00 0:00:00.579286 11837 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T10:11:07.510115+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-26T09:00:00+00:00 EmrJobFlowSensor 2021-03-26T10:01:00.868938+00:00 2021-03-26T10:11:03.831638+00:00 0:10:02.962700 11833 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-26T10:00:58.485313+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-26T09:00:00+00:00 EmrCreateJobFlowOperator 2021-03-26T10:00:40.633902+00:00 2021-03-26T10:00:42.449715+00:00 0:00:01.815813 11832 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-26T10:00:38.454896+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-26T09:00:00+00:00 PythonOperator 2021-03-26T10:00:19.018713+00:00 2021-03-26T10:00:21.827792+00:00 0:00:02.809079 11831 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-26T10:00:16.462016+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-26T08:00:00+00:00 TriggerDagRunOperator 2021-03-26T09:10:19.093476+00:00 2021-03-26T09:10:19.537303+00:00 0:00:00.443827 11826 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T09:10:16.749128+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-26T08:00:00+00:00 TriggerDagRunOperator 2021-03-26T09:10:19.023901+00:00 2021-03-26T09:10:19.594705+00:00 0:00:00.570804 11825 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T09:10:16.749162+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-26T08:00:00+00:00 EmrJobFlowSensor 2021-03-26T09:00:54.301227+00:00 2021-03-26T09:09:57.037170+00:00 0:09:02.735943 11821 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-26T09:00:51.923223+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-26T08:00:00+00:00 EmrCreateJobFlowOperator 2021-03-26T09:00:30.538367+00:00 2021-03-26T09:00:32.205931+00:00 0:00:01.667564 11820 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-26T09:00:27.979303+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-26T08:00:00+00:00 PythonOperator 2021-03-26T09:00:08.779789+00:00 2021-03-26T09:00:11.654853+00:00 0:00:02.875064 11819 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-26T09:00:05.951099+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-26T07:00:00+00:00 TriggerDagRunOperator 2021-03-26T08:10:18.089511+00:00 2021-03-26T08:10:18.506185+00:00 0:00:00.416674 11814 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T08:10:15.826730+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-26T07:00:00+00:00 TriggerDagRunOperator 2021-03-26T08:10:18.124625+00:00 2021-03-26T08:10:18.682615+00:00 0:00:00.557990 11813 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T08:10:15.826702+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-26T07:00:00+00:00 EmrJobFlowSensor 2021-03-26T08:01:06.903364+00:00 2021-03-26T08:10:09.654338+00:00 0:09:02.750974 11809 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-26T08:01:04.651645+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-26T07:00:00+00:00 EmrCreateJobFlowOperator 2021-03-26T08:00:40.817466+00:00 2021-03-26T08:00:42.505073+00:00 0:00:01.687607 11808 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-26T08:00:38.594283+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-26T07:00:00+00:00 PythonOperator 2021-03-26T08:00:18.941310+00:00 2021-03-26T08:00:21.757189+00:00 0:00:02.815879 11807 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-26T08:00:16.550415+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-26T06:00:00+00:00 TriggerDagRunOperator 2021-03-26T07:10:06.089180+00:00 2021-03-26T07:10:06.529873+00:00 0:00:00.440693 11802 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T07:10:03.651167+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-26T06:00:00+00:00 TriggerDagRunOperator 2021-03-26T07:10:05.979108+00:00 2021-03-26T07:10:06.539408+00:00 0:00:00.560300 11801 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T07:10:03.651127+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-26T06:00:00+00:00 EmrJobFlowSensor 2021-03-26T07:00:51.030247+00:00 2021-03-26T07:09:53.687979+00:00 0:09:02.657732 11797 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-26T07:00:48.706545+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-26T06:00:00+00:00 EmrCreateJobFlowOperator 2021-03-26T07:00:28.835277+00:00 2021-03-26T07:00:30.562539+00:00 0:00:01.727262 11796 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-26T07:00:26.689317+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-26T06:00:00+00:00 PythonOperator 2021-03-26T07:00:07.000610+00:00 2021-03-26T07:00:09.704696+00:00 0:00:02.704086 11795 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-26T07:00:04.593264+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-26T05:00:00+00:00 TriggerDagRunOperator 2021-03-26T06:11:11.870793+00:00 2021-03-26T06:11:12.269793+00:00 0:00:00.399000 11790 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T06:11:09.504720+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-26T05:00:00+00:00 TriggerDagRunOperator 2021-03-26T06:11:11.671475+00:00 2021-03-26T06:11:12.204361+00:00 0:00:00.532886 11789 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T06:11:09.504752+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-26T05:00:00+00:00 EmrJobFlowSensor 2021-03-26T06:01:02.516407+00:00 2021-03-26T06:11:05.396845+00:00 0:10:02.880438 11785 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-26T06:01:00.313320+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-26T05:00:00+00:00 EmrCreateJobFlowOperator 2021-03-26T06:00:38.653748+00:00 2021-03-26T06:00:40.429484+00:00 0:00:01.775736 11784 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-26T06:00:36.299311+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-26T05:00:00+00:00 PythonOperator 2021-03-26T06:00:15.065965+00:00 2021-03-26T06:00:17.810803+00:00 0:00:02.744838 11783 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-26T06:00:12.280670+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-26T04:00:00+00:00 TriggerDagRunOperator 2021-03-26T05:10:28.939864+00:00 2021-03-26T05:10:29.333628+00:00 0:00:00.393764 11778 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T05:10:26.645657+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-26T04:00:00+00:00 TriggerDagRunOperator 2021-03-26T05:10:28.929408+00:00 2021-03-26T05:10:29.434918+00:00 0:00:00.505510 11777 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T05:10:26.645726+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-26T04:00:00+00:00 EmrJobFlowSensor 2021-03-26T05:01:08.067570+00:00 2021-03-26T05:10:10.661390+00:00 0:09:02.593820 11773 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-26T05:01:05.908392+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-26T04:00:00+00:00 EmrCreateJobFlowOperator 2021-03-26T05:00:46.185081+00:00 2021-03-26T05:00:47.903778+00:00 0:00:01.718697 11772 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-26T05:00:43.891373+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-26T04:00:00+00:00 PythonOperator 2021-03-26T05:00:24.269235+00:00 2021-03-26T05:00:26.962069+00:00 0:00:02.692834 11771 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-26T05:00:21.856645+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-26T03:00:00+00:00 TriggerDagRunOperator 2021-03-26T04:11:23.876908+00:00 2021-03-26T04:11:24.557782+00:00 0:00:00.680874 11766 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T04:11:21.441820+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-26T03:00:00+00:00 TriggerDagRunOperator 2021-03-26T04:11:23.808921+00:00 2021-03-26T04:11:24.418748+00:00 0:00:00.609827 11765 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T04:11:21.441783+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-26T03:00:00+00:00 EmrJobFlowSensor 2021-03-26T04:01:12.655714+00:00 2021-03-26T04:11:15.468364+00:00 0:10:02.812650 11761 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-26T04:01:10.466874+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-26T03:00:00+00:00 EmrCreateJobFlowOperator 2021-03-26T04:00:52.603270+00:00 2021-03-26T04:00:54.362288+00:00 0:00:01.759018 11760 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-26T04:00:50.432596+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-26T03:00:00+00:00 PythonOperator 2021-03-26T04:00:24.985587+00:00 2021-03-26T04:00:27.732953+00:00 0:00:02.747366 11759 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-26T04:00:22.411033+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-26T02:00:00+00:00 TriggerDagRunOperator 2021-03-26T03:10:08.718880+00:00 2021-03-26T03:10:09.184204+00:00 0:00:00.465324 11754 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T03:10:05.941577+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-26T02:00:00+00:00 TriggerDagRunOperator 2021-03-26T03:10:08.363425+00:00 2021-03-26T03:10:08.879825+00:00 0:00:00.516400 11753 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T03:10:05.941608+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-26T02:00:00+00:00 EmrJobFlowSensor 2021-03-26T03:00:57.388883+00:00 2021-03-26T03:10:00.179782+00:00 0:09:02.790899 11749 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-26T03:00:55.185865+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-26T02:00:00+00:00 EmrCreateJobFlowOperator 2021-03-26T03:00:35.494865+00:00 2021-03-26T03:00:37.178972+00:00 0:00:01.684107 11748 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-26T03:00:33.185348+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-26T02:00:00+00:00 PythonOperator 2021-03-26T03:00:13.623999+00:00 2021-03-26T03:00:16.522726+00:00 0:00:02.898727 11747 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-26T03:00:11.086950+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-26T01:00:00+00:00 TriggerDagRunOperator 2021-03-26T02:09:58.560308+00:00 2021-03-26T02:09:59.058658+00:00 0:00:00.498350 11742 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T02:09:56.119381+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-26T01:00:00+00:00 TriggerDagRunOperator 2021-03-26T02:09:58.371687+00:00 2021-03-26T02:09:58.792985+00:00 0:00:00.421298 11741 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T02:09:56.119344+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-26T01:00:00+00:00 EmrJobFlowSensor 2021-03-26T02:00:49.510650+00:00 2021-03-26T02:09:52.359143+00:00 0:09:02.848493 11737 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-26T02:00:47.229423+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-26T01:00:00+00:00 EmrCreateJobFlowOperator 2021-03-26T02:00:27.466116+00:00 2021-03-26T02:00:29.202756+00:00 0:00:01.736640 11736 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-26T02:00:25.211645+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-26T01:00:00+00:00 PythonOperator 2021-03-26T02:00:05.852734+00:00 2021-03-26T02:00:08.735784+00:00 0:00:02.883050 11735 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-26T02:00:03.340862+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-26T00:00:00+00:00 TriggerDagRunOperator 2021-03-26T01:10:15.572392+00:00 2021-03-26T01:10:16.085027+00:00 0:00:00.512635 11730 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T01:10:13.299205+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-26T00:00:00+00:00 TriggerDagRunOperator 2021-03-26T01:10:15.526748+00:00 2021-03-26T01:10:15.939477+00:00 0:00:00.412729 11729 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T01:10:13.299174+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-26T00:00:00+00:00 EmrJobFlowSensor 2021-03-26T01:00:58.815664+00:00 2021-03-26T01:10:01.536248+00:00 0:09:02.720584 11725 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-26T01:00:56.444303+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-26T00:00:00+00:00 EmrCreateJobFlowOperator 2021-03-26T01:00:38.595713+00:00 2021-03-26T01:00:40.297282+00:00 0:00:01.701569 11724 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-26T01:00:36.336179+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-26T00:00:00+00:00 PythonOperator 2021-03-26T01:00:16.589277+00:00 2021-03-26T01:00:19.368373+00:00 0:00:02.779096 11723 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-26T01:00:14.230709+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-25T23:00:00+00:00 TriggerDagRunOperator 2021-03-26T00:09:38.067997+00:00 2021-03-26T00:09:38.922637+00:00 0:00:00.854640 11718 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T00:09:35.570990+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-25T23:00:00+00:00 TriggerDagRunOperator 2021-03-26T00:09:37.867604+00:00 2021-03-26T00:09:38.260681+00:00 0:00:00.393077 11717 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T00:09:35.570941+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-25T23:00:00+00:00 EmrJobFlowSensor 2021-03-26T00:01:15.011372+00:00 2021-03-26T00:09:17.632450+00:00 0:08:02.621078 11713 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-26T00:01:12.783093+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-25T23:00:00+00:00 EmrCreateJobFlowOperator 2021-03-26T00:00:53.062891+00:00 2021-03-26T00:00:54.751089+00:00 0:00:01.688198 11712 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-26T00:00:50.784284+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-25T23:00:00+00:00 PythonOperator 2021-03-26T00:00:24.972656+00:00 2021-03-26T00:00:27.697785+00:00 0:00:02.725129 11711 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-26T00:00:22.730375+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-25T22:00:00+00:00 TriggerDagRunOperator 2021-03-25T23:11:14.558707+00:00 2021-03-25T23:11:15.061117+00:00 0:00:00.502410 11706 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T23:11:11.978212+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-25T22:00:00+00:00 TriggerDagRunOperator 2021-03-25T23:11:14.407952+00:00 2021-03-25T23:11:14.851133+00:00 0:00:00.443181 11705 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T23:11:11.978161+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-25T22:00:00+00:00 EmrJobFlowSensor 2021-03-25T23:00:57.235157+00:00 2021-03-25T23:11:00.089381+00:00 0:10:02.854224 11701 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T23:00:55.055805+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-25T22:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T23:00:35.255320+00:00 2021-03-25T23:00:37.074675+00:00 0:00:01.819355 11700 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-25T23:00:33.013325+00:00 2 default_pool