Stabilize MCP ingress log capture test
This commit is contained in:
@@ -595,9 +595,8 @@ mod tests {
|
|||||||
.compact()
|
.compact()
|
||||||
.with_filter(LevelFilter::INFO),
|
.with_filter(LevelFilter::INFO),
|
||||||
);
|
);
|
||||||
let dispatch = tracing::Dispatch::new(subscriber);
|
|
||||||
|
|
||||||
let _guard = tracing::dispatcher::set_default(&dispatch);
|
let _ = tracing::subscriber::set_global_default(subscriber);
|
||||||
let response = post_jsonrpc_response(
|
let response = post_jsonrpc_response(
|
||||||
&client,
|
&client,
|
||||||
&mcp_url,
|
&mcp_url,
|
||||||
@@ -622,7 +621,10 @@ mod tests {
|
|||||||
assert_eq!(response.status(), reqwest::StatusCode::OK);
|
assert_eq!(response.status(), reqwest::StatusCode::OK);
|
||||||
|
|
||||||
let logs = writer.output();
|
let logs = writer.output();
|
||||||
assert!(logs.contains("mcp request received"));
|
assert!(
|
||||||
|
logs.contains("mcp request received"),
|
||||||
|
"captured logs did not include ingress marker: {logs}"
|
||||||
|
);
|
||||||
assert!(logs.contains("req_mcp_trace_123"));
|
assert!(logs.contains("req_mcp_trace_123"));
|
||||||
assert!(logs.contains("sales-request-trace"));
|
assert!(logs.contains("sales-request-trace"));
|
||||||
assert!(logs.contains("default"));
|
assert!(logs.contains("default"));
|
||||||
|
|||||||
Reference in New Issue
Block a user