Skip to content

Commit 4ddbb84

Browse files
committed
Delete unused DeclarativePartitionFactory
1 parent a3304b9 commit 4ddbb84

File tree

1 file changed

+0
-27
lines changed

1 file changed

+0
-27
lines changed

airbyte_cdk/sources/declarative/stream_slicers/declarative_partition_generator.py

Lines changed: 0 additions & 27 deletions
Original file line numberDiff line numberDiff line change
@@ -38,33 +38,6 @@ def create(self, stream_slice: StreamSlice) -> Partition:
3838
stream_slice,
3939
)
4040

41-
class DeclarativePartitionFactory1:
42-
def __init__(
43-
self,
44-
stream_name: str,
45-
json_schema: Mapping[str, Any],
46-
retriever: Retriever,
47-
message_repository: MessageRepository,
48-
) -> None:
49-
"""
50-
The DeclarativePartitionFactory takes a retriever_factory and not a retriever directly. The reason is that our components are not
51-
thread safe and classes like `DefaultPaginator` may not work because multiple threads can access and modify a shared field across each other.
52-
In order to avoid these problems, we will create one retriever per thread which should make the processing thread-safe.
53-
"""
54-
self._stream_name = stream_name
55-
self._json_schema = json_schema
56-
self._retriever = retriever
57-
self._message_repository = message_repository
58-
59-
def create(self, stream_slice: StreamSlice) -> Partition:
60-
return DeclarativePartition(
61-
self._stream_name,
62-
self._json_schema,
63-
self._retriever,
64-
self._message_repository,
65-
stream_slice,
66-
)
67-
6841
class DeclarativePartition(Partition):
6942
def __init__(
7043
self,

0 commit comments

Comments
 (0)