diff --git a/acto/kubernetes_engine/kind.py b/acto/kubernetes_engine/kind.py
index 4c85c22a1..35ddb7009 100644
--- a/acto/kubernetes_engine/kind.py
+++ b/acto/kubernetes_engine/kind.py
@@ -173,7 +173,7 @@ def get_node_list(self, name: str):
 
         return res
 
-    def stream_control_plane_stats(self, cluster_name: str) -> Generator[Dict]:
+    def stream_control_plane_stats(self, cluster_name: str) -> Iterator[Dict]:
         '''Get stats of a node
         Args:
             - cluster_name: name of the cluster