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-12T07:00:00+00:00 EmrJobFlowSensor 2023-03-12T08:00:54.593779+00:00 2023-03-12T08:10:56.336294+00:00 0:10:01.742515 352290 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-12T08:00:52.351407+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-12T07:00:00+00:00 EmrCreateJobFlowOperator 2023-03-12T08:00:33.090818+00:00 2023-03-12T08:00:34.255031+00:00 0:00:01.164213 352288 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-12T08:00:30.398259+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-12T07:00:00+00:00 PythonOperator 2023-03-12T08:00:12.699771+00:00 2023-03-12T08:00:15.883108+00:00 0:00:03.183337 352286 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-12T08:00:10.227719+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-12T06:00:00+00:00 TriggerDagRunOperator 2023-03-12T07:12:45.375603+00:00 2023-03-12T07:12:46.092590+00:00 0:00:00.716987 352275 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-12T07:12:41.187627+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-12T06:00:00+00:00 TriggerDagRunOperator 2023-03-12T07:12:43.389008+00:00 2023-03-12T07:12:44.014984+00:00 0:00:00.625976 352274 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-12T07:12:41.187596+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-12T06:00:00+00:00 EmrJobFlowSensor 2023-03-12T07:00:58.173127+00:00 2023-03-12T07:10:59.994754+00:00 0:10:01.821627 352269 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-12T07:00:55.725467+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-12T06:00:00+00:00 EmrCreateJobFlowOperator 2023-03-12T07:00:37.883305+00:00 2023-03-12T07:00:38.784589+00:00 0:00:00.901284 352267 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-12T07:00:35.704234+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-12T06:00:00+00:00 PythonOperator 2023-03-12T07:00:16.403761+00:00 2023-03-12T07:00:20.316614+00:00 0:00:03.912853 352265 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-12T07:00:13.688597+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-12T05:00:00+00:00 TriggerDagRunOperator 2023-03-12T06:17:34.791458+00:00 2023-03-12T06:17:35.368868+00:00 0:00:00.577410 352258 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-12T06:17:31.913588+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-12T05:00:00+00:00 TriggerDagRunOperator 2023-03-12T06:17:34.555822+00:00 2023-03-12T06:17:35.075499+00:00 0:00:00.519677 352257 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-12T06:17:31.913560+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-12T05:00:00+00:00 EmrJobFlowSensor 2023-03-12T06:00:51.314221+00:00 2023-03-12T06:10:53.198020+00:00 0:10:01.883799 352249 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-12T06:00:49.005037+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-12T05:00:00+00:00 EmrCreateJobFlowOperator 2023-03-12T06:00:29.166202+00:00 2023-03-12T06:00:30.123275+00:00 0:00:00.957073 352247 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-12T06:00:26.983787+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-12T05:00:00+00:00 PythonOperator 2023-03-12T06:00:07.934755+00:00 2023-03-12T06:00:11.209676+00:00 0:00:03.274921 352245 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-12T06:00:04.967623+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-12T04:00:00+00:00 TriggerDagRunOperator 2023-03-12T05:13:41.783773+00:00 2023-03-12T05:13:42.573466+00:00 0:00:00.789693 352234 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-12T05:13:33.939894+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-12T04:00:00+00:00 TriggerDagRunOperator 2023-03-12T05:13:36.229047+00:00 2023-03-12T05:13:36.693884+00:00 0:00:00.464837 352232 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-12T05:13:33.939856+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-12T04:00:00+00:00 EmrJobFlowSensor 2023-03-12T05:00:49.252898+00:00 2023-03-12T05:10:51.045442+00:00 0:10:01.792544 352228 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-12T05:00:47.041780+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-12T04:00:00+00:00 EmrCreateJobFlowOperator 2023-03-12T05:00:27.540820+00:00 2023-03-12T05:00:28.400192+00:00 0:00:00.859372 352227 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-12T05:00:24.981914+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-12T04:00:00+00:00 PythonOperator 2023-03-12T05:00:05.229792+00:00 2023-03-12T05:00:08.297065+00:00 0:00:03.067273 352225 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-12T05:00:02.975783+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-12T03:00:00+00:00 TriggerDagRunOperator 2023-03-12T04:16:55.341303+00:00 2023-03-12T04:16:55.867616+00:00 0:00:00.526313 352216 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-12T04:16:52.266308+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-12T03:00:00+00:00 TriggerDagRunOperator 2023-03-12T04:16:55.196355+00:00 2023-03-12T04:16:55.669793+00:00 0:00:00.473438 352215 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-12T04:16:52.266346+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-12T03:00:00+00:00 EmrJobFlowSensor 2023-03-12T04:00:49.708701+00:00 2023-03-12T04:10:51.948404+00:00 0:10:02.239703 352211 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-12T04:00:45.824458+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-12T03:00:00+00:00 EmrCreateJobFlowOperator 2023-03-12T04:00:28.055062+00:00 2023-03-12T04:00:28.914719+00:00 0:00:00.859657 352209 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-12T04:00:25.787920+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-12T03:00:00+00:00 PythonOperator 2023-03-12T04:00:06.214824+00:00 2023-03-12T04:00:10.215332+00:00 0:00:04.000508 352207 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-12T04:00:03.765081+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-12T02:00:00+00:00 TriggerDagRunOperator 2023-03-12T03:37:28.036849+00:00 2023-03-12T03:37:28.516998+00:00 0:00:00.480149 352202 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-12T03:37:25.333270+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-12T02:00:00+00:00 TriggerDagRunOperator 2023-03-12T03:37:27.854195+00:00 2023-03-12T03:37:28.329590+00:00 0:00:00.475395 352201 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-12T03:37:25.333227+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-12T02:00:00+00:00 EmrJobFlowSensor 2023-03-12T03:23:58.160720+00:00 2023-03-12T03:35:00.136879+00:00 0:11:01.976159 352196 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-12T03:23:55.899464+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-12T02:00:00+00:00 EmrCreateJobFlowOperator 2023-03-12T03:23:36.230126+00:00 2023-03-12T03:23:37.145296+00:00 0:00:00.915170 352193 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-12T03:23:33.877406+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-12T02:00:00+00:00 PythonOperator 2023-03-12T03:23:16.634598+00:00 2023-03-12T03:23:20.618146+00:00 0:00:03.983548 352190 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-12T03:23:13.829818+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-12T01:00:00+00:00 TriggerDagRunOperator 2023-03-12T02:11:18.239749+00:00 2023-03-12T02:11:18.775285+00:00 0:00:00.535536 352180 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-12T02:11:15.760273+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-12T01:00:00+00:00 TriggerDagRunOperator 2023-03-12T02:11:18.154013+00:00 2023-03-12T02:11:18.736496+00:00 0:00:00.582483 352179 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-12T02:11:15.760309+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-12T01:00:00+00:00 EmrJobFlowSensor 2023-03-12T02:01:08.546189+00:00 2023-03-12T02:11:10.298628+00:00 0:10:01.752439 352173 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-12T02:01:05.906696+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-12T01:00:00+00:00 EmrCreateJobFlowOperator 2023-03-12T02:00:46.347977+00:00 2023-03-12T02:00:47.172568+00:00 0:00:00.824591 352170 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-12T02:00:43.899527+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-12T01:00:00+00:00 PythonOperator 2023-03-12T02:00:24.162905+00:00 2023-03-12T02:00:28.116823+00:00 0:00:03.953918 352168 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-12T02:00:21.726868+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-12T00:00:00+00:00 TriggerDagRunOperator 2023-03-12T01:15:14.110578+00:00 2023-03-12T01:15:14.853689+00:00 0:00:00.743111 352153 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-12T01:15:11.701332+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-12T00:00:00+00:00 TriggerDagRunOperator 2023-03-12T01:15:14.034000+00:00 2023-03-12T01:15:14.681371+00:00 0:00:00.647371 352152 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-12T01:15:11.701303+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-12T00:00:00+00:00 EmrJobFlowSensor 2023-03-12T01:05:02.457208+00:00 2023-03-12T01:15:04.173660+00:00 0:10:01.716452 352146 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-12T01:04:59.781434+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-12T00:00:00+00:00 EmrCreateJobFlowOperator 2023-03-12T01:04:44.440735+00:00 2023-03-12T01:04:46.011660+00:00 0:00:01.570925 352144 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-12T01:04:39.765038+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-12T00:00:00+00:00 PythonOperator 2023-03-12T01:04:21.523928+00:00 2023-03-12T01:04:25.796390+00:00 0:00:04.272462 352142 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-12T01:04:17.745908+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-11T23:00:00+00:00 TriggerDagRunOperator 2023-03-12T00:17:17.414799+00:00 2023-03-12T00:17:17.913176+00:00 0:00:00.498377 352133 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-12T00:17:14.416368+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-11T23:00:00+00:00 TriggerDagRunOperator 2023-03-12T00:17:17.206985+00:00 2023-03-12T00:17:17.663036+00:00 0:00:00.456051 352132 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-12T00:17:14.416396+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-11T23:00:00+00:00 EmrJobFlowSensor 2023-03-12T00:01:03.700340+00:00 2023-03-12T00:11:05.615648+00:00 0:10:01.915308 352125 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-12T00:01:01.290232+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-11T23:00:00+00:00 EmrCreateJobFlowOperator 2023-03-12T00:00:41.598205+00:00 2023-03-12T00:00:42.431936+00:00 0:00:00.833731 352123 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-12T00:00:39.244162+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-11T23:00:00+00:00 PythonOperator 2023-03-12T00:00:21.704079+00:00 2023-03-12T00:00:24.784546+00:00 0:00:03.080467 352121 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-12T00:00:19.226718+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-11T22:00:00+00:00 TriggerDagRunOperator 2023-03-11T23:11:31.905799+00:00 2023-03-11T23:11:32.438110+00:00 0:00:00.532311 352110 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-11T23:11:29.382154+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-11T22:00:00+00:00 TriggerDagRunOperator 2023-03-11T23:11:31.746606+00:00 2023-03-11T23:11:32.237671+00:00 0:00:00.491065 352109 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-11T23:11:29.382183+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-11T22:00:00+00:00 EmrJobFlowSensor 2023-03-11T23:01:05.488967+00:00 2023-03-11T23:11:07.331156+00:00 0:10:01.842189 352103 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-11T23:01:03.234861+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-11T22:00:00+00:00 EmrCreateJobFlowOperator 2023-03-11T23:00:43.446112+00:00 2023-03-11T23:00:44.469902+00:00 0:00:01.023790 352100 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-11T23:00:41.212958+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-11T22:00:00+00:00 PythonOperator 2023-03-11T23:00:21.332632+00:00 2023-03-11T23:00:25.261295+00:00 0:00:03.928663 352097 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-11T23:00:19.180712+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-11T21:00:00+00:00 TriggerDagRunOperator 2023-03-11T22:11:29.138324+00:00 2023-03-11T22:11:29.703139+00:00 0:00:00.564815 352084 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-11T22:11:26.516375+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-11T21:00:00+00:00 TriggerDagRunOperator 2023-03-11T22:11:29.010955+00:00 2023-03-11T22:11:29.483235+00:00 0:00:00.472280 352083 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-11T22:11:26.516415+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-11T21:00:00+00:00 EmrJobFlowSensor 2023-03-11T22:01:01.815305+00:00 2023-03-11T22:11:03.621293+00:00 0:10:01.805988 352077 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-11T22:00:58.702576+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-11T21:00:00+00:00 EmrCreateJobFlowOperator 2023-03-11T22:00:38.988086+00:00 2023-03-11T22:00:39.809690+00:00 0:00:00.821604 352075 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-11T22:00:36.592125+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-11T21:00:00+00:00 PythonOperator 2023-03-11T22:00:17.692070+00:00 2023-03-11T22:00:20.964880+00:00 0:00:03.272810 352073 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-11T22:00:14.575480+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-11T20:00:00+00:00 TriggerDagRunOperator 2023-03-11T21:11:26.598008+00:00 2023-03-11T21:11:27.094579+00:00 0:00:00.496571 352061 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-11T21:11:24.233332+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-11T20:00:00+00:00 TriggerDagRunOperator 2023-03-11T21:11:26.554340+00:00 2023-03-11T21:11:27.040520+00:00 0:00:00.486180 352060 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-11T21:11:24.233303+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-11T20:00:00+00:00 EmrJobFlowSensor 2023-03-11T21:01:02.247477+00:00 2023-03-11T21:11:04.628200+00:00 0:10:02.380723 352053 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-11T21:00:58.987442+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-11T20:00:00+00:00 EmrCreateJobFlowOperator 2023-03-11T21:00:39.331451+00:00 2023-03-11T21:00:40.564920+00:00 0:00:01.233469 352051 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-11T21:00:36.835310+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-11T20:00:00+00:00 PythonOperator 2023-03-11T21:00:17.265786+00:00 2023-03-11T21:00:20.433770+00:00 0:00:03.167984 352049 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-11T21:00:14.804453+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-11T19:00:00+00:00 TriggerDagRunOperator 2023-03-11T20:11:17.070119+00:00 2023-03-11T20:11:17.523950+00:00 0:00:00.453831 352038 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-11T20:11:14.542290+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-11T19:00:00+00:00 TriggerDagRunOperator 2023-03-11T20:11:16.795121+00:00 2023-03-11T20:11:17.262201+00:00 0:00:00.467080 352037 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-11T20:11:14.542257+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-11T19:00:00+00:00 EmrJobFlowSensor 2023-03-11T20:01:00.512611+00:00 2023-03-11T20:11:02.349815+00:00 0:10:01.837204 352031 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-11T20:00:58.045249+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-11T19:00:00+00:00 EmrCreateJobFlowOperator 2023-03-11T20:00:40.806824+00:00 2023-03-11T20:00:41.627766+00:00 0:00:00.820942 352029 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-11T20:00:38.037190+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-11T19:00:00+00:00 PythonOperator 2023-03-11T20:00:18.285050+00:00 2023-03-11T20:00:21.451536+00:00 0:00:03.166486 352027 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-11T20:00:15.985183+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-11T18:00:00+00:00 TriggerDagRunOperator 2023-03-11T19:11:06.269380+00:00 2023-03-11T19:11:06.803286+00:00 0:00:00.533906 352015 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-11T19:11:04.046093+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-11T18:00:00+00:00 TriggerDagRunOperator 2023-03-11T19:11:06.278052+00:00 2023-03-11T19:11:06.754706+00:00 0:00:00.476654 352014 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-11T19:11:04.046062+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-11T18:00:00+00:00 EmrJobFlowSensor 2023-03-11T19:00:58.107951+00:00 2023-03-11T19:10:59.907634+00:00 0:10:01.799683 352007 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-11T19:00:55.820379+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-11T18:00:00+00:00 EmrCreateJobFlowOperator 2023-03-11T19:00:38.027752+00:00 2023-03-11T19:00:38.808680+00:00 0:00:00.780928 352005 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-11T19:00:35.803965+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-11T18:00:00+00:00 PythonOperator 2023-03-11T19:00:16.292161+00:00 2023-03-11T19:00:21.912279+00:00 0:00:05.620118 352003 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-11T19:00:13.781988+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-11T17:00:00+00:00 TriggerDagRunOperator 2023-03-11T18:11:11.355826+00:00 2023-03-11T18:11:11.867102+00:00 0:00:00.511276 351993 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-11T18:11:08.955473+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-11T17:00:00+00:00 TriggerDagRunOperator 2023-03-11T18:11:11.358421+00:00 2023-03-11T18:11:11.857785+00:00 0:00:00.499364 351992 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-11T18:11:08.955500+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-11T17:00:00+00:00 EmrJobFlowSensor 2023-03-11T18:00:48.686035+00:00 2023-03-11T18:10:50.463507+00:00 0:10:01.777472 351985 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-11T18:00:46.454465+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-11T17:00:00+00:00 EmrCreateJobFlowOperator 2023-03-11T18:00:26.617040+00:00 2023-03-11T18:00:27.509883+00:00 0:00:00.892843 351983 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-11T18:00:24.435904+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-11T17:00:00+00:00 PythonOperator 2023-03-11T18:00:04.642723+00:00 2023-03-11T18:00:07.722106+00:00 0:00:03.079383 351981 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-11T18:00:02.408434+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-11T16:00:00+00:00 TriggerDagRunOperator 2023-03-11T17:18:06.281720+00:00 2023-03-11T17:18:06.785145+00:00 0:00:00.503425 351972 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-11T17:18:03.669993+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-11T16:00:00+00:00 TriggerDagRunOperator 2023-03-11T17:18:06.152627+00:00 2023-03-11T17:18:06.607483+00:00 0:00:00.454856 351971 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-11T17:18:03.670021+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-11T16:00:00+00:00 EmrJobFlowSensor 2023-03-11T17:00:55.190879+00:00 2023-03-11T17:10:57.079884+00:00 0:10:01.889005 351963 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-11T17:00:52.737985+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-11T16:00:00+00:00 EmrCreateJobFlowOperator 2023-03-11T17:00:33.041506+00:00 2023-03-11T17:00:33.903236+00:00 0:00:00.861730 351961 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-11T17:00:30.711866+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-11T16:00:00+00:00 PythonOperator 2023-03-11T17:00:13.237808+00:00 2023-03-11T17:00:16.542997+00:00 0:00:03.305189 351959 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-11T17:00:10.628065+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-11T15:00:00+00:00 TriggerDagRunOperator 2023-03-11T16:11:09.188749+00:00 2023-03-11T16:11:09.717960+00:00 0:00:00.529211 351950 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-11T16:11:06.542891+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-11T15:00:00+00:00 TriggerDagRunOperator 2023-03-11T16:11:09.031177+00:00 2023-03-11T16:11:09.497733+00:00 0:00:00.466556 351949 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-11T16:11:06.542861+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-11T15:00:00+00:00 EmrJobFlowSensor 2023-03-11T16:00:57.223444+00:00 2023-03-11T16:10:59.057756+00:00 0:10:01.834312 351942 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-11T16:00:54.972707+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-11T15:00:00+00:00 EmrCreateJobFlowOperator 2023-03-11T16:00:37.212589+00:00 2023-03-11T16:00:38.071931+00:00 0:00:00.859342 351940 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-11T16:00:34.948791+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-11T15:00:00+00:00 PythonOperator 2023-03-11T16:00:15.275880+00:00 2023-03-11T16:00:19.210882+00:00 0:00:03.935002 351938 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-11T16:00:12.919906+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-11T14:00:00+00:00 TriggerDagRunOperator 2023-03-11T15:10:57.612302+00:00 2023-03-11T15:10:58.248964+00:00 0:00:00.636662 351931 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-11T15:10:54.858094+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-11T14:00:00+00:00 TriggerDagRunOperator 2023-03-11T15:10:57.616868+00:00 2023-03-11T15:10:58.229960+00:00 0:00:00.613092 351930 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-11T15:10:54.858123+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-11T14:00:00+00:00 EmrJobFlowSensor 2023-03-11T15:00:50.138772+00:00 2023-03-11T15:10:51.901155+00:00 0:10:01.762383 351924 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-11T15:00:47.118041+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-11T14:00:00+00:00 EmrCreateJobFlowOperator 2023-03-11T15:00:29.421348+00:00 2023-03-11T15:00:30.968504+00:00 0:00:01.547156 351922 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-11T15:00:25.095187+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-11T14:00:00+00:00 PythonOperator 2023-03-11T15:00:05.350099+00:00 2023-03-11T15:00:09.521129+00:00 0:00:04.171030 351919 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-11T15:00:02.971771+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-11T13:00:00+00:00 TriggerDagRunOperator 2023-03-11T14:20:33.984422+00:00 2023-03-11T14:20:34.477667+00:00 0:00:00.493245 351913 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-11T14:20:31.037451+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-11T13:00:00+00:00 TriggerDagRunOperator 2023-03-11T14:20:33.800207+00:00 2023-03-11T14:20:34.257866+00:00 0:00:00.457659 351912 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-11T14:20:31.037487+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-11T13:00:00+00:00 EmrJobFlowSensor 2023-03-11T14:08:44.700624+00:00 2023-03-11T14:18:46.671362+00:00 0:10:01.970738 351907 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-11T14:08:42.075080+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-11T13:00:00+00:00 EmrCreateJobFlowOperator 2023-03-11T14:08:22.267536+00:00 2023-03-11T14:08:23.165433+00:00 0:00:00.897897 351904 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-11T14:08:20.058808+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-11T13:00:00+00:00 PythonOperator 2023-03-11T14:08:01.349550+00:00 2023-03-11T14:08:08.229813+00:00 0:00:06.880263 351901 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-11T14:07:58.038817+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-11T12:00:00+00:00 TriggerDagRunOperator 2023-03-11T13:21:00.111909+00:00 2023-03-11T13:21:00.656671+00:00 0:00:00.544762 351894 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-11T13:20:56.979824+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-11T12:00:00+00:00 TriggerDagRunOperator 2023-03-11T13:20:59.916277+00:00 2023-03-11T13:21:00.485443+00:00 0:00:00.569166 351893 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-11T13:20:56.979864+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-11T12:00:00+00:00 EmrJobFlowSensor 2023-03-11T13:02:13.505869+00:00 2023-03-11T13:11:15.107625+00:00 0:09:01.601756 351886 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-11T13:02:11.113118+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-11T12:00:00+00:00 EmrCreateJobFlowOperator 2023-03-11T13:01:53.310599+00:00 2023-03-11T13:01:54.414193+00:00 0:00:01.103594 351884 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-11T13:01:51.052215+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-11T12:00:00+00:00 PythonOperator 2023-03-11T13:01:31.837751+00:00 2023-03-11T13:01:35.304923+00:00 0:00:03.467172 351882 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-11T13:01:29.032761+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-11T11:00:00+00:00 TriggerDagRunOperator 2023-03-11T12:25:02.774703+00:00 2023-03-11T12:25:03.280534+00:00 0:00:00.505831 351874 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-11T12:25:00.276286+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-11T11:00:00+00:00 TriggerDagRunOperator 2023-03-11T12:25:02.724156+00:00 2023-03-11T12:25:03.219035+00:00 0:00:00.494879 351873 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-11T12:25:00.276315+00:00 2 default_pool