flibusta-apps/telegram_files_cache_server
1
0
Fork 0
mirror of https://github.com/flibusta-apps/telegram_files_cache_server.git synced 2025-12-06 06:35:38 +01:00
Code Issues Actions Packages Projects Releases Wiki Activity

Fix

Browse Source
This commit is contained in:
Bulat Kurbanov
2023-05-21 01:59:17 +02:00
parent 4d3aca532f
commit cd6f28cdbc
1 changed files with 6 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
src/core/taskiq_middlewares.py
View File

@@ -14,6 +14,8 @@ class FastAPIREtryMiddleware(SimpleRetryMiddleware):
) -> dict[str, Any]: ) -> dict[str, Any]:
sig = signature(task_func) sig = signature(task_func)
keys_to_remove = []
for key in message_kwargs.keys(): for key in message_kwargs.keys():
param = sig.parameters.get(key, None) param = sig.parameters.get(key, None)
@@ -21,6 +23,9 @@ class FastAPIREtryMiddleware(SimpleRetryMiddleware):
continue continue
if isinstance(param.default, Dependency): if isinstance(param.default, Dependency):
keys_to_remove.append(key)
for key in keys_to_remove:
message_kwargs.pop(key) message_kwargs.pop(key)
return message_kwargs return message_kwargs