SqsSessionStatus change (enum variants in subschema have to be of the…

… same type)

mirrord/operator/src/crd.rs

@@ -446,6 +446,8 @@ pub struct QueueDetails {
     //                              |               ---- queue id
     //                              ---- ConfigMap name
 
+    // TODO: Don't save whole PodSpec, because its schema is so long you can't create the CRD with
+    //  `kubectl apply` due to a length limit.
     /// The original PodSpec of the queue consumer.
     pub original_spec: PodSpec,
 }
@@ -490,24 +492,24 @@ pub struct MirrordQueueSplitterSpec {
 #[derive(Clone, Debug, Default, Deserialize, Serialize, JsonSchema)]
 #[serde(rename = "SQSSessionDetails", rename_all = "camelCase")]
 pub struct SqsSessionDetails {
+    // TODO: Don't save whole PodSpec, because its schema is so long you can't create the CRD with
+    //  `kubectl apply` due to a length limit.
     pub spec: PodSpec,
     pub queue_names: HashMap<QueueId, QueueNameUpdate>,
 }
 
 #[derive(Clone, Debug, Default, Deserialize, Serialize, JsonSchema)]
 #[serde(rename = "SQSSessionStatus", rename_all = "camelCase")]
-pub enum SqsSessionStatus {
-    #[default]
-    Requested,
-    Started(SqsSessionDetails),
+pub struct SqsSessionStatus {
+    pub details: Option<SqsSessionDetails>,
 }
 
 /// 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| matches!(status, SqsSessionStatus::Started(..)))
+        .map(|status| status.details.is_some())
         .unwrap_or_default()
 }