From 083e599b659f806c243b739c72cf190dc33133c0 Mon Sep 17 00:00:00 2001 From: anant Date: Wed, 26 Mar 2025 18:23:26 +0530 Subject: [PATCH] bugfix for oidc --- src/handlers/http/ingest.rs | 2 +- src/handlers/http/modal/query_server.rs | 4 +++- 2 files changed, 4 insertions(+), 2 deletions(-) diff --git a/src/handlers/http/ingest.rs b/src/handlers/http/ingest.rs index 485b071a9..8a37e4c51 100644 --- a/src/handlers/http/ingest.rs +++ b/src/handlers/http/ingest.rs @@ -89,7 +89,7 @@ pub async fn ingest( }; let log_source_entry = LogSourceEntry::new(log_source.clone(), fields); - + PARSEABLE .create_stream_if_not_exists( &stream_name, diff --git a/src/handlers/http/modal/query_server.rs b/src/handlers/http/modal/query_server.rs index 161bd88f5..e0f3c7e31 100644 --- a/src/handlers/http/modal/query_server.rs +++ b/src/handlers/http/modal/query_server.rs @@ -148,7 +148,9 @@ impl ParseableServer for QueryServer { tokio::spawn(airplane::server()); - let result = self.start(shutdown_rx, prometheus.clone(), None).await; + let result = self + .start(shutdown_rx, prometheus.clone(), PARSEABLE.options.openid()) + .await; // Cancel sync jobs cancel_tx.send(()).expect("Cancellation should not fail");