diff --git a/src/query/src/options.rs b/src/query/src/options.rs index 6cb74f0305..688d6315b0 100644 --- a/src/query/src/options.rs +++ b/src/query/src/options.rs @@ -184,6 +184,10 @@ impl FlowQueryExtensions { } } +/// Returns whether raw Flow query extensions request terminal region watermark collection. +/// +/// This is only an intent/presence check for transport/scan plumbing; callers that need +/// validated Flow options must still use [`FlowQueryExtensions::parse_flow_extensions`]. pub fn should_collect_region_watermark_from_extensions( extensions: &HashMap, ) -> bool {