updated delete_streams_to_overwrite to use the correct stream ID

airbytehq · Dec 19, 2023 · ee1de37 · ee1de37
1 parent f163d47
commit ee1de37
Showing 1 changed file with 2 additions and 1 deletion.
diff --git 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)