From 8b572347c1e2555a2b6d8b3f192811e6dab540a1 Mon Sep 17 00:00:00 2001 From: DrAuYueng Date: Sat, 20 Jun 2020 11:50:28 +0800 Subject: [PATCH] resource version reset default when event object resource version invalid --- watch/watch.py | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/watch/watch.py b/watch/watch.py index fe7a9247..002deae3 100644 --- a/watch/watch.py +++ b/watch/watch.py @@ -97,6 +97,10 @@ def unmarshal_event(self, data, return_type): and 'resourceVersion' in js['object']['metadata']): self.resource_version = js['object']['metadata'][ 'resourceVersion'] + if self.resource_version is None: + # In some case like 'too old resource version', + # the event type would be ERROR, resource version will be None + self.resource_version = 0 return js def stream(self, func, *args, **kwargs):