Influxdata
/
influxdb
mirror of https://github.com/influxdata/influxdb.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

fix: fix pugin code that broke main (#25909)

pull/25910/head
Paul Dix 2025-01-23 14:53:44 -08:00 committed by GitHub
parent c672ee8d1f
commit 266e1ff78c
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
influxdb3_processing_engine/src/lib.rs
View File

@ -147,6 +147,7 @@ impl PluginChannels {
rx
}
#[cfg(feature = "system-py")]
fn add_schedule_trigger(
&mut self,
db: String,
@ -160,6 +161,7 @@ impl PluginChannels {
rx
}
#[cfg(feature = "system-py")]
fn add_request_trigger(&mut self, path: String) -> mpsc::Receiver<RequestEvent> {
let (tx, rx) = mpsc::channel(PLUGIN_EVENT_BUFFER_SIZE);
self.request_triggers.insert(path, tx);
@ -803,15 +805,18 @@ impl WalFileNotifier for ProcessingEngineManagerImpl {
}
}
#[allow(dead_code)]
pub(crate) enum WalEvent {
WriteWalContents(Arc<WalContents>),
Shutdown(oneshot::Sender<()>),
}
#[allow(dead_code)]
pub(crate) enum ScheduleEvent {
Shutdown(oneshot::Sender<()>),
}
#[allow(dead_code)]
pub(crate) enum RequestEvent {
Request(Request),
Shutdown(oneshot::Sender<()>),

3
influxdb3_processing_engine/src/plugins.rs
View File

@ -1,7 +1,7 @@
#[cfg(feature = "system-py")]
use crate::PluginCode;
use crate::{RequestEvent, ScheduleEvent, WalEvent};
#[cfg(feature = "system-py")]
use crate::{RequestEvent, ScheduleEvent, WalEvent};
use data_types::NamespaceName;
use hashbrown::HashMap;
use influxdb3_catalog::catalog::Catalog;
@ -757,7 +757,6 @@ pub(crate) fn run_test_schedule_plugin(
#[cfg(test)]
mod tests {
use super::*;
use data_types::NamespaceName;
use hashbrown::HashMap;
use influxdb3_catalog::catalog::Catalog;
use influxdb3_internal_api::query_executor::UnimplementedQueryExecutor;