Skip to content

Commit 262f8b1

Browse files
committed
set default one thread for encode/decode messages
1 parent 0448ada commit 262f8b1

File tree

1 file changed

+5
-1
lines changed

1 file changed

+5
-1
lines changed

ydb/topic.py

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -387,7 +387,11 @@ def _check_closed(self):
387387

388388
@dataclass
389389
class TopicClientSettings:
390-
encode_decode_threads_count: int = 4
390+
# ATTENTION
391+
# When set the encode_decode_threads_count - all custom encoders/decoders for topic reader/writer
392+
# MUST be thread-safe
393+
# because they will be called from parallel threads
394+
encode_decode_threads_count: int = 1
391395

392396

393397
class TopicError(issues.Error):

0 commit comments

Comments
 (0)