From 66b828dbc532f95f462d3065b6bdcf5ca66e4bc1 Mon Sep 17 00:00:00 2001
From: "jayant.shrivastava" <jayant.shrivastava@datadoghq.com>
Date: Thu, 18 Jun 2026 18:30:35 +0000
Subject: [PATCH] fix comment on DistributedLeafExec

---
 src/execution_plans/distributed_leaf.rs | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/src/execution_plans/distributed_leaf.rs b/src/execution_plans/distributed_leaf.rs
index de148935..b9ab4d35 100644
--- a/src/execution_plans/distributed_leaf.rs
+++ b/src/execution_plans/distributed_leaf.rs
@@ -69,7 +69,8 @@ pub struct DistributedLeafExec {
 
 impl DistributedLeafExec {
     /// Builds a new [DistributedLeafExec] based on the provided original plan and its per-task
-    /// variants. Provided variants must expose the same partition count as the original plan.
+    /// variants. Every variant must expose the same schema and partition count as every other
+    /// variant.
     pub fn try_new(
         original: Arc<dyn ExecutionPlan>,
         variants: impl IntoIterator<Item = Arc<dyn ExecutionPlan>>,