From 498180fa9d4feee1b867ead4b0ab1d90ae24d38b Mon Sep 17 00:00:00 2001 From: "pre-commit-ci[bot]" <66853113+pre-commit-ci[bot]@users.noreply.github.com> Date: Mon, 16 Mar 2026 19:55:28 +0000 Subject: [PATCH 1/2] =?UTF-8?q?=E2=AC=86=20[pre-commit.ci]=20pre-commit=20?= =?UTF-8?q?autoupdate?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit updates: - [github.com/pre-commit/pre-commit-hooks: v5.0.0 → v6.0.0](https://github.com/pre-commit/pre-commit-hooks/compare/v5.0.0...v6.0.0) - [github.com/astral-sh/ruff-pre-commit: v0.8.3 → v0.15.6](https://github.com/astral-sh/ruff-pre-commit/compare/v0.8.3...v0.15.6) - [github.com/igorshubovych/markdownlint-cli: v0.43.0 → v0.48.0](https://github.com/igorshubovych/markdownlint-cli/compare/v0.43.0...v0.48.0) - [github.com/macisamuele/language-formatters-pre-commit-hooks: v2.14.0 → v2.16.0](https://github.com/macisamuele/language-formatters-pre-commit-hooks/compare/v2.14.0...v2.16.0) --- .pre-commit-config.yaml | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/.pre-commit-config.yaml b/.pre-commit-config.yaml index 49f988e5..78a970cb 100644 --- a/.pre-commit-config.yaml +++ b/.pre-commit-config.yaml @@ -6,7 +6,7 @@ ci: repos: - repo: https://github.com/pre-commit/pre-commit-hooks - rev: v5.0.0 + rev: v6.0.0 hooks: - id: trailing-whitespace - id: debug-statements @@ -18,20 +18,20 @@ repos: - id: end-of-file-fixer - repo: https://github.com/astral-sh/ruff-pre-commit - rev: v0.8.3 + rev: v0.15.6 hooks: - id: ruff args: [--fix, --exit-non-zero-on-fix] - id: ruff-format - repo: https://github.com/igorshubovych/markdownlint-cli - rev: v0.43.0 + rev: v0.48.0 hooks: - id: markdownlint-fix args: [--config=pyproject.toml, --configPointer=/tool/markdownlint] - repo: https://github.com/macisamuele/language-formatters-pre-commit-hooks - rev: v2.14.0 + rev: v2.16.0 hooks: - id: pretty-format-toml args: [--autofix] From f106fbe97d123cd1ff353203cc4f5f4787291b2d Mon Sep 17 00:00:00 2001 From: "pre-commit-ci[bot]" <66853113+pre-commit-ci[bot]@users.noreply.github.com> Date: Mon, 16 Mar 2026 19:58:08 +0000 Subject: [PATCH 2/2] =?UTF-8?q?=F0=9F=8E=A8=20[pre-commit.ci]=20Auto=20for?= =?UTF-8?q?mat=20from=20pre-commit.com=20hooks?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- repid/connections/abc.py | 16 +++++++++------- repid/connections/redis/utils.py | 2 +- repid/testing/modifiers.py | 2 +- 3 files changed, 11 insertions(+), 9 deletions(-) diff --git a/repid/connections/abc.py b/repid/connections/abc.py index 96347cb5..4821a11e 100644 --- a/repid/connections/abc.py +++ b/repid/connections/abc.py @@ -10,6 +10,8 @@ TypeVar, ) +from typing_extensions import Self + from repid.config import Config from repid.message import MessageCategory from repid.middlewares import middleware_wrapper @@ -26,10 +28,10 @@ class _WrappedABC(ABC): # noqa: B024 __WRAPPED_METHODS__: tuple[str, ...] = () def __new__( - cls: type[WrappedABCSelf], - *args: Any, # noqa: ARG003 - **kwargs: Any, # noqa: ARG003 - ) -> WrappedABCSelf: + cls, + *args: Any, + **kwargs: Any, + ) -> Self: inst = super().__new__(cls) for method in inst.__WRAPPED_METHODS__: @@ -184,7 +186,7 @@ async def queue_delete(self, queue_name: str) -> None: def __new__( # noqa: PYI034 cls: type[MessageBrokerT], - *args: Any, # noqa: ARG003 + *args: Any, **kwargs: Any, # noqa: ARG003s ) -> MessageBrokerT: cls.ROUTING_KEY_CLASS = deepcopy(Config.ROUTING_KEY) @@ -222,8 +224,8 @@ async def delete_bucket(self, id_: str) -> None: def __new__( # noqa: PYI034 cls: type[BucketBrokerT], - *args: Any, # noqa: ARG003 - **kwargs: Any, # noqa: ARG003 + *args: Any, + **kwargs: Any, ) -> BucketBrokerT: cls.BUCKET_CLASS = deepcopy(Config.BUCKET) diff --git a/repid/connections/redis/utils.py b/repid/connections/redis/utils.py index 16affe96..cf5059e0 100644 --- a/repid/connections/redis/utils.py +++ b/repid/connections/redis/utils.py @@ -103,7 +103,7 @@ def full_message_name_from_short(short_name: str, full_queue_name: str) -> str: def get_queue_marker(full_queue_name: str) -> str: - return full_queue_name.split(":")[-1] + return full_queue_name.rsplit(":", maxsplit=1)[-1] def parse_short_message_name(short_name: str) -> tuple[str, str]: diff --git a/repid/testing/modifiers.py b/repid/testing/modifiers.py index 9831c5cb..19df6fd6 100644 --- a/repid/testing/modifiers.py +++ b/repid/testing/modifiers.py @@ -40,7 +40,7 @@ def __init__(self, parent: MessageBrokerT | BucketBrokerT) -> None: def consumer_class_wrapper(self, class_: type[ConsumerT]) -> type[ConsumerT]: class ConsumerWrapper(class_): # type: ignore[valid-type,misc] - def __new__(cls, *args: Any, **kwargs: Any) -> Any: # noqa: ARG003 + def __new__(cls, *args: Any, **kwargs: Any) -> Any: inst = super().__new__(cls) for method in inst.__WRAPPED_METHODS__: