From 534d7c3d5a8223fde0734ada6c65df2292037533 Mon Sep 17 00:00:00 2001 From: Markus Unterwaditzer Date: Thu, 7 May 2026 16:15:30 +0200 Subject: [PATCH] fix(taskbroker-client): Update docstrings to reflect msgpack serialization Fixes STREAM-948 Co-Authored-By: Claude Opus 4.5 --- clients/python/src/taskbroker_client/task.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/clients/python/src/taskbroker_client/task.py b/clients/python/src/taskbroker_client/task.py index f3ec77a2..51035dea 100644 --- a/clients/python/src/taskbroker_client/task.py +++ b/clients/python/src/taskbroker_client/task.py @@ -112,7 +112,7 @@ def delay(self, *args: P.args, **kwargs: P.kwargs) -> None: """ Schedule a task to run later with a set of arguments. - The provided parameters will be JSON encoded and stored within + The provided parameters will be msgpack encoded and stored within a `TaskActivation` protobuf that is appended to kafka """ self.apply_async(args=args, kwargs=kwargs) @@ -129,7 +129,7 @@ def apply_async( """ Schedule a task to run later with a set of arguments. - The provided parameters will be JSON encoded and stored within + The provided parameters will be msgpack encoded and stored within a `TaskActivation` protobuf that is appended to kafka. """ if args is None: