Skip to content

Commit 90c2b02

Browse files
Sync _resource_version from Watch on each event, before firing handlers
Co-authored-by: brendandburns <5751682+brendandburns@users.noreply.github.com>
1 parent 4bf1e06 commit 90c2b02

File tree

1 file changed

+6
-0
lines changed

1 file changed

+6
-0
lines changed

kubernetes/informer/informer.py

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -226,6 +226,12 @@ def _run_loop(self):
226226
break
227227
evt_type = event.get("type")
228228
obj = event.get("object")
229+
# Sync the most recent resource version from the Watch
230+
# instance (updated by unmarshal_event before yielding).
231+
# Do this before firing handlers so consumers that wake on
232+
# an event immediately see the advanced resource version.
233+
if self._watch is not None and self._watch.resource_version:
234+
self._resource_version = self._watch.resource_version
229235
if evt_type == ADDED:
230236
self._cache._put(obj)
231237
self._fire(ADDED, obj)

0 commit comments

Comments
 (0)