From 266e1ff78c60e113318d3f34cb36d3b52ea4202e Mon Sep 17 00:00:00 2001 From: Paul Dix Date: Thu, 23 Jan 2025 14:53:44 -0800 Subject: [PATCH] fix: fix pugin code that broke main (#25909) --- influxdb3_processing_engine/src/lib.rs | 5 +++++ influxdb3_processing_engine/src/plugins.rs | 3 +-- 2 files changed, 6 insertions(+), 2 deletions(-) diff --git a/influxdb3_processing_engine/src/lib.rs b/influxdb3_processing_engine/src/lib.rs index 733f1ebaca..55dd0325cb 100644 --- a/influxdb3_processing_engine/src/lib.rs +++ b/influxdb3_processing_engine/src/lib.rs @@ -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 { 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), 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<()>), diff --git a/influxdb3_processing_engine/src/plugins.rs b/influxdb3_processing_engine/src/plugins.rs index cc19d7a6f7..3ead73fd0f 100644 --- a/influxdb3_processing_engine/src/plugins.rs +++ b/influxdb3_processing_engine/src/plugins.rs @@ -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;