Skip to content

Commit 259c769

Browse files
rename acknowledgement_timeout to ack_timeout
1 parent a81bade commit 259c769

File tree

10 files changed

+28
-35
lines changed

10 files changed

+28
-35
lines changed

slack_bolt/app/app.py

Lines changed: 6 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -913,7 +913,7 @@ def function(
913913
matchers: Optional[Sequence[Callable[..., bool]]] = None,
914914
middleware: Optional[Sequence[Union[Callable, Middleware]]] = None,
915915
auto_acknowledge: bool = True,
916-
acknowledgement_timeout: int = 3,
916+
ack_timeout: int = 3,
917917
) -> Callable[..., Optional[Callable[..., Optional[BoltResponse]]]]:
918918
"""Registers a new Function listener.
919919
This method can be used as either a decorator or a method.
@@ -943,18 +943,16 @@ def reverse_string(ack: Ack, inputs: dict, complete: Complete, fail: Fail):
943943
"""
944944

945945
if auto_acknowledge is True:
946-
if acknowledgement_timeout != 3:
947-
self._framework_logger.warning(warning_ack_timeout_has_no_effect(callback_id, acknowledgement_timeout))
946+
if ack_timeout != 3:
947+
self._framework_logger.warning(warning_ack_timeout_has_no_effect(callback_id, ack_timeout))
948948

949949
matchers = list(matchers) if matchers else []
950950
middleware = list(middleware) if middleware else []
951951

952952
def __call__(*args, **kwargs):
953953
functions = self._to_listener_functions(kwargs) if kwargs else list(args)
954954
primary_matcher = builtin_matchers.function_executed(callback_id=callback_id, base_logger=self._base_logger)
955-
return self._register_listener(
956-
functions, primary_matcher, matchers, middleware, auto_acknowledge, acknowledgement_timeout
957-
)
955+
return self._register_listener(functions, primary_matcher, matchers, middleware, auto_acknowledge, ack_timeout)
958956

959957
return __call__
960958

@@ -1430,7 +1428,7 @@ def _register_listener(
14301428
matchers: Optional[Sequence[Callable[..., bool]]],
14311429
middleware: Optional[Sequence[Union[Callable, Middleware]]],
14321430
auto_acknowledgement: bool = False,
1433-
acknowledgement_timeout: int = 3,
1431+
ack_timeout: int = 3,
14341432
) -> Optional[Callable[..., Optional[BoltResponse]]]:
14351433
value_to_return = None
14361434
if not isinstance(functions, list):
@@ -1461,7 +1459,7 @@ def _register_listener(
14611459
matchers=listener_matchers,
14621460
middleware=listener_middleware,
14631461
auto_acknowledgement=auto_acknowledgement,
1464-
acknowledgement_timeout=acknowledgement_timeout,
1462+
ack_timeout=ack_timeout,
14651463
base_logger=self._base_logger,
14661464
)
14671465
)

slack_bolt/app/async_app.py

Lines changed: 6 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -941,7 +941,7 @@ def function(
941941
matchers: Optional[Sequence[Callable[..., Awaitable[bool]]]] = None,
942942
middleware: Optional[Sequence[Union[Callable, AsyncMiddleware]]] = None,
943943
auto_acknowledge: bool = True,
944-
acknowledgement_timeout: int = 3,
944+
ack_timeout: int = 3,
945945
) -> Callable[..., Optional[Callable[..., Awaitable[BoltResponse]]]]:
946946
"""Registers a new Function listener.
947947
This method can be used as either a decorator or a method.
@@ -970,8 +970,8 @@ async def reverse_string(ack: AsyncAck, inputs: dict, complete: AsyncComplete, f
970970
Only when all the middleware call `next()` method, the listener function can be invoked.
971971
"""
972972
if auto_acknowledge is True:
973-
if acknowledgement_timeout != 3:
974-
self._framework_logger.warning(warning_ack_timeout_has_no_effect(callback_id, acknowledgement_timeout))
973+
if ack_timeout != 3:
974+
self._framework_logger.warning(warning_ack_timeout_has_no_effect(callback_id, ack_timeout))
975975

