From 3e5a3d7d918c19efe7d7f7d24d387158cfbccb05 Mon Sep 17 00:00:00 2001
From: haixuanTao <tao.xavier@outlook.com>
Date: Wed, 4 Dec 2024 16:50:07 +0100
Subject: [PATCH] Fix NON_INPUT_EVENT

---
 apis/rust/node/src/event_stream/mod.rs       | 3 +--
 apis/rust/node/src/event_stream/scheduler.rs | 2 +-
 2 files changed, 2 insertions(+), 3 deletions(-)

diff --git a/apis/rust/node/src/event_stream/mod.rs b/apis/rust/node/src/event_stream/mod.rs
index 713b05b8..a82d9aeb 100644
--- a/apis/rust/node/src/event_stream/mod.rs
+++ b/apis/rust/node/src/event_stream/mod.rs
@@ -16,7 +16,7 @@ use futures::{
     Stream, StreamExt,
 };
 use futures_timer::Delay;
-use scheduler::Scheduler;
+use scheduler::{Scheduler, NON_INPUT_EVENT};
 
 use self::{
     event::SharedMemoryData,
@@ -25,7 +25,6 @@ use self::{
 use crate::daemon_connection::DaemonChannel;
 use dora_core::{
     config::{Input, NodeId},
-    topics::NON_INPUT_EVENT,
     uhlc,
 };
 use eyre::{eyre, Context};
diff --git a/apis/rust/node/src/event_stream/scheduler.rs b/apis/rust/node/src/event_stream/scheduler.rs
index 27a4d460..c6e15abe 100644
--- a/apis/rust/node/src/event_stream/scheduler.rs
+++ b/apis/rust/node/src/event_stream/scheduler.rs
@@ -1,9 +1,9 @@
 use std::collections::{HashMap, VecDeque};
 
-use dora_core::topics::NON_INPUT_EVENT;
 use dora_message::{daemon_to_node::NodeEvent, id::DataId};
 
 use super::thread::EventItem;
+pub const NON_INPUT_EVENT: &str = "dora/non_input_event";
 
 // This scheduler will make sure that there is fairness between
 // inputs.