From 24a0850f55b90326410888882c47ba10b99f9297 Mon Sep 17 00:00:00 2001 From: Jakob Scheid Date: Thu, 19 Feb 2026 18:18:51 +0100 Subject: [PATCH] =?UTF-8?q?=09ge=C3=A4ndert:=20=20=20=20=20=20=20README.md?= =?UTF-8?q?=20=09ge=C3=A4ndert:=20=20=20=20=20=20=20pyproject.toml=20=09ge?= =?UTF-8?q?=C3=A4ndert:=20=20=20=20=20=20=20src/jeb=5Futils/jeb=5Futils.py?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- README.md | 3 +++ pyproject.toml | 2 +- src/jeb_utils/jeb_utils.py | 2 +- 3 files changed, 5 insertions(+), 2 deletions(-) diff --git a/README.md b/README.md index 9ac8a90..12098ac 100644 --- a/README.md +++ b/README.md @@ -77,6 +77,9 @@ pip install jeb-utils --index-url https://jcloud-services.ddns.net/simple/ --ext - `create_file_if_not_exists`: Creates a file if it does not exist. ## Changelog +### Version 0.1.2 +- Bug fix: `jeb_utils.mktopicpart` tried to raise `jeb_utils.exceptions.exceptions.TopicNotFoundError` instead of `jeb_utils.exceptions.TopicNotFoundError` if the topic does not exist. + ### Version 0.1.1 - Support for custom data paths (`jeb_utils.init`) diff --git a/pyproject.toml b/pyproject.toml index 5628f88..188cb1d 100644 --- a/pyproject.toml +++ b/pyproject.toml @@ -4,6 +4,6 @@ build-backend = "setuptools.build_meta" [project] name = "jeb-utils" -version = "0.1.1" +version = "0.1.2" description = "Common utils for JEB client and server." dependencies = ["cryptography"] \ No newline at end of file diff --git a/src/jeb_utils/jeb_utils.py b/src/jeb_utils/jeb_utils.py index 06b4aee..1805d67 100644 --- a/src/jeb_utils/jeb_utils.py +++ b/src/jeb_utils/jeb_utils.py @@ -127,7 +127,7 @@ def mktopicpart(topic_name: str, partition_number: int): formatted_partition_number = f'{(int(partition_number)):02d}' with dbm.open(f'{DATA_DIR}/conf/topics', 'c') as db: if topic_name.encode() not in db.keys(): - raise exceptions.exceptions.TopicNotFoundError(f'topic \'{topic_name}\' does not exist') + raise exceptions.TopicNotFoundError(f'topic \'{topic_name}\' does not exist') partitions = pickle.loads(db[topic_name.encode()])['partitions'] if partition_number in partitions: raise exceptions.TopicPartitionExistsError(f'partition \'{formatted_partition_number}\' already exists for topic \'{topic_name}\'')