976976
matchers = list(matchers) if matchers else []
977977
middleware = list(middleware) if middleware else []
@@ -981,9 +981,7 @@ def __call__(*args, **kwargs):
981981
primary_matcher = builtin_matchers.function_executed(
982982
callback_id=callback_id, base_logger=self._base_logger, asyncio=True
983983
)
984-
return self._register_listener(
985-
functions, primary_matcher, matchers, middleware, auto_acknowledge, acknowledgement_timeout
986-
)
984+
return self._register_listener(functions, primary_matcher, matchers, middleware, auto_acknowledge, ack_timeout)
987985

988986
return __call__
989987

@@ -1463,7 +1461,7 @@ def _register_listener(
14631461
matchers: Optional[Sequence[Callable[..., Awaitable[bool]]]],
14641462
middleware: Optional[Sequence[Union[Callable, AsyncMiddleware]]],
14651463
auto_acknowledgement: bool = False,
1466-
acknowledgement_timeout: int = 3,
1464+
ack_timeout: int = 3,
14671465
) -> Optional[Callable[..., Awaitable[Optional[BoltResponse]]]]:
14681466
value_to_return = None
14691467
if not isinstance(functions, list):
@@ -1499,7 +1497,7 @@ def _register_listener(
14991497
matchers=listener_matchers,
15001498
middleware=listener_middleware,
15011499
auto_acknowledgement=auto_acknowledgement,
1502-
acknowledgement_timeout=acknowledgement_timeout,
1500+
ack_timeout=ack_timeout,
15031501
base_logger=self._base_logger,
15041502
)
15051503
)

slack_bolt/listener/async_listener.py

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,7 @@ class AsyncListener(metaclass=ABCMeta):
1515
ack_function: Callable[..., Awaitable[BoltResponse]]
1616
lazy_functions: Sequence[Callable[..., Awaitable[None]]]
1717
auto_acknowledgement: bool
18-
acknowledgement_timeout: int
18+
ack_timeout: int
1919

