diff --git a/crates/nodata/src/dagger_engine.rs b/crates/nodata/src/dagger_engine.rs
index 8703ac2..ca3b47b 100644
--- a/crates/nodata/src/dagger_engine.rs
+++ b/crates/nodata/src/dagger_engine.rs
@@ -1,7 +1,7 @@
 use std::sync::Arc;
 
 use anyhow::Context;
-use dagger_sdk::{PortForward, ServiceEndpointOpts, ServiceUpOpts};
+use dagger_sdk::{PortForward, ServiceUpOpts};
 use tokio::net::TcpListener;
 use tokio_util::sync::CancellationToken;
 
diff --git a/crates/nodata/src/main.rs b/crates/nodata/src/main.rs
index bf000d2..0187826 100644
--- a/crates/nodata/src/main.rs
+++ b/crates/nodata/src/main.rs
@@ -92,8 +92,6 @@ async fn main() -> anyhow::Result<()> {
             ClientCommands::PublishEvent { topic, value } => {
                 let mut client = create_client(grpc_host).await?;
 
-                let timestamp = chrono::Utc::now();
-
                 let _ = client
                     .publish_event(PublishEventRequest {
                         topic,
diff --git a/crates/nodata/src/services/handler.rs b/crates/nodata/src/services/handler.rs
index b3ecf34..96061ca 100644
--- a/crates/nodata/src/services/handler.rs
+++ b/crates/nodata/src/services/handler.rs
@@ -1,7 +1,7 @@
 use crate::state::SharedState;
 
 use super::{
-    consumers::{Consumer, PartitionKey, Topic, TopicOffset},
+    consumers::{Consumer, Topic, TopicOffset},
     staging::Staging,
 };
 
diff --git a/crates/nodata/src/services/staging.rs b/crates/nodata/src/services/staging.rs
index f10b4c2..94415b5 100644
--- a/crates/nodata/src/services/staging.rs
+++ b/crates/nodata/src/services/staging.rs
@@ -4,7 +4,7 @@ use tokio::sync::RwLock;
 
 use crate::state::SharedState;
 
-use super::consumers::{PartitionKey, Topic, TopicOffset};
+use super::consumers::{Topic, TopicOffset};
 
 #[derive(Clone, Debug, PartialEq, Eq)]
 pub struct StagingEvent {