Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

progress messages for jupyterhub 0.9 #153

Merged
merged 10 commits into from
May 24, 2018
Merged

progress messages for jupyterhub 0.9 #153

Changes from 1 commit
Commits
Show all changes
10 commits
Select commit Hold shift + click to select a range
8c757d0
Use EventReflector to watch pod events
clkao Mar 26, 2018
0728dcf
Use jupyterhub progress api for showing pending messages
clkao Apr 14, 2018
ac5bfa9
require async_generator
clkao Apr 15, 2018
85d7369
require Python 3.5 for async/await syntax
clkao Apr 16, 2018
1ae6127
Use per-generator index to stream cached events from single reflector.
clkao Apr 24, 2018
cdf9c13
Add __del__ for reflector
clkao Apr 24, 2018
84a05ef
Add timeout for reflector watcher stream
clkao Apr 24, 2018
09c489a
improve launch event debug message
clkao Apr 24, 2018
8322a10
remove queue
clkao Apr 24, 2018
de759c0
make progress generator check if reflector is stopped
clkao May 15, 2018
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
Add timeout for reflector watcher stream
  • Loading branch information
@clkao
clkao committed May 10, 2018

Verified

This commit was created on GitHub.com and signed with GitHub’s verified signature.
GPG key ID: B5690EEEBB952194
Verified
Learn about vigilant mode
commit 84a05ef05f29155726c0657b6f22781e65a32fe3
3 changes: 2 additions & 1 deletion kubespawner/reflector.py
View file
Original file line number Diff line number Diff line change
@@ -148,8 +148,8 @@ def _watch_and_update(self):
update' cycle on them), we should be ok!
"""
cur_delay = 0.1
self.log.info("watching for %s with label selector %s / field selector %s in namespace %s", self.kind, self.label_selector, self.field_selector, self.namespace)
while True:
self.log.info("watching for %s with label selector %s / field selector %s in namespace %s", self.kind, self.label_selector, self.field_selector, self.namespace)
w = watch.Watch()
try:
resource_version = self._list_and_update()
@@ -162,6 +162,7 @@ def _watch_and_update(self):
label_selector=self.label_selector,
field_selector=self.field_selector,
resource_version=resource_version,
timeout_seconds=10,
):
cur_delay = 0.1
resource = ev['object']