2020
async def async_matches(
2121
self,
@@ -88,7 +88,7 @@ class AsyncCustomListener(AsyncListener):
8888
matchers: Sequence[AsyncListenerMatcher]
8989
middleware: Sequence[AsyncMiddleware]
9090
auto_acknowledgement: bool
91-
acknowledgement_timeout: int
91+
ack_timeout: int
9292
arg_names: MutableSequence[str]
9393
logger: Logger
9494

@@ -101,7 +101,7 @@ def __init__(
101101
matchers: Sequence[AsyncListenerMatcher],
102102
middleware: Sequence[AsyncMiddleware],
103103
auto_acknowledgement: bool = False,
104-
acknowledgement_timeout: int = 3,
104+
ack_timeout: int = 3,
105105
base_logger: Optional[Logger] = None,
106106
):
107107
self.app_name = app_name
@@ -110,7 +110,7 @@ def __init__(
110110
self.matchers = matchers
111111
self.middleware = middleware
112112
self.auto_acknowledgement = auto_acknowledgement
113-
self.acknowledgement_timeout = acknowledgement_timeout
113+
self.ack_timeout = ack_timeout
114114
self.arg_names = get_arg_names_of_callable(ack_function)
115115
self.logger = get_bolt_app_logger(app_name, self.ack_function, base_logger)
116116

slack_bolt/listener/asyncio_runner.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -149,7 +149,7 @@ async def run_ack_function_asynchronously(
149149
self._start_lazy_function(lazy_func, request)
150150

151151
# await for the completion of ack() in the async listener execution
152-
while ack.response is None and time.time() - starting_time <= listener.acknowledgement_timeout:
152+
while ack.response is None and time.time() - starting_time <= listener.ack_timeout:
153153
await asyncio.sleep(0.01)
154154

155155
if response is None and ack.response is None:

slack_bolt/listener/custom_listener.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -18,7 +18,7 @@ class CustomListener(Listener):
1818
matchers: Sequence[ListenerMatcher]
1919
middleware: Sequence[Middleware]
2020
auto_acknowledgement: bool
21-
acknowledgement_timeout: int = 3
21+
ack_timeout: int = 3
2222
arg_names: MutableSequence[str]
2323
logger: Logger
2424

@@ -31,7 +31,7 @@ def __init__(
3131
matchers: Sequence[ListenerMatcher],
3232
middleware: Sequence[Middleware],
3333
auto_acknowledgement: bool = False,
34-
acknowledgement_timeout: int = 3,
34+
ack_timeout: int = 3,
3535
base_logger: Optional[Logger] = None,
3636
):
3737
self.app_name = app_name
@@ -40,7 +40,7 @@ def __init__(
4040
self.matchers = matchers
4141
self.middleware = middleware
4242
self.auto_acknowledgement = auto_acknowledgement
43-
self.acknowledgement_timeout = acknowledgement_timeout
43+
self.ack_timeout = ack_timeout
4444
self.arg_names = get_arg_names_of_callable(ack_function)
4545
self.logger = get_bolt_app_logger(app_name, self.ack_function, base_logger)
4646

slack_bolt/listener/listener.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,7 @@ class Listener(metaclass=ABCMeta):
1313
ack_function: Callable[..., BoltResponse]
1414
lazy_functions: Sequence[Callable[..., None]]
1515
auto_acknowledgement: bool
16-
acknowledgement_timeout: int = 3
16+
ack_timeout: int = 3
1717

1818
def matches(
1919
self,

slack_bolt/listener/thread_runner.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -160,7 +160,7 @@ def run_ack_function_asynchronously():
160160
self._start_lazy_function(lazy_func, request)
161161

162162
# await for the completion of ack() in the async listener execution
163-
while ack.response is None and time.time() - starting_time <= listener.acknowledgement_timeout:
163+
while ack.response is None and time.time() - starting_time <= listener.ack_timeout:
164164
time.sleep(0.01)
165165

166166
if response is None and ack.response is None:

slack_bolt/logger/messages.py

Lines changed: 2 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -332,12 +332,9 @@ def warning_skip_uncommon_arg_name(arg_name: str) -> str:
332332
)
333333

334334

335-
def warning_ack_timeout_has_no_effect(identifier: Union[str, Pattern], acknowledgement_timeout: int) -> str:
335+
def warning_ack_timeout_has_no_effect(identifier: Union[str, Pattern], ack_timeout: int) -> str:
336336
handler_example = f'@app.function("{identifier}")' if isinstance(identifier, str) else f"@app.function({identifier})"
337-
return (
338-
f"On {handler_example}, as `auto_acknowledge` is `True`, "
339-
f"`acknowledgement_timeout={acknowledgement_timeout}` you gave will be unused"
340-
)
337+
return f"On {handler_example}, as `auto_acknowledge` is `True`, " f"`ack_timeout={ack_timeout}` you gave will be unused"
341338

342339

343340
# -------------------------------

tests/scenario_tests/test_function.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -155,7 +155,7 @@ def test_function_handler_timeout(self, monkeypatch):
155155
client=self.web_client,
156156
signing_secret=self.signing_secret,
157157
)
158-
app.function("reverse", auto_acknowledge=False, acknowledgement_timeout=timeout)(just_no_ack)
158+
app.function("reverse", auto_acknowledge=False, ack_timeout=timeout)(just_no_ack)
159159
request = self.build_request_from_body(function_body)
160160

161161
sleep_mock = Mock()
@@ -181,7 +181,7 @@ def test_warning_when_timeout_improperly_set(self, caplog):
181181
app.function("reverse")(just_no_ack)
182182
assert "WARNING" not in caplog.text
183183

184-
timeout_argument_name = "acknowledgement_timeout"
184+
timeout_argument_name = "ack_timeout"
185185
kwargs = {timeout_argument_name: 5}
186186

187187
callback_id = "reverse1"

tests/scenario_tests_async/test_function.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -166,7 +166,7 @@ async def test_function_handler_timeout(self, monkeypatch):
166166
client=self.web_client,
167167
signing_secret=self.signing_secret,
168168
)
169-
app.function("reverse", auto_acknowledge=False, acknowledgement_timeout=timeout)(just_no_ack)
169+
app.function("reverse", auto_acknowledge=False, ack_timeout=timeout)(just_no_ack)
170170
request = self.build_request_from_body(function_body)
171171

172172
sleep_mock = MagicMock(side_effect=fake_sleep)
@@ -193,7 +193,7 @@ async def test_warning_when_timeout_improperly_set(self, caplog):
193193
app.function("reverse")(just_no_ack)
194194
assert "WARNING" not in caplog.text
195195

196-
timeout_argument_name = "acknowledgement_timeout"
196+
timeout_argument_name = "ack_timeout"
197197
kwargs = {timeout_argument_name: 5}
198198

199199
callback_id = "reverse1"

0 commit comments

Comments
 (0)