diff --git a/pykube/query.py b/pykube/query.py
index 31d4b3b..5296cb4 100644
--- a/pykube/query.py
+++ b/pykube/query.py
@@ -138,6 +138,9 @@ def response(self):
         return self.query_cache["response"]
 
 
+WatchEvent = namedtuple("WatchEvent", "type object")
+
+
 class WatchQuery(BaseQuery):
 
     def __init__(self, *args, **kwargs):
@@ -158,7 +161,6 @@ def object_stream(self):
             kwargs["version"] = self.api_obj_class.version
         r = self.api.get(**kwargs)
         self.api.raise_for_status(r)
-        WatchEvent = namedtuple("WatchEvent", "type object")
         for line in r.iter_lines():
             we = json.loads(line.decode("utf-8"))
             yield WatchEvent(type=we["type"], object=self.api_obj_class(self.api, we["object"]))