Skip to content

Commit ed78fe9

Browse files
maxi297brianjlai
andauthored
Update airbyte_cdk/sources/declarative/stream_slicers/declarative_partition_generator.py
Co-authored-by: Brian Lai <[email protected]>
1 parent d060ff0 commit ed78fe9

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

airbyte_cdk/sources/declarative/stream_slicers/declarative_partition_generator.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -21,8 +21,8 @@ def __init__(
2121
message_repository: MessageRepository,
2222
) -> None:
2323
"""
24-
The DeclarativePartitionFactory takes a retriever_factory and not a retriever directly. The reason is that out components are not
25-
thread safe and classes like `DefaultPaginator` would not behave the way we want if multiple threads were to call their methods.
24+
The DeclarativePartitionFactory takes a retriever_factory and not a retriever directly. The reason is that our components are not
25+
thread safe and classes like `DefaultPaginator` may not work because multiple threads can access and modify a shared field across each other.
2626
In order to avoid these problems, we will create one retriever per thread which should make the processing thread-safe.
2727
"""
2828
self._stream_name = stream_name

0 commit comments

Comments
 (0)