@@ -64,7 +64,7 @@ def thread_started(
6464 func = is_assistant_thread_started_event ,
6565 asyncio = True ,
6666 base_logger = self .base_logger ,
67- ), # type:ignore[arg-type]
67+ ), # type: ignore[arg-type]
6868 matchers ,
6969 )
7070 if is_used_without_argument (args ):
@@ -73,7 +73,7 @@ def thread_started(
7373 self .build_listener (
7474 listener_or_functions = func ,
7575 matchers = all_matchers ,
76- middleware = middleware , # type:ignore[arg-type]
76+ middleware = middleware , # type: ignore[arg-type]
7777 )
7878 )
7979 return func
@@ -110,7 +110,7 @@ def user_message(
110110 func = is_user_message_event_in_assistant_thread ,
111111 asyncio = True ,
112112 base_logger = self .base_logger ,
113- ), # type:ignore[arg-type]
113+ ), # type: ignore[arg-type]
114114 matchers ,
115115 )
116116 if is_used_without_argument (args ):
@@ -119,7 +119,7 @@ def user_message(
119119 self .build_listener (
120120 listener_or_functions = func ,
121121 matchers = all_matchers ,
122- middleware = middleware , # type:ignore[arg-type]
122+ middleware = middleware , # type: ignore[arg-type]
123123 )
124124 )
125125 return func
@@ -156,7 +156,7 @@ def bot_message(
156156 func = is_bot_message_event_in_assistant_thread ,
157157 asyncio = True ,
158158 base_logger = self .base_logger ,
159- ), # type:ignore[arg-type]
159+ ), # type: ignore[arg-type]
160160 matchers ,
161161 )
162162 if is_used_without_argument (args ):
@@ -165,7 +165,7 @@ def bot_message(
165165 self .build_listener (
166166 listener_or_functions = func ,
167167 matchers = all_matchers ,
168- middleware = middleware , # type:ignore[arg-type]
168+ middleware = middleware , # type: ignore[arg-type]
169169 )
170170 )
171171 return func
@@ -202,7 +202,7 @@ def thread_context_changed(
202202 func = is_assistant_thread_context_changed_event ,
203203 asyncio = True ,
204204 base_logger = self .base_logger ,
205- ), # type:ignore[arg-type]
205+ ), # type: ignore[arg-type]
206206 matchers ,
207207 )
208208 if is_used_without_argument (args ):
@@ -211,7 +211,7 @@ def thread_context_changed(
211211 self .build_listener (
212212 listener_or_functions = func ,
213213 matchers = all_matchers ,
214- middleware = middleware , # type:ignore[arg-type]
214+ middleware = middleware , # type: ignore[arg-type]
215215 )
216216 )
217217 return func
@@ -239,14 +239,14 @@ def _merge_matchers(
239239 primary_matcher : Union [Callable [..., bool ], AsyncListenerMatcher ],
240240 custom_matchers : Optional [Union [Callable [..., bool ], AsyncListenerMatcher ]],
241241 ):
242- return [primary_matcher ] + (custom_matchers or []) # type:ignore[operator]
242+ return [primary_matcher ] + (custom_matchers or []) # type: ignore[operator]
243243
244244 @staticmethod
245245 async def default_thread_context_changed (save_thread_context : AsyncSaveThreadContext , payload : dict ):
246246 new_context : dict = payload ["assistant_thread" ]["context" ]
247247 await save_thread_context (new_context )
248248
249- async def async_process ( # type:ignore[return]
249+ async def async_process ( # type: ignore[return]
250250 self ,
251251 * ,
252252 req : AsyncBoltRequest ,
@@ -294,8 +294,8 @@ def build_listener(
294294 middleware : Optional [List [AsyncMiddleware ]] = None ,
295295 base_logger : Optional [Logger ] = None ,
296296 ) -> AsyncListener :
297- if isinstance (listener_or_functions , Callable ): # type:ignore[arg-type]
298- listener_or_functions = [listener_or_functions ] # type:ignore[list-item]
297+ if isinstance (listener_or_functions , Callable ): # type: ignore[arg-type]
298+ listener_or_functions = [listener_or_functions ] # type: ignore[list-item]
299299
300300 if isinstance (listener_or_functions , AsyncListener ):
301301 return listener_or_functions
@@ -313,7 +313,7 @@ def build_listener(
313313 else :
314314 listener_matchers .append (
315315 build_listener_matcher (
316- func = matcher , # type:ignore[arg-type]
316+ func = matcher , # type: ignore[arg-type]
317317 asyncio = True ,
318318 base_logger = base_logger ,
319319 )
0 commit comments