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