diff --git a/airbyte-integrations/connectors/destination-vectara/destination_vectara/writer.py b/airbyte-integrations/connectors/destination-vectara/destination_vectara/writer.py index f6af5b929306..1c9624f91790 100644 --- a/airbyte-integrations/connectors/destination-vectara/destination_vectara/writer.py +++ b/airbyte-integrations/connectors/destination-vectara/destination_vectara/writer.py @@ -31,7 +31,8 @@ def __init__(self, client: VectaraClient, text_fields: Optional[List[str]], meta def delete_streams_to_overwrite(self, catalog: ConfiguredAirbyteCatalog) -> None: streams_to_overwrite = [ - stream.stream.name for stream in catalog.streams if stream.destination_sync_mode == DestinationSyncMode.overwrite + f"{stream.stream.namespace}_{stream.stream.name}" + for stream in catalog.streams if stream.destination_sync_mode == DestinationSyncMode.overwrite ] if len(streams_to_overwrite): self.client.delete_doc_by_metadata(metadata_field_name=METADATA_STREAM_FIELD, metadata_field_values=streams_to_overwrite)