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");