Skip to content

Commit 2502c10

Browse files
authored
Merge pull request #366 set default one thread for encode/decode messages
2 parents 0448ada + 262f8b1 commit 2502c10

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)