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 check_cluster_status 2023-03-06T09:00:00+00:00 EmrJobFlowSensor 2023-03-06T10:01:22.314080+00:00 2023-03-06T10:11:24.010071+00:00 0:10:01.695991 349231 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-06T10:01:20.089859+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-06T09:00:00+00:00 EmrCreateJobFlowOperator 2023-03-06T10:01:00.448218+00:00 2023-03-06T10:01:01.364297+00:00 0:00:00.916079 349229 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-06T10:00:58.065306+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-06T09:00:00+00:00 PythonOperator 2023-03-06T10:00:38.430745+00:00 2023-03-06T10:00:42.402934+00:00 0:00:03.972189 349227 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-06T10:00:36.046818+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-06T08:00:00+00:00 TriggerDagRunOperator 2023-03-06T09:26:20.678936+00:00 2023-03-06T09:26:21.239569+00:00 0:00:00.560633 349221 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-06T09:26:18.243313+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-06T08:00:00+00:00 TriggerDagRunOperator 2023-03-06T09:26:20.650909+00:00 2023-03-06T09:26:21.201710+00:00 0:00:00.550801 349220 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-06T09:26:18.243343+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-06T08:00:00+00:00 EmrJobFlowSensor 2023-03-06T09:13:31.300374+00:00 2023-03-06T09:22:33.651697+00:00 0:09:02.351323 349216 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-06T09:13:29.009723+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-06T08:00:00+00:00 EmrCreateJobFlowOperator 2023-03-06T09:13:11.370244+00:00 2023-03-06T09:13:12.202749+00:00 0:00:00.832505 349213 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-06T09:13:08.985677+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-06T08:00:00+00:00 PythonOperator 2023-03-06T09:12:49.362500+00:00 2023-03-06T09:12:52.604584+00:00 0:00:03.242084 349211 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-06T09:12:46.970909+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-06T07:00:00+00:00 TriggerDagRunOperator 2023-03-06T08:26:14.345828+00:00 2023-03-06T08:26:15.134592+00:00 0:00:00.788764 349200 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-06T08:26:11.059459+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-06T07:00:00+00:00 TriggerDagRunOperator 2023-03-06T08:26:13.402709+00:00 2023-03-06T08:26:13.849088+00:00 0:00:00.446379 349199 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-06T08:26:11.059404+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-06T07:00:00+00:00 EmrJobFlowSensor 2023-03-06T08:01:06.766258+00:00 2023-03-06T08:11:08.485599+00:00 0:10:01.719341 349195 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-06T08:01:04.526066+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-06T07:00:00+00:00 EmrCreateJobFlowOperator 2023-03-06T08:00:47.217458+00:00 2023-03-06T08:00:48.370962+00:00 0:00:01.153504 349193 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-06T08:00:42.491917+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-06T07:00:00+00:00 PythonOperator 2023-03-06T08:00:25.178689+00:00 2023-03-06T08:00:28.094443+00:00 0:00:02.915754 349191 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-06T08:00:22.483671+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-06T06:00:00+00:00 TriggerDagRunOperator 2023-03-06T07:22:41.754064+00:00 2023-03-06T07:22:42.253922+00:00 0:00:00.499858 349183 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-06T07:22:39.251537+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-06T06:00:00+00:00 TriggerDagRunOperator 2023-03-06T07:22:41.696840+00:00 2023-03-06T07:22:42.249831+00:00 0:00:00.552991 349182 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-06T07:22:39.251567+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-06T06:00:00+00:00 EmrJobFlowSensor 2023-03-06T07:12:28.077541+00:00 2023-03-06T07:22:29.973806+00:00 0:10:01.896265 349176 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-06T07:12:25.737637+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-06T06:00:00+00:00 EmrCreateJobFlowOperator 2023-03-06T07:12:07.712210+00:00 2023-03-06T07:12:08.960838+00:00 0:00:01.248628 349172 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-06T07:12:03.715153+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-06T05:00:00+00:00 TriggerDagRunOperator 2023-03-06T07:11:52.215111+00:00 2023-03-06T07:11:53.223833+00:00 0:00:01.008722 349170 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-06T07:11:43.671317+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-06T06:00:00+00:00 PythonOperator 2023-03-06T07:11:52.177868+00:00 2023-03-06T07:11:57.058209+00:00 0:00:04.880341 349169 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-06T07:11:43.671366+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-06T05:00:00+00:00 TriggerDagRunOperator 2023-03-06T07:11:46.152506+00:00 2023-03-06T07:11:46.637351+00:00 0:00:00.484845 349167 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-06T07:11:43.671352+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-06T05:00:00+00:00 EmrJobFlowSensor 2023-03-06T06:01:04.263148+00:00 2023-03-06T06:11:05.922006+00:00 0:10:01.658858 349162 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-06T06:01:01.904253+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-06T05:00:00+00:00 EmrCreateJobFlowOperator 2023-03-06T06:00:40.540966+00:00 2023-03-06T06:00:41.937521+00:00 0:00:01.396555 349160 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-06T06:00:37.827357+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-06T05:00:00+00:00 PythonOperator 2023-03-06T06:00:18.553257+00:00 2023-03-06T06:00:22.457355+00:00 0:00:03.904098 349158 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-06T06:00:15.810404+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-06T04:00:00+00:00 TriggerDagRunOperator 2023-03-06T05:48:50.506675+00:00 2023-03-06T05:48:51.232868+00:00 0:00:00.726193 349153 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-06T05:48:47.774255+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-06T04:00:00+00:00 TriggerDagRunOperator 2023-03-06T05:48:50.489889+00:00 2023-03-06T05:48:51.187247+00:00 0:00:00.697358 349152 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-06T05:48:47.774285+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-06T04:00:00+00:00 EmrJobFlowSensor 2023-03-06T05:17:08.488702+00:00 2023-03-06T05:27:10.361841+00:00 0:10:01.873139 349148 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-06T05:17:06.097687+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-06T04:00:00+00:00 EmrCreateJobFlowOperator 2023-03-06T05:16:48.263907+00:00 2023-03-06T05:16:49.048934+00:00 0:00:00.785027 349145 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-06T05:16:46.067767+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-06T04:00:00+00:00 PythonOperator 2023-03-06T05:16:26.830323+00:00 2023-03-06T05:16:30.785852+00:00 0:00:03.955529 349142 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-06T05:16:23.934811+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-06T03:00:00+00:00 TriggerDagRunOperator 2023-03-06T04:18:48.724584+00:00 2023-03-06T04:18:49.219647+00:00 0:00:00.495063 349133 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-06T04:18:46.243252+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-06T03:00:00+00:00 TriggerDagRunOperator 2023-03-06T04:18:48.632198+00:00 2023-03-06T04:18:49.138214+00:00 0:00:00.506016 349132 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-06T04:18:46.243223+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-06T03:00:00+00:00 EmrJobFlowSensor 2023-03-06T04:09:30.290990+00:00 2023-03-06T04:18:31.973137+00:00 0:09:01.682147 349129 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-06T04:09:27.813677+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-06T03:00:00+00:00 EmrCreateJobFlowOperator 2023-03-06T04:09:10.451100+00:00 2023-03-06T04:09:11.287111+00:00 0:00:00.836011 349126 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-06T04:09:07.787586+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-06T03:00:00+00:00 PythonOperator 2023-03-06T04:08:46.605594+00:00 2023-03-06T04:08:49.549334+00:00 0:00:02.943740 349123 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-06T04:08:44.017333+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-06T02:00:00+00:00 TriggerDagRunOperator 2023-03-06T03:40:12.826332+00:00 2023-03-06T03:40:13.296250+00:00 0:00:00.469918 349115 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-06T03:40:10.101686+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-06T02:00:00+00:00 TriggerDagRunOperator 2023-03-06T03:40:12.830425+00:00 2023-03-06T03:40:13.366441+00:00 0:00:00.536016 349114 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-06T03:40:10.101728+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-06T02:00:00+00:00 EmrJobFlowSensor 2023-03-06T03:30:06.216480+00:00 2023-03-06T03:40:07.969889+00:00 0:10:01.753409 349109 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-06T03:30:03.913177+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-06T02:00:00+00:00 EmrCreateJobFlowOperator 2023-03-06T03:29:46.277640+00:00 2023-03-06T03:29:47.154261+00:00 0:00:00.876621 349106 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-06T03:29:43.900031+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-06T02:00:00+00:00 PythonOperator 2023-03-06T03:29:24.718811+00:00 2023-03-06T03:29:28.021815+00:00 0:00:03.303004 349103 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-06T03:29:21.805114+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-06T01:00:00+00:00 TriggerDagRunOperator 2023-03-06T02:12:44.989618+00:00 2023-03-06T02:12:45.739177+00:00 0:00:00.749559 349096 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-06T02:12:42.228827+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-06T01:00:00+00:00 TriggerDagRunOperator 2023-03-06T02:12:44.875090+00:00 2023-03-06T02:12:45.565207+00:00 0:00:00.690117 349095 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-06T02:12:42.228867+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-06T01:00:00+00:00 EmrJobFlowSensor 2023-03-06T02:02:33.312205+00:00 2023-03-06T02:12:35.100214+00:00 0:10:01.788009 349089 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-06T02:02:30.899225+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-06T01:00:00+00:00 EmrCreateJobFlowOperator 2023-03-06T02:02:13.177887+00:00 2023-03-06T02:02:14.059435+00:00 0:00:00.881548 349087 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-06T02:02:10.803196+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-06T01:00:00+00:00 PythonOperator 2023-03-06T02:01:51.802013+00:00 2023-03-06T02:01:55.141995+00:00 0:00:03.339982 349085 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-06T02:01:48.786040+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-06T00:00:00+00:00 TriggerDagRunOperator 2023-03-06T01:10:54.376672+00:00 2023-03-06T01:10:54.847901+00:00 0:00:00.471229 349068 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-06T01:10:51.377405+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-06T00:00:00+00:00 TriggerDagRunOperator 2023-03-06T01:10:53.690379+00:00 2023-03-06T01:10:54.209226+00:00 0:00:00.518847 349067 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-06T01:10:51.377438+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-06T00:00:00+00:00 EmrJobFlowSensor 2023-03-06T01:00:48.260161+00:00 2023-03-06T01:10:50.082727+00:00 0:10:01.822566 349061 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-06T01:00:45.824555+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-06T00:00:00+00:00 EmrCreateJobFlowOperator 2023-03-06T01:00:28.874688+00:00 2023-03-06T01:00:29.762191+00:00 0:00:00.887503 349059 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-06T01:00:25.734101+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-06T00:00:00+00:00 PythonOperator 2023-03-06T01:00:06.341413+00:00 2023-03-06T01:00:09.666262+00:00 0:00:03.324849 349057 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-06T01:00:03.729083+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-05T23:00:00+00:00 TriggerDagRunOperator 2023-03-06T00:46:52.284954+00:00 2023-03-06T00:46:52.829197+00:00 0:00:00.544243 349052 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-06T00:46:49.309600+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-05T23:00:00+00:00 TriggerDagRunOperator 2023-03-06T00:46:52.153852+00:00 2023-03-06T00:46:52.660239+00:00 0:00:00.506387 349051 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-06T00:46:49.309572+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-05T23:00:00+00:00 EmrJobFlowSensor 2023-03-06T00:07:57.521011+00:00 2023-03-06T00:17:59.328066+00:00 0:10:01.807055 349047 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-06T00:07:55.230179+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-05T23:00:00+00:00 EmrCreateJobFlowOperator 2023-03-06T00:07:35.349968+00:00 2023-03-06T00:07:36.244952+00:00 0:00:00.894984 349044 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-06T00:07:33.201238+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-05T23:00:00+00:00 PythonOperator 2023-03-06T00:07:15.714907+00:00 2023-03-06T00:07:18.757000+00:00 0:00:03.042093 349041 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-06T00:07:13.160000+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-05T22:00:00+00:00 TriggerDagRunOperator 2023-03-05T23:15:05.036125+00:00 2023-03-05T23:15:05.520931+00:00 0:00:00.484806 349029 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-05T23:15:02.243673+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-05T22:00:00+00:00 TriggerDagRunOperator 2023-03-05T23:15:04.432282+00:00 2023-03-05T23:15:04.915664+00:00 0:00:00.483382 349028 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-05T23:15:02.243642+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-05T22:00:00+00:00 EmrJobFlowSensor 2023-03-05T23:00:57.299426+00:00 2023-03-05T23:10:59.185527+00:00 0:10:01.886101 349023 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-05T23:00:54.803303+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-05T22:00:00+00:00 EmrCreateJobFlowOperator 2023-03-05T23:00:35.217315+00:00 2023-03-05T23:00:36.024654+00:00 0:00:00.807339 349020 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-05T23:00:32.733148+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-05T22:00:00+00:00 PythonOperator 2023-03-05T23:00:12.969923+00:00 2023-03-05T23:00:16.435255+00:00 0:00:03.465332 349017 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-05T23:00:10.693123+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-05T21:00:00+00:00 TriggerDagRunOperator 2023-03-05T22:10:57.106435+00:00 2023-03-05T22:10:57.622934+00:00 0:00:00.516499 349007 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-05T22:10:54.415721+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-05T21:00:00+00:00 TriggerDagRunOperator 2023-03-05T22:10:56.885529+00:00 2023-03-05T22:10:57.357835+00:00 0:00:00.472306 349006 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-05T22:10:54.415693+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-05T21:00:00+00:00 EmrJobFlowSensor 2023-03-05T22:00:49.983160+00:00 2023-03-05T22:10:51.859175+00:00 0:10:01.876015 348999 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-05T22:00:47.611610+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-05T21:00:00+00:00 EmrCreateJobFlowOperator 2023-03-05T22:00:27.847849+00:00 2023-03-05T22:00:28.742252+00:00 0:00:00.894403 348997 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-05T22:00:25.527893+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-05T21:00:00+00:00 PythonOperator 2023-03-05T22:00:05.857069+00:00 2023-03-05T22:00:08.965837+00:00 0:00:03.108768 348995 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-05T22:00:03.501708+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-05T20:00:00+00:00 TriggerDagRunOperator 2023-03-05T21:36:11.295637+00:00 2023-03-05T21:36:11.799713+00:00 0:00:00.504076 348989 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-05T21:36:08.839371+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-05T20:00:00+00:00 TriggerDagRunOperator 2023-03-05T21:36:11.273921+00:00 2023-03-05T21:36:11.763451+00:00 0:00:00.489530 348988 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-05T21:36:08.839401+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-05T20:00:00+00:00 EmrJobFlowSensor 2023-03-05T21:17:54.068461+00:00 2023-03-05T21:27:55.799889+00:00 0:10:01.731428 348985 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-05T21:17:51.831417+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-05T20:00:00+00:00 EmrCreateJobFlowOperator 2023-03-05T21:17:32.207178+00:00 2023-03-05T21:17:33.047025+00:00 0:00:00.839847 348982 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-05T21:17:29.773908+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-05T20:00:00+00:00 PythonOperator 2023-03-05T21:17:10.087042+00:00 2023-03-05T21:17:14.124782+00:00 0:00:04.037740 348979 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-05T21:17:07.749042+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-05T19:00:00+00:00 TriggerDagRunOperator 2023-03-05T20:10:04.482812+00:00 2023-03-05T20:10:05.007933+00:00 0:00:00.525121 348967 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-05T20:10:01.894051+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-05T19:00:00+00:00 TriggerDagRunOperator 2023-03-05T20:10:04.334475+00:00 2023-03-05T20:10:04.816820+00:00 0:00:00.482345 348966 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-05T20:10:01.894082+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-05T19:00:00+00:00 EmrJobFlowSensor 2023-03-05T20:00:47.115529+00:00 2023-03-05T20:09:48.701934+00:00 0:09:01.586405 348959 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-05T20:00:44.715111+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-05T19:00:00+00:00 EmrCreateJobFlowOperator 2023-03-05T20:00:25.163163+00:00 2023-03-05T20:00:26.022537+00:00 0:00:00.859374 348957 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-05T20:00:22.692849+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-05T19:00:00+00:00 PythonOperator 2023-03-05T20:00:05.194929+00:00 2023-03-05T20:00:11.549763+00:00 0:00:06.354834 348955 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-05T20:00:02.631339+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-05T18:00:00+00:00 TriggerDagRunOperator 2023-03-05T19:20:59.798482+00:00 2023-03-05T19:21:00.312975+00:00 0:00:00.514493 348945 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-05T19:20:56.606866+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-05T18:00:00+00:00 TriggerDagRunOperator 2023-03-05T19:20:59.079637+00:00 2023-03-05T19:20:59.515355+00:00 0:00:00.435718 348944 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-05T19:20:56.606894+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-05T18:00:00+00:00 EmrJobFlowSensor 2023-03-05T19:01:01.190987+00:00 2023-03-05T19:11:03.003337+00:00 0:10:01.812350 348939 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-05T19:00:58.935125+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-05T18:00:00+00:00 EmrCreateJobFlowOperator 2023-03-05T19:00:41.153508+00:00 2023-03-05T19:00:42.015490+00:00 0:00:00.861982 348937 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-05T19:00:38.899459+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-05T18:00:00+00:00 PythonOperator 2023-03-05T19:00:19.823835+00:00 2023-03-05T19:00:26.680520+00:00 0:00:06.856685 348935 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-05T19:00:16.869447+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-05T17:00:00+00:00 TriggerDagRunOperator 2023-03-05T18:16:12.360198+00:00 2023-03-05T18:16:13.110474+00:00 0:00:00.750276 348925 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-05T18:16:08.047148+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-05T17:00:00+00:00 TriggerDagRunOperator 2023-03-05T18:16:10.317722+00:00 2023-03-05T18:16:10.778520+00:00 0:00:00.460798 348924 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-05T18:16:08.047115+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-05T17:00:00+00:00 EmrJobFlowSensor 2023-03-05T18:00:52.186820+00:00 2023-03-05T18:10:53.807177+00:00 0:10:01.620357 348919 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-05T18:00:49.941962+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-05T17:00:00+00:00 EmrCreateJobFlowOperator 2023-03-05T18:00:30.269165+00:00 2023-03-05T18:00:31.178765+00:00 0:00:00.909600 348917 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-05T18:00:27.872707+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-05T17:00:00+00:00 PythonOperator 2023-03-05T18:00:08.194700+00:00 2023-03-05T18:00:11.394596+00:00 0:00:03.199896 348915 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-05T18:00:05.853385+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-05T16:00:00+00:00 TriggerDagRunOperator 2023-03-05T17:11:02.490255+00:00 2023-03-05T17:11:03.086112+00:00 0:00:00.595857 348906 airflow-worker-2.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-05T17:10:59.668913+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-05T16:00:00+00:00 TriggerDagRunOperator 2023-03-05T17:11:02.469883+00:00 2023-03-05T17:11:03.090775+00:00 0:00:00.620892 348905 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-05T17:10:59.668885+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-05T16:00:00+00:00 EmrJobFlowSensor 2023-03-05T17:02:48.725704+00:00 2023-03-05T17:10:50.284777+00:00 0:08:01.559073 348896 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-05T17:02:46.198209+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-05T16:00:00+00:00 EmrCreateJobFlowOperator 2023-03-05T17:00:29.736191+00:00 2023-03-05T17:00:30.694030+00:00 0:00:00.957839 348894 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-05T17:00:27.524422+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-05T16:00:00+00:00 PythonOperator 2023-03-05T17:00:09.655002+00:00 2023-03-05T17:00:13.618568+00:00 0:00:03.963566 348893 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-05T17:00:07.492341+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-05T15:00:00+00:00 TriggerDagRunOperator 2023-03-05T16:34:06.716950+00:00 2023-03-05T16:34:07.227229+00:00 0:00:00.510279 348886 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-05T16:34:03.945484+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-05T15:00:00+00:00 TriggerDagRunOperator 2023-03-05T16:34:06.601240+00:00 2023-03-05T16:34:07.113764+00:00 0:00:00.512524 348885 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-05T16:34:03.945456+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-05T15:00:00+00:00 EmrJobFlowSensor 2023-03-05T16:18:18.358104+00:00 2023-03-05T16:28:20.270497+00:00 0:10:01.912393 348881 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-05T16:18:15.991015+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-05T15:00:00+00:00 EmrCreateJobFlowOperator 2023-03-05T16:18:02.732103+00:00 2023-03-05T16:18:04.036438+00:00 0:00:01.304335 348878 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-05T16:17:55.980498+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-05T15:00:00+00:00 PythonOperator 2023-03-05T16:17:36.274703+00:00 2023-03-05T16:17:42.454891+00:00 0:00:06.180188 348875 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-05T16:17:33.870772+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-05T14:00:00+00:00 TriggerDagRunOperator 2023-03-05T15:17:06.630492+00:00 2023-03-05T15:17:07.456658+00:00 0:00:00.826166 348861 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-05T15:17:03.257947+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-05T14:00:00+00:00 TriggerDagRunOperator 2023-03-05T15:17:06.162561+00:00 2023-03-05T15:17:06.614220+00:00 0:00:00.451659 348860 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-05T15:17:03.257979+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-05T14:00:00+00:00 EmrJobFlowSensor 2023-03-05T15:01:01.174832+00:00 2023-03-05T15:11:03.008593+00:00 0:10:01.833761 348856 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-05T15:00:58.975099+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-05T14:00:00+00:00 EmrCreateJobFlowOperator 2023-03-05T15:00:39.149355+00:00 2023-03-05T15:00:39.957716+00:00 0:00:00.808361 348854 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-05T15:00:36.928843+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-05T14:00:00+00:00 PythonOperator 2023-03-05T15:00:17.460054+00:00 2023-03-05T15:00:23.252211+00:00 0:00:05.792157 348852 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-05T15:00:14.862808+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-05T13:00:00+00:00 TriggerDagRunOperator 2023-03-05T14:43:26.094167+00:00 2023-03-05T14:43:26.668018+00:00 0:00:00.573851 348847 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-05T14:43:23.249141+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-05T13:00:00+00:00 TriggerDagRunOperator 2023-03-05T14:43:25.895296+00:00 2023-03-05T14:43:26.565602+00:00 0:00:00.670306 348846 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-05T14:43:23.249113+00:00 2 default_pool