This commit is contained in:
2023-05-20 22:30:18 +02:00
parent 56fd2ec06a
commit 12d3e55e1c

View File

@@ -8,6 +8,7 @@ from taskiq.result import TaskiqResult
class FastAPIREtryMiddleware(SimpleRetryMiddleware): class FastAPIREtryMiddleware(SimpleRetryMiddleware):
@staticmethod @staticmethod
def _is_need_to_remove(to_remove: list[Any], value: Any) -> bool: def _is_need_to_remove(to_remove: list[Any], value: Any) -> bool:
print(type(value), to_remove)
return type(value) in to_remove return type(value) in to_remove
async def on_error( async def on_error(