diff --git a/mirrord/operator/src/crd.rs b/mirrord/operator/src/crd.rs index 62bf09d054c..8c9bf18f1cc 100644 --- a/mirrord/operator/src/crd.rs +++ b/mirrord/operator/src/crd.rs @@ -504,12 +504,19 @@ pub struct SqsSessionStatus { pub details: Option, } +impl SqsSessionStatus { + pub fn is_ready(&self) -> bool { + self.details.is_some() + } +} + + /// The [`kube::runtime::wait::Condition`] trait is auto-implemented for this function. /// To be used in [`kube::runtime::wait::await_condition`]. pub fn is_session_ready(session: Option<&MirrordSqsSession>) -> bool { session .and_then(|session| session.status.as_ref()) - .map(|status| status.details.is_some()) + .map(|status| status.is_ready()) .unwrap_or_default() }