From 7ce624499c67ca756a381f6c3b81e162da0cd0a7 Mon Sep 17 00:00:00 2001
From: jamesWalczak <jakub.walczak@cmcc.it>
Date: Mon, 22 Jan 2024 12:27:52 +0100
Subject: [PATCH] Remove statis typing for streamz dataframe

---
 drivers/intake_geokube/iot/driver.py | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/drivers/intake_geokube/iot/driver.py b/drivers/intake_geokube/iot/driver.py
index ce5fca0..115be70 100644
--- a/drivers/intake_geokube/iot/driver.py
+++ b/drivers/intake_geokube/iot/driver.py
@@ -100,7 +100,7 @@ def _get_schema(self):
             self.stream.start()
         return {"stream": str(self.stream)}
 
-    def read(self) -> streamz.dataframe.DataFrame:
+    def read(self):
         """Read IoT data."""
         self.log.info("reading stream...")
         self._get_schema()
@@ -113,7 +113,7 @@ def load(self) -> NoReturn:
             "loading entire product is not supported for IoT data"
         )
 
-    def process(self, query: GeoQuery) -> streamz.dataframe.DataFrame:
+    def process(self, query: GeoQuery):
         """Process IoT data with the passed query.
 
         Parameters