diff --git a/src/base/json_schema.rs b/src/base/json_schema.rs
index ae5a3995e..9cad4ad54 100644
--- a/src/base/json_schema.rs
+++ b/src/base/json_schema.rs
@@ -225,7 +225,7 @@ impl JsonSchemaBuilder {
             required: struct_schema
                 .fields
                 .iter()
-                .filter(|&f| (self.options.fields_always_required || !f.value_type.nullable))
+                .filter(|&f| self.options.fields_always_required || !f.value_type.nullable)
                 .map(|f| f.name.to_string())
                 .collect(),
             additional_properties: Some(Schema::Bool(false).into()),
diff --git a/src/base/spec.rs b/src/base/spec.rs
index 1ba9ffe7d..ed55d3458 100644
--- a/src/base/spec.rs
+++ b/src/base/spec.rs
@@ -123,12 +123,6 @@ impl fmt::Display for ConstantMapping {
     }
 }
 
-#[derive(Debug, Clone, Serialize, Deserialize)]
-pub struct CollectionMapping {
-    pub field: FieldMapping,
-    pub scope_name: ScopeName,
-}
-
 #[derive(Debug, Clone, Serialize, Deserialize)]
 pub struct StructMapping {
     pub fields: Vec<NamedSpec<ValueMapping>>,
@@ -522,15 +516,6 @@ pub struct TransientFlowSpec {
     pub output_value: ValueMapping,
 }
 
-#[derive(Debug, Clone, Serialize, Deserialize)]
-pub struct SimpleSemanticsQueryHandlerSpec {
-    pub name: String,
-    pub flow_instance_name: String,
-    pub export_target_name: String,
-    pub query_transform_flow: TransientFlowSpec,
-    pub default_similarity_metric: VectorSimilarityMetric,
-}
-
 pub struct AuthEntryReference<T> {
     pub key: String,
     _phantom: std::marker::PhantomData<T>,
diff --git a/src/ops/targets/qdrant.rs b/src/ops/targets/qdrant.rs
index cb54e3434..96e943002 100644
--- a/src/ops/targets/qdrant.rs
+++ b/src/ops/targets/qdrant.rs
@@ -1,8 +1,6 @@
 use crate::ops::sdk::*;
 use crate::prelude::*;
 
-use std::fmt::Display;
-
 use crate::ops::registry::ExecutorFactoryRegistry;
 use crate::setup;
 use qdrant_client::Qdrant;
@@ -351,18 +349,6 @@ struct Factory {
     qdrant_clients: Mutex<HashMap<Option<spec::AuthEntryReference<ConnectionSpec>>, Arc<Qdrant>>>,
 }
 
-#[derive(Debug, Clone, Serialize, Deserialize, PartialEq, Eq, Hash)]
-struct CollectionId {
-    collection_name: String,
-}
-
-impl Display for CollectionId {
-    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
-        write!(f, "{}", self.collection_name)?;
-        Ok(())
-    }
-}
-
 #[async_trait]
 impl TargetFactoryBase for Factory {
     type Spec = Spec;