[ARVADOS] updated: a85ea61ef977320a17f8362c4ad5b54b3f206e8c
git at public.curoverse.com
git at public.curoverse.com
Mon Nov 23 16:04:47 EST 2015
Summary of changes:
sdk/python/arvados/events.py | 12 ++++++------
1 file changed, 6 insertions(+), 6 deletions(-)
via a85ea61ef977320a17f8362c4ad5b54b3f206e8c (commit)
from 856c4e2694f7b38d0f8182a1353fd6dd3658330e (commit)
Those revisions listed above that are new to this repository have
not appeared on any other notification email; so we list those
revisions in full, below.
commit a85ea61ef977320a17f8362c4ad5b54b3f206e8c
Author: Tom Clegg <tom at curoverse.com>
Date: Sun Nov 22 05:03:36 2015 -0500
7751: 7654: Rename bool to _closed to avoid conflicting with superclass closed() method.
refs #7654
diff --git a/sdk/python/arvados/events.py b/sdk/python/arvados/events.py
index 07c6a47..3132da3 100644
--- a/sdk/python/arvados/events.py
+++ b/sdk/python/arvados/events.py
@@ -29,23 +29,23 @@ class EventClient(WebSocketClient):
self.filters = filters
self.on_event = on_event
self.last_log_id = last_log_id
- self.closed_lock = threading.RLock()
- self.closed = False
+ self._closed_lock = threading.RLock()
+ self._closed = False
def opened(self):
self.subscribe(self.filters, self.last_log_id)
def received_message(self, m):
- with self.closed_lock:
- if not self.closed:
+ with self._closed_lock:
+ if not self._closed:
self.on_event(json.loads(str(m)))
def close(self, code=1000, reason=''):
"""Close event client and wait for it to finish."""
super(EventClient, self).close(code, reason)
- with self.closed_lock:
+ with self._closed_lock:
# make sure we don't process any more messages.
- self.closed = True
+ self._closed = True
def subscribe(self, filters, last_log_id=None):
m = {"method": "subscribe", "filters": filters}
-----------------------------------------------------------------------
hooks/post-receive
--
More information about the arvados-commits
mailing list