We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 474dcd2 commit af096e4Copy full SHA for af096e4
src/handlers/http/ingest.rs
@@ -89,7 +89,7 @@ pub async fn ingest(
89
};
90
91
let log_source_entry = LogSourceEntry::new(log_source.clone(), fields);
92
-
+
93
PARSEABLE
94
.create_stream_if_not_exists(
95
&stream_name,
src/handlers/http/modal/query_server.rs
@@ -148,7 +148,9 @@ impl ParseableServer for QueryServer {
148
149
tokio::spawn(airplane::server());
150
151
- let result = self.start(shutdown_rx, prometheus.clone(), None).await;
+ let result = self
152
+ .start(shutdown_rx, prometheus.clone(), PARSEABLE.options.openid())
153
+ .await;
154
// Cancel sync jobs
155
cancel_tx.send(()).expect("Cancellation should not fail");
156
0 commit comments