diff --git a/src/connection.rs b/src/connection.rs
index 2fa8eee..e2e3e0f 100644
--- a/src/connection.rs
+++ b/src/connection.rs
@@ -59,10 +59,8 @@ struct PointWriteTarget {
     external_id: String,
 }
 
-struct PollPointInfo {
+pub struct PollPointInfo {
     handle: JoinHandle<()>,
-    external_id: String,
-    interval_s: i32,
 }
 
 #[derive(Debug, Clone, serde::Serialize, serde::Deserialize)]
@@ -325,11 +323,7 @@ impl ConnectionManager {
             if let Some(conn_status) = status.get_mut(&source_id) {
                 conn_status.poll_points.insert(
                     point_id,
-                    PollPointInfo {
-                        handle,
-                        external_id: point.external_id.clone(),
-                        interval_s: point.scan_interval_s,
-                    },
+                    PollPointInfo { handle },
                 );
             }
         }
@@ -670,7 +664,7 @@ impl ConnectionManager {
             let source_connected = self
                 .get_status(*source_id)
                 .await
-                .map(|s| s.is_connected && s.session.is_some())
+                .map(|s| s.is_connected)
                 .unwrap_or(false);
             if !source_connected {
                 return Ok(Self::write_value_batch_result(