From 472ffb77dd4e84bf7826cdf5337c66f1733eda27 Mon Sep 17 00:00:00 2001 From: "dependabot[bot]" <49699333+dependabot[bot]@users.noreply.github.com> Date: Sun, 1 Nov 2026 17:06:59 +0000 Subject: [PATCH 1/2] Bump ruff from 0.16.9 to 0.17.3 Bumps [ruff](https://github.com/astral-sh/ruff) from 0.16.9 to 0.17.3. - [Release notes](https://github.com/astral-sh/ruff/releases) - [Changelog](https://github.com/astral-sh/ruff/blob/main/CHANGELOG.md) - [Commits](https://github.com/astral-sh/ruff/compare/0.16.9...0.17.3) --- updated-dependencies: - dependency-name: ruff dependency-version: 0.17.3 dependency-type: direct:development update-type: version-update:semver-minor ... Signed-off-by: dependabot[bot] --- pyproject.toml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pyproject.toml b/pyproject.toml index 94f694d..d586dc5 100644 --- a/pyproject.toml +++ b/pyproject.toml @@ -50,7 +50,7 @@ doc = [ ] lint = [ "pyright", - "ruff==0.16.9", + "ruff==0.17.3", ] test = [ "pytest", From 439d66f670982b41328b4a865d0dd37627f2c566 Mon Sep 17 00:00:00 2001 From: Tom Willemsen Date: Tue, 3 Nov 2026 14:04:05 +0000 Subject: [PATCH 2/2] fix clock mock --- tests/kafka/test_consumers.py | 10 ++++++++-- 1 file changed, 8 insertions(+), 2 deletions(-) diff --git a/tests/kafka/test_consumers.py b/tests/kafka/test_consumers.py index 1ce0107..ab51850 100644 --- a/tests/kafka/test_consumers.py +++ b/tests/kafka/test_consumers.py @@ -1,3 +1,5 @@ +import time +from types import SimpleNamespace from unittest import mock from unittest.mock import MagicMock, patch @@ -96,6 +98,7 @@ def test_run_callbacks(): def test_consume_from_kafka_forever(): data = Data() + mock_sleep = MagicMock(spec=time.sleep) with ( patch( "kafka_dae_diagnostics.kafka.consumers.make_runinfo_consumer" @@ -114,7 +117,10 @@ def test_consume_from_kafka_forever(): "kafka_dae_diagnostics.kafka.consumers.handle_veto_config_messages" ) as handle_veto_config_messages, patch("kafka_dae_diagnostics.kafka.consumers.run_callbacks") as run_callbacks, - patch("kafka_dae_diagnostics.kafka.consumers.time.sleep") as sleep, + patch( + "kafka_dae_diagnostics.kafka.consumers.time", + SimpleNamespace(time=time.time, sleep=mock_sleep), + ), ): make_runinfo_consumer.return_value.consume.side_effect = [[b"some_runinfo_message"], []] make_event_consumer.return_value.consume.side_effect = [[b"some_event_message"], []] @@ -125,7 +131,7 @@ def test_consume_from_kafka_forever(): # Slightly ugly way to force the infinite loop to break when it has # nothing more to process. - sleep.side_effect = TimeoutError("Waiting for new events") + mock_sleep.side_effect = TimeoutError("Waiting for new events") config = DiagnosticsConfig( runinfo_topic="runInfo",