Skip to content

Commit 783ed99

Browse files
committed
fix(graph): validate query output column names
1 parent b3e9b53 commit 783ed99

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
@@ -404,6 +404,16 @@ impl RawTable {
404404

405405
debug!(logger, "Resolving query schema");
406406
let schema = Self::resolve_schema(logger, amp_client, &query).await?;
407+
408+
for field in schema.fields() {
409+
validate_ident(field.name()).map_err(|e| {
410+
e.source_context(format!(
411+
"invalid query output schema: invalid column '{}'",
412+
field.name()
413+
))
414+
})?;
415+
}
416+
407417
let block_range_query_builder = Self::resolve_block_range_query_builder(
408418
logger,
409419
amp_client,

0 commit comments

Comments
 (0)