rust/greptimedb
1
0
Fork 0
mirror of https://github.com/GreptimeTeam/greptimedb.git synced 2026-10-19 18:32:33 +00:00
Code Issues Packages Projects Releases Wiki Activity

test(flow): align meta unknown option status assertions

Browse Source 
Signed-off-by: discord9 <55937128+discord9@users.noreply.github.com>
This commit is contained in:
discord9
2026-10-08 18:07:15 +08:00
parent c49219b799
commit c519e27eca
1 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/common/meta/src/ddl/tests/create_flow.rs
+4 -3
View File
@@ -368,9 +368,10 @@ fn test_validate_flow_options_rejects_schedule_and_internal_keys_as_unknown() {
.insert(key.to_string(), "value".to_string());
let err = validate_flow_options(&task).unwrap_err();
assert_eq!(StatusCode::InvalidArguments, err.status_code());
assert!(
err.to_string()
.contains(&format!("Unknown flow option '{key}'")),
.contains(&format!("unknown flow option '{key}'")),
"unexpected error for {key}: {err}"
);
}
@@ -906,10 +907,10 @@ async fn test_create_flow_rejects_unknown_option_in_meta_task() {
let mut procedure = CreateFlowProcedure::new(task, query_ctx, ddl_context);
let err = procedure.on_prepare().await.unwrap_err();
assert_matches!(err, error::Error::Unexpected { .. });
assert_eq!(StatusCode::InvalidArguments, err.status_code());
assert!(
err.to_string()
.contains("Unknown flow option 'unknown_option'")
.contains("unknown flow option 'unknown_option'")
);
}