Skip to content

Commit ceac06c

Browse files
committed
add destination_object_name to catalog builder
1 parent 18d36f5 commit ceac06c

File tree

1 file changed

+5
-1
lines changed

1 file changed

+5
-1
lines changed

airbyte_cdk/test/catalog_builder.py

+5-1
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,7 @@ def __init__(self) -> None:
2121
"supported_sync_modes": ["full_refresh", "incremental"],
2222
"source_defined_primary_key": [["id"]],
2323
},
24-
"primary_key": [["id"]],
24+
"primary_key": None,
2525
"sync_mode": "full_refresh",
2626
"destination_sync_mode": "overwrite",
2727
}
@@ -40,6 +40,10 @@ def with_destination_sync_mode(
4040
self._stream["destination_sync_mode"] = sync_mode.name
4141
return self
4242

43+
def with_destination_object_name(self, name: str) -> "ConfiguredAirbyteStreamBuilder":
44+
self._stream["destination_object_name"] = name
45+
return self
46+
4347
def with_primary_key(self, pk: List[List[str]]) -> "ConfiguredAirbyteStreamBuilder":
4448
self._stream["primary_key"] = pk
4549
self._stream["stream"]["source_defined_primary_key"] = pk # type: ignore # we assume that self._stream["stream"] is a Dict[str, Any]

0 commit comments

Comments
 (0)