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-02-28T13:00:00+00:00 EmrJobFlowSensor 2023-02-28T14:03:56.097678+00:00 2023-02-28T14:13:58.401598+00:00 0:10:02.303920 346457 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-28T14:03:52.642511+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-28T13:00:00+00:00 EmrCreateJobFlowOperator 2023-02-28T14:03:32.883347+00:00 2023-02-28T14:03:33.761439+00:00 0:00:00.878092 346455 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-28T14:03:30.589951+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-28T13:00:00+00:00 PythonOperator 2023-02-28T14:03:11.344763+00:00 2023-02-28T14:03:15.309875+00:00 0:00:03.965112 346453 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-28T14:03:08.574762+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-28T12:00:00+00:00 TriggerDagRunOperator 2023-02-28T13:15:30.461562+00:00 2023-02-28T13:15:31.058983+00:00 0:00:00.597421 346447 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-28T13:15:27.648781+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-28T12:00:00+00:00 TriggerDagRunOperator 2023-02-28T13:15:30.279070+00:00 2023-02-28T13:15:30.778184+00:00 0:00:00.499114 346446 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-28T13:15:27.648751+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-28T12:00:00+00:00 EmrJobFlowSensor 2023-02-28T13:03:04.272822+00:00 2023-02-28T13:13:06.093481+00:00 0:10:01.820659 346440 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-28T13:03:02.087538+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-28T12:00:00+00:00 EmrCreateJobFlowOperator 2023-02-28T13:02:42.385082+00:00 2023-02-28T13:02:43.195025+00:00 0:00:00.809943 346438 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-28T13:02:40.068190+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-28T12:00:00+00:00 PythonOperator 2023-02-28T13:02:20.365263+00:00 2023-02-28T13:02:23.316272+00:00 0:00:02.951009 346436 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-28T13:02:18.049405+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-28T11:00:00+00:00 TriggerDagRunOperator 2023-02-28T12:11:11.409526+00:00 2023-02-28T12:11:11.881854+00:00 0:00:00.472328 346427 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-28T12:11:08.606933+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-28T11:00:00+00:00 TriggerDagRunOperator 2023-02-28T12:11:11.316136+00:00 2023-02-28T12:11:11.797480+00:00 0:00:00.481344 346426 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-28T12:11:08.606997+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-28T11:00:00+00:00 EmrJobFlowSensor 2023-02-28T12:00:53.244444+00:00 2023-02-28T12:10:55.320516+00:00 0:10:02.076072 346419 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-28T12:00:47.301448+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-28T11:00:00+00:00 EmrCreateJobFlowOperator 2023-02-28T12:00:27.609016+00:00 2023-02-28T12:00:28.453028+00:00 0:00:00.844012 346417 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-28T12:00:25.214789+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-28T11:00:00+00:00 PythonOperator 2023-02-28T12:00:05.758740+00:00 2023-02-28T12:00:08.691034+00:00 0:00:02.932294 346415 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-28T12:00:03.173608+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-28T10:00:00+00:00 TriggerDagRunOperator 2023-02-28T11:18:35.682406+00:00 2023-02-28T11:18:36.207701+00:00 0:00:00.525295 346408 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-28T11:18:32.546260+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-28T10:00:00+00:00 TriggerDagRunOperator 2023-02-28T11:18:35.433674+00:00 2023-02-28T11:18:35.895838+00:00 0:00:00.462164 346407 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-28T11:18:32.546230+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-28T10:00:00+00:00 EmrJobFlowSensor 2023-02-28T11:01:22.324612+00:00 2023-02-28T11:11:24.169575+00:00 0:10:01.844963 346401 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-28T11:01:19.875434+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-28T10:00:00+00:00 EmrCreateJobFlowOperator 2023-02-28T11:01:00.191833+00:00 2023-02-28T11:01:01.111688+00:00 0:00:00.919855 346399 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-28T11:00:57.855762+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-28T10:00:00+00:00 PythonOperator 2023-02-28T11:00:40.071510+00:00 2023-02-28T11:00:44.042827+00:00 0:00:03.971317 346397 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-28T11:00:37.836008+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-28T09:00:00+00:00 TriggerDagRunOperator 2023-02-28T10:27:39.357815+00:00 2023-02-28T10:27:39.832125+00:00 0:00:00.474310 346388 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-28T10:27:36.615775+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-28T09:00:00+00:00 TriggerDagRunOperator 2023-02-28T10:27:39.218455+00:00 2023-02-28T10:27:39.678917+00:00 0:00:00.460462 346387 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-28T10:27:36.615745+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-28T09:00:00+00:00 EmrJobFlowSensor 2023-02-28T10:17:32.348955+00:00 2023-02-28T10:27:33.961871+00:00 0:10:01.612916 346382 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-28T10:17:30.128247+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-28T09:00:00+00:00 EmrCreateJobFlowOperator 2023-02-28T10:17:10.272693+00:00 2023-02-28T10:17:11.186311+00:00 0:00:00.913618 346379 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-28T10:17:08.063112+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-28T09:00:00+00:00 PythonOperator 2023-02-28T10:16:50.898466+00:00 2023-02-28T10:16:54.545620+00:00 0:00:03.647154 346377 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-28T10:16:48.049430+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-28T08:00:00+00:00 TriggerDagRunOperator 2023-02-28T09:11:24.565688+00:00 2023-02-28T09:11:25.071460+00:00 0:00:00.505772 346368 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-28T09:11:21.795819+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-28T08:00:00+00:00 TriggerDagRunOperator 2023-02-28T09:11:24.200676+00:00 2023-02-28T09:11:24.695200+00:00 0:00:00.494524 346367 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-28T09:11:21.795847+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-28T08:00:00+00:00 EmrJobFlowSensor 2023-02-28T09:01:04.588804+00:00 2023-02-28T09:11:06.582502+00:00 0:10:01.993698 346360 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-28T09:01:01.287598+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-28T08:00:00+00:00 EmrCreateJobFlowOperator 2023-02-28T09:00:41.586781+00:00 2023-02-28T09:00:42.540858+00:00 0:00:00.954077 346358 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-28T09:00:39.206010+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-28T08:00:00+00:00 PythonOperator 2023-02-28T09:00:17.605451+00:00 2023-02-28T09:00:20.544630+00:00 0:00:02.939179 346356 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-28T09:00:15.198471+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-28T07:00:00+00:00 TriggerDagRunOperator 2023-02-28T08:12:01.222378+00:00 2023-02-28T08:12:01.728469+00:00 0:00:00.506091 346349 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-28T08:11:58.244689+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-28T07:00:00+00:00 TriggerDagRunOperator 2023-02-28T08:12:01.078081+00:00 2023-02-28T08:12:01.565750+00:00 0:00:00.487669 346348 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-28T08:11:58.244659+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-28T07:00:00+00:00 EmrJobFlowSensor 2023-02-28T08:00:57.587762+00:00 2023-02-28T08:10:59.309741+00:00 0:10:01.721979 346341 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-28T08:00:55.245575+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-28T07:00:00+00:00 EmrCreateJobFlowOperator 2023-02-28T08:00:37.870204+00:00 2023-02-28T08:00:39.047494+00:00 0:00:01.177290 346339 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-28T08:00:33.223786+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-28T07:00:00+00:00 PythonOperator 2023-02-28T08:00:15.679967+00:00 2023-02-28T08:00:20.087319+00:00 0:00:04.407352 346337 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-28T08:00:13.222186+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-28T06:00:00+00:00 TriggerDagRunOperator 2023-02-28T07:11:20.319252+00:00 2023-02-28T07:11:20.784795+00:00 0:00:00.465543 346327 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-28T07:11:17.613381+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-28T06:00:00+00:00 TriggerDagRunOperator 2023-02-28T07:11:19.905696+00:00 2023-02-28T07:11:20.529566+00:00 0:00:00.623870 346326 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-28T07:11:17.613410+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-28T06:00:00+00:00 EmrJobFlowSensor 2023-02-28T07:01:05.021211+00:00 2023-02-28T07:11:06.817606+00:00 0:10:01.796395 346320 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-28T07:01:02.607107+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-28T06:00:00+00:00 EmrCreateJobFlowOperator 2023-02-28T07:00:43.069708+00:00 2023-02-28T07:00:44.026715+00:00 0:00:00.957007 346318 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-28T07:00:40.577371+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-28T06:00:00+00:00 PythonOperator 2023-02-28T07:00:22.800190+00:00 2023-02-28T07:00:26.198102+00:00 0:00:03.397912 346316 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-28T07:00:20.556110+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-28T05:00:00+00:00 TriggerDagRunOperator 2023-02-28T06:28:41.585531+00:00 2023-02-28T06:28:42.214874+00:00 0:00:00.629343 346308 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-28T06:28:38.349182+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-28T05:00:00+00:00 TriggerDagRunOperator 2023-02-28T06:28:41.315659+00:00 2023-02-28T06:28:42.014662+00:00 0:00:00.699003 346307 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-28T06:28:38.349218+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-28T05:00:00+00:00 EmrJobFlowSensor 2023-02-28T06:03:28.573943+00:00 2023-02-28T06:13:30.400715+00:00 0:10:01.826772 346300 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-28T06:03:26.252498+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-28T05:00:00+00:00 EmrCreateJobFlowOperator 2023-02-28T06:03:08.486041+00:00 2023-02-28T06:03:09.346840+00:00 0:00:00.860799 346298 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-28T06:03:06.237159+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-28T05:00:00+00:00 PythonOperator 2023-02-28T06:02:47.347815+00:00 2023-02-28T06:02:51.313956+00:00 0:00:03.966141 346296 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-28T06:02:44.244916+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-28T04:00:00+00:00 TriggerDagRunOperator 2023-02-28T05:36:44.127748+00:00 2023-02-28T05:36:45.242499+00:00 0:00:01.114751 346289 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-28T05:36:40.754975+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-28T04:00:00+00:00 TriggerDagRunOperator 2023-02-28T05:36:44.054140+00:00 2023-02-28T05:36:44.967280+00:00 0:00:00.913140 346288 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-28T05:36:40.754911+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-28T04:00:00+00:00 EmrJobFlowSensor 2023-02-28T05:16:51.980960+00:00 2023-02-28T05:26:53.752111+00:00 0:10:01.771151 346284 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-28T05:16:49.728457+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-28T04:00:00+00:00 EmrCreateJobFlowOperator 2023-02-28T05:16:31.908293+00:00 2023-02-28T05:16:32.769749+00:00 0:00:00.861456 346280 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-28T05:16:29.669139+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-28T03:00:00+00:00 TriggerDagRunOperator 2023-02-28T05:16:13.660550+00:00 2023-02-28T05:16:14.353720+00:00 0:00:00.693170 346276 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-28T05:16:07.646414+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-28T04:00:00+00:00 PythonOperator 2023-02-28T05:16:13.611601+00:00 2023-02-28T05:16:17.766615+00:00 0:00:04.155014 346275 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-28T05:16:07.646462+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-28T03:00:00+00:00 TriggerDagRunOperator 2023-02-28T05:16:09.928566+00:00 2023-02-28T05:16:10.392064+00:00 0:00:00.463498 346274 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-28T05:16:07.646448+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-28T03:00:00+00:00 EmrJobFlowSensor 2023-02-28T04:37:23.649944+00:00 2023-02-28T04:47:25.483221+00:00 0:10:01.833277 346268 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-28T04:37:21.332270+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-28T03:00:00+00:00 EmrCreateJobFlowOperator 2023-02-28T04:37:04.062882+00:00 2023-02-28T04:37:05.150640+00:00 0:00:01.087758 346265 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-28T04:37:01.297396+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-28T03:00:00+00:00 PythonOperator 2023-02-28T04:36:41.609208+00:00 2023-02-28T04:36:45.616483+00:00 0:00:04.007275 346261 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-28T04:36:39.205585+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-28T02:00:00+00:00 TriggerDagRunOperator 2023-02-28T03:55:43.378222+00:00 2023-02-28T03:55:44.076858+00:00 0:00:00.698636 346256 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-28T03:55:40.230890+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-28T02:00:00+00:00 TriggerDagRunOperator 2023-02-28T03:55:43.291001+00:00 2023-02-28T03:55:43.882757+00:00 0:00:00.591756 346255 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-28T03:55:40.230925+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-28T02:00:00+00:00 EmrJobFlowSensor 2023-02-28T03:32:08.674200+00:00 2023-02-28T03:42:10.383524+00:00 0:10:01.709324 346252 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-28T03:32:06.278561+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-28T02:00:00+00:00 EmrCreateJobFlowOperator 2023-02-28T03:31:46.867911+00:00 2023-02-28T03:31:47.733102+00:00 0:00:00.865191 346248 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-28T03:31:44.301603+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-28T02:00:00+00:00 PythonOperator 2023-02-28T03:25:39.015708+00:00 2023-02-28T03:25:52.896781+00:00 0:00:13.881073 346241 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-28T03:25:27.995722+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-28T01:00:00+00:00 TriggerDagRunOperator 2023-02-28T03:25:38.104474+00:00 2023-02-28T03:25:40.497335+00:00 0:00:02.392861 346240 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-28T03:25:27.995709+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-28T01:00:00+00:00 TriggerDagRunOperator 2023-02-28T03:25:30.378758+00:00 2023-02-28T03:25:30.813187+00:00 0:00:00.434429 346239 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-28T03:25:27.995680+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-28T01:00:00+00:00 EmrJobFlowSensor 2023-02-28T02:37:38.699849+00:00 2023-02-28T02:47:40.460451+00:00 0:10:01.760602 346235 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-28T02:37:35.863017+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-28T01:00:00+00:00 EmrCreateJobFlowOperator 2023-02-28T02:37:20.357984+00:00 2023-02-28T02:37:21.666649+00:00 0:00:01.308665 346232 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-28T02:37:13.846034+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-28T01:00:00+00:00 PythonOperator 2023-02-28T02:36:58.545959+00:00 2023-02-28T02:37:01.992328+00:00 0:00:03.446369 346229 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-28T02:36:53.756437+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-28T00:00:00+00:00 TriggerDagRunOperator 2023-02-28T01:50:20.300778+00:00 2023-02-28T01:50:21.204299+00:00 0:00:00.903521 346218 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-28T01:50:17.605806+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-28T00:00:00+00:00 TriggerDagRunOperator 2023-02-28T01:50:19.821757+00:00 2023-02-28T01:50:20.390104+00:00 0:00:00.568347 346217 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-28T01:50:17.605838+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-28T00:00:00+00:00 EmrJobFlowSensor 2023-02-28T01:49:56.211254+00:00 2023-02-28T01:49:56.785405+00:00 0:00:00.574151 346213 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-28T01:49:53.591502+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-28T00:00:00+00:00 EmrCreateJobFlowOperator 2023-02-28T01:24:44.907988+00:00 2023-02-28T01:24:45.875719+00:00 0:00:00.967731 346205 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-28T01:24:41.274872+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-28T00:00:00+00:00 PythonOperator 2023-02-28T01:24:23.426246+00:00 2023-02-28T01:24:27.325046+00:00 0:00:03.898800 346201 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-28T01:24:21.251908+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-27T22:00:00+00:00 TriggerDagRunOperator 2023-02-27T23:19:16.274571+00:00 2023-02-27T23:19:16.760992+00:00 0:00:00.486421 346194 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-27T23:19:13.432851+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-27T22:00:00+00:00 TriggerDagRunOperator 2023-02-27T23:19:16.024266+00:00 2023-02-27T23:19:16.497024+00:00 0:00:00.472758 346193 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-27T23:19:13.432899+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-27T22:00:00+00:00 EmrJobFlowSensor 2023-02-27T23:06:32.491283+00:00 2023-02-27T23:16:34.629884+00:00 0:10:02.138601 346187 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-27T23:06:29.867047+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-27T22:00:00+00:00 EmrCreateJobFlowOperator 2023-02-27T23:06:12.516563+00:00 2023-02-27T23:06:13.923855+00:00 0:00:01.407292 346184 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-27T23:06:09.854238+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-27T22:00:00+00:00 PythonOperator 2023-02-27T23:05:50.496508+00:00 2023-02-27T23:05:54.434405+00:00 0:00:03.937897 346179 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-27T23:05:47.830570+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-27T21:00:00+00:00 TriggerDagRunOperator 2023-02-27T22:11:16.414174+00:00 2023-02-27T22:11:16.916495+00:00 0:00:00.502321 346170 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-27T22:11:13.295351+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-27T21:00:00+00:00 TriggerDagRunOperator 2023-02-27T22:11:16.294598+00:00 2023-02-27T22:11:16.754168+00:00 0:00:00.459570 346169 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-27T22:11:13.295305+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-27T21:00:00+00:00 EmrJobFlowSensor 2023-02-27T22:01:52.041044+00:00 2023-02-27T22:10:53.833744+00:00 0:09:01.792700 346163 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-27T22:01:49.560058+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-27T21:00:00+00:00 EmrCreateJobFlowOperator 2023-02-27T22:01:30.414461+00:00 2023-02-27T22:01:31.441883+00:00 0:00:01.027422 346162 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-27T22:01:27.542108+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-27T21:00:00+00:00 PythonOperator 2023-02-27T22:00:12.662084+00:00 2023-02-27T22:00:15.830072+00:00 0:00:03.167988 346158 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-27T22:00:10.432270+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-27T20:00:00+00:00 TriggerDagRunOperator 2023-02-27T21:16:26.556104+00:00 2023-02-27T21:16:27.082281+00:00 0:00:00.526177 346148 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-27T21:16:23.724725+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-27T20:00:00+00:00 TriggerDagRunOperator 2023-02-27T21:16:26.356766+00:00 2023-02-27T21:16:26.855915+00:00 0:00:00.499149 346147 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-27T21:16:23.724697+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-27T20:00:00+00:00 EmrJobFlowSensor 2023-02-27T21:01:02.281841+00:00 2023-02-27T21:11:04.115986+00:00 0:10:01.834145 346140 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-27T21:00:59.851086+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-27T20:00:00+00:00 EmrCreateJobFlowOperator 2023-02-27T21:00:40.075882+00:00 2023-02-27T21:00:41.003338+00:00 0:00:00.927456 346137 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-27T21:00:37.829193+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-27T20:00:00+00:00 PythonOperator 2023-02-27T21:00:18.647400+00:00 2023-02-27T21:00:21.811590+00:00 0:00:03.164190 346136 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-27T21:00:15.827095+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-27T19:00:00+00:00 TriggerDagRunOperator 2023-02-27T20:11:09.336572+00:00 2023-02-27T20:11:09.804480+00:00 0:00:00.467908 346124 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-27T20:11:07.061852+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-27T19:00:00+00:00 TriggerDagRunOperator 2023-02-27T20:11:09.223261+00:00 2023-02-27T20:11:09.736141+00:00 0:00:00.512880 346123 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-27T20:11:07.061882+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-27T19:00:00+00:00 EmrJobFlowSensor 2023-02-27T20:00:51.140900+00:00 2023-02-27T20:10:52.908440+00:00 0:10:01.767540 346118 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-27T20:00:48.513770+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-27T19:00:00+00:00 EmrCreateJobFlowOperator 2023-02-27T20:00:32.495309+00:00 2023-02-27T20:00:33.692255+00:00 0:00:01.196946 346116 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-27T20:00:28.408417+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-27T19:00:00+00:00 PythonOperator 2023-02-27T20:00:08.671435+00:00 2023-02-27T20:00:11.855935+00:00 0:00:03.184500 346114 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-27T20:00:06.387309+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-27T18:00:00+00:00 TriggerDagRunOperator 2023-02-27T19:11:01.573467+00:00 2023-02-27T19:11:02.113514+00:00 0:00:00.540047 346104 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-27T19:10:59.126386+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-27T18:00:00+00:00 TriggerDagRunOperator 2023-02-27T19:11:01.392765+00:00 2023-02-27T19:11:01.866038+00:00 0:00:00.473273 346103 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-27T19:10:59.126420+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-27T18:00:00+00:00 EmrJobFlowSensor 2023-02-27T19:07:51.748380+00:00 2023-02-27T19:10:52.707319+00:00 0:03:00.958939 346097 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-27T19:07:48.825603+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-27T18:00:00+00:00 EmrCreateJobFlowOperator 2023-02-27T19:00:32.456296+00:00 2023-02-27T19:00:33.305781+00:00 0:00:00.849485 346095 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-27T19:00:30.000962+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-27T18:00:00+00:00 PythonOperator 2023-02-27T19:00:12.392136+00:00 2023-02-27T19:00:16.294526+00:00 0:00:03.902390 346093 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-27T19:00:09.991783+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-27T17:00:00+00:00 TriggerDagRunOperator 2023-02-27T18:11:07.346310+00:00 2023-02-27T18:11:07.828856+00:00 0:00:00.482546 346084 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-27T18:11:05.057699+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-27T17:00:00+00:00 TriggerDagRunOperator 2023-02-27T18:11:07.249877+00:00 2023-02-27T18:11:07.741312+00:00 0:00:00.491435 346083 airflow-worker-2.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-27T18:11:05.057667+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-27T17:00:00+00:00 EmrJobFlowSensor 2023-02-27T18:00:55.536018+00:00 2023-02-27T18:10:57.369714+00:00 0:10:01.833696 346074 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-27T18:00:53.321780+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-27T17:00:00+00:00 EmrCreateJobFlowOperator 2023-02-27T18:00:33.469734+00:00 2023-02-27T18:00:34.301347+00:00 0:00:00.831613 346073 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-27T18:00:31.299501+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-27T17:00:00+00:00 PythonOperator 2023-02-27T18:00:11.428101+00:00 2023-02-27T18:00:14.607685+00:00 0:00:03.179584 346072 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-27T18:00:09.234935+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-27T16:00:00+00:00 TriggerDagRunOperator 2023-02-27T17:11:18.211169+00:00 2023-02-27T17:11:18.730303+00:00 0:00:00.519134 346062 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-27T17:11:15.786490+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-27T16:00:00+00:00 TriggerDagRunOperator 2023-02-27T17:11:18.041718+00:00 2023-02-27T17:11:18.494920+00:00 0:00:00.453202 346061 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-27T17:11:15.786462+00:00 2 default_pool