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-06-01 13:14:56 +02:00
parent ed8de9e978
commit 9f1882ecca
2 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/core/taskiq_middlewares.py
View File

@@ -7,7 +7,7 @@ from taskiq.result import TaskiqResult
from taskiq_dependencies.dependency import Dependency from taskiq_dependencies.dependency import Dependency
class FastAPIREtryMiddleware(SimpleRetryMiddleware): class FastAPIRetryMiddleware(SimpleRetryMiddleware):
@staticmethod @staticmethod
def _remove_depends( def _remove_depends(
task_func: Any, message_kwargs: dict[str, Any] task_func: Any, message_kwargs: dict[str, Any]

4
src/core/taskiq_worker.py
View File

@@ -2,7 +2,7 @@ import taskiq_fastapi
from taskiq_redis import ListQueueBroker, RedisAsyncResultBackend from taskiq_redis import ListQueueBroker, RedisAsyncResultBackend
from core.config import REDIS_URL from core.config import REDIS_URL
from core.taskiq_middlewares import FastAPIREtryMiddleware from core.taskiq_middlewares import FastAPIRetryMiddleware
broker = ( broker = (
@@ -10,7 +10,7 @@ broker = (
.with_result_backend( .with_result_backend(
RedisAsyncResultBackend(redis_url=REDIS_URL, result_ex_time=5 * 60) RedisAsyncResultBackend(redis_url=REDIS_URL, result_ex_time=5 * 60)
) )
.with_middlewares(FastAPIREtryMiddleware()) .with_middlewares(FastAPIRetryMiddleware())
) )