diff --git a/rust/operator-binary/src/listener_controller.rs b/rust/operator-binary/src/listener_controller.rs index ae1ef986..44505e18 100644 --- a/rust/operator-binary/src/listener_controller.rs +++ b/rust/operator-binary/src/listener_controller.rs @@ -1,4 +1,5 @@ -use crate::utils::node_primary_address; +use std::{collections::BTreeMap, sync::Arc}; + use futures::{future::try_join_all, StreamExt}; use snafu::{OptionExt, ResultExt, Snafu}; use stackable_operator::{ @@ -13,10 +14,12 @@ use stackable_operator::{ runtime::{controller, reflector::ObjectRef, watcher}, }, logging::controller::{report_controller_reconciled, ReconcilerError}, + time::Duration, }; -use std::{collections::BTreeMap, sync::Arc, time::Duration}; use strum::IntoStaticStr; +use crate::utils::node_primary_address; + #[cfg(doc)] use stackable_operator::k8s_openapi::api::core::v1::Pod; @@ -316,7 +319,7 @@ pub async fn reconcile(listener: Arc, ctx: Arc) -> Result(_obj: Arc, _error: &Error, _ctx: Arc) -> controller::Action { - controller::Action::requeue(Duration::from_secs(5)) + controller::Action::requeue(*Duration::from_secs(5)) } #[derive(Snafu, Debug)]