9
9
import uuid
10
10
11
11
from kazoo .exceptions import KazooException , NoNodeError , NodeExistsError
12
- from kazoo .protocol .states import EventType
13
-
12
+ from kazoo .protocol .states import EventType , WatchedEvent
13
+ from typing import TYPE_CHECKING , Optional
14
14
15
+ if TYPE_CHECKING :
16
+ from kazoo .client import KazooClient
17
+ from typing_extensions import Literal
15
18
class Barrier (object ):
16
19
"""Kazoo Barrier
17
20
@@ -27,7 +30,7 @@ class Barrier(object):
27
30
28
31
"""
29
32
30
- def __init__ (self , client , path ):
33
+ def __init__ (self , client : KazooClient , path : str ):
31
34
"""Create a Kazoo Barrier
32
35
33
36
:param client: A :class:`~kazoo.client.KazooClient` instance.
@@ -37,11 +40,11 @@ def __init__(self, client, path):
37
40
self .client = client
38
41
self .path = path
39
42
40
- def create (self ):
43
+ def create (self ) -> None :
41
44
"""Establish the barrier if it doesn't exist already"""
42
45
self .client .retry (self .client .ensure_path , self .path )
43
46
44
- def remove (self ):
47
+ def remove (self ) -> bool :
45
48
"""Remove the barrier
46
49
47
50
:returns: Whether the barrier actually needed to be removed.
@@ -54,7 +57,7 @@ def remove(self):
54
57
except NoNodeError :
55
58
return False
56
59
57
- def wait (self , timeout = None ):
60
+ def wait (self , timeout : Optional [ float ] = None ) -> bool :
58
61
"""Wait on the barrier to be cleared
59
62
60
63
:returns: True if the barrier has been cleared, otherwise
@@ -64,7 +67,7 @@ def wait(self, timeout=None):
64
67
"""
65
68
cleared = self .client .handler .event_object ()
66
69
67
- def wait_for_clear (event ) :
70
+ def wait_for_clear (event : WatchedEvent ) -> None :
68
71
if event .type == EventType .DELETED :
69
72
cleared .set ()
70
73
@@ -93,7 +96,7 @@ class DoubleBarrier(object):
93
96
94
97
"""
95
98
96
- def __init__ (self , client , path , num_clients , identifier = None ):
99
+ def __init__ (self , client : KazooClient , path : str , num_clients : int , identifier : Optional [ str ] = None ):
97
100
"""Create a Double Barrier
98
101
99
102
:param client: A :class:`~kazoo.client.KazooClient` instance.
@@ -118,7 +121,7 @@ def __init__(self, client, path, num_clients, identifier=None):
118
121
self .node_name = uuid .uuid4 ().hex
119
122
self .create_path = self .path + "/" + self .node_name
120
123
121
- def enter (self ):
124
+ def enter (self ) -> None :
122
125
"""Enter the barrier, blocks until all nodes have entered"""
123
126
try :
124
127
self .client .retry (self ._inner_enter )
@@ -128,7 +131,7 @@ def enter(self):
128
131
self ._best_effort_cleanup ()
129
132
self .participating = False
130
133
131
- def _inner_enter (self ):
134
+ def _inner_enter (self ) -> Literal [ True ] :
132
135
# make sure our barrier parent node exists
133
136
if not self .assured_path :
134
137
self .client .ensure_path (self .path )
@@ -145,7 +148,7 @@ def _inner_enter(self):
145
148
except NodeExistsError :
146
149
pass
147
150
148
- def created (event ) :
151
+ def created (event : WatchedEvent ) -> None :
149
152
if event .type == EventType .CREATED :
150
153
ready .set ()
151
154
@@ -159,7 +162,7 @@ def created(event):
159
162
self .client .ensure_path (self .path + "/ready" )
160
163
return True
161
164
162
- def leave (self ):
165
+ def leave (self ) -> None :
163
166
"""Leave the barrier, blocks until all nodes have left"""
164
167
try :
165
168
self .client .retry (self ._inner_leave )
@@ -168,7 +171,7 @@ def leave(self):
168
171
self ._best_effort_cleanup ()
169
172
self .participating = False
170
173
171
- def _inner_leave (self ):
174
+ def _inner_leave (self ) -> Literal [ True ] :
172
175
# Delete the ready node if its around
173
176
try :
174
177
self .client .delete (self .path + "/ready" )
@@ -188,7 +191,7 @@ def _inner_leave(self):
188
191
189
192
ready = self .client .handler .event_object ()
190
193
191
- def deleted (event ) :
194
+ def deleted (event : WatchedEvent ) -> None :
192
195
if event .type == EventType .DELETED :
193
196
ready .set ()
194
197
@@ -214,7 +217,7 @@ def deleted(event):
214
217
# Wait for the lowest to be deleted
215
218
ready .wait ()
216
219
217
- def _best_effort_cleanup (self ):
220
+ def _best_effort_cleanup (self ) -> None :
218
221
try :
219
222
self .client .retry (self .client .delete , self .create_path )
220
223
except NoNodeError :
0 commit comments