Skip to content

Commit 7b704e0

Browse files
author
maxime.c
committed
Merge branch 'main' into maxi297/remove_declarative_stream
2 parents f5d1b71 + cd48741 commit 7b704e0

File tree

2 files changed

+0
-13
lines changed

2 files changed

+0
-13
lines changed

airbyte_cdk/sources/declarative/parsers/model_to_component_factory.py

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2117,7 +2117,6 @@ def _is_client_side_filtering_enabled(self, model: DeclarativeStreamModel) -> bo
21172117
model.incremental_sync
21182118
and hasattr(model.incremental_sync, "is_client_side_incremental")
21192119
and model.incremental_sync.is_client_side_incremental
2120-
)
21212120

21222121
def _build_stream_slicer_from_partition_router(
21232122
self,

airbyte_cdk/sources/declarative/stream_slicers/declarative_partition_generator.py

Lines changed: 0 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -12,18 +12,6 @@
1212
from airbyte_cdk.utils.slice_hasher import SliceHasher
1313

1414

15-
class SchemaLoaderCachingDecorator(SchemaLoader):
16-
def __init__(self, schema_loader: SchemaLoader):
17-
self._decorated = schema_loader
18-
self._loaded_schema: Optional[Mapping[str, Any]] = None
19-
20-
def get_json_schema(self) -> Mapping[str, Any]:
21-
if self._loaded_schema is None:
22-
self._loaded_schema = self._decorated.get_json_schema()
23-
24-
return self._loaded_schema # type: ignore # at that point, we assume the schema will be populated
25-
26-
2715
class SchemaLoaderCachingDecorator(SchemaLoader):
2816
def __init__(self, schema_loader: SchemaLoader):
2917
self._decorated = schema_loader

0 commit comments

Comments
 (0)