Skip to content

Commit 74c9357

Browse files
committed
fix(graph): validate query output column names
1 parent a02db82 commit 74c9357

File tree

1 file changed

+10
-0
lines changed
  • graph/src/amp/manifest/data_source

1 file changed

+10
-0
lines changed

graph/src/amp/manifest/data_source/raw.rs

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -408,6 +408,16 @@ impl RawTable {
408408

409409
debug!(logger, "Resolving query schema");
410410
let schema = Self::resolve_schema(logger, amp_client, &query).await?;
411+
412+
for field in schema.fields() {
413+
validate_ident(field.name()).map_err(|e| {
414+
e.source_context(format!(
415+
"invalid query output schema: invalid column '{}'",
416+
field.name()
417+
))
418+
})?;
419+
}
420+
411421
let block_range_query_builder = Self::resolve_block_range_query_builder(
412422
logger,
413423
amp_client,

0 commit comments

Comments
 (0)