default vector id

griptape/drivers/vector/base_vector_store_driver.py

@@ -1,4 +1,5 @@
 from __future__ import annotations
+import uuid
 from abc import ABC, abstractmethod
 from concurrent import futures
 from dataclasses import dataclass
@@ -56,7 +57,7 @@ def upsert_text_artifact(
         **kwargs,
     ) -> str:
         meta = {} if meta is None else meta
-        vector_id = utils.str_to_hash(artifact.to_text()) if vector_id is None else vector_id
+        vector_id = self._get_default_vector_id(artifact.to_text()) if vector_id is None else vector_id
 
         if self.does_entry_exist(vector_id, namespace):
             return vector_id
@@ -81,7 +82,7 @@ def upsert_text(
         meta: Optional[dict] = None,
         **kwargs,
     ) -> str:
-        vector_id = utils.str_to_hash(string) if vector_id is None else vector_id
+        vector_id = self._get_default_vector_id(string) if vector_id is None else vector_id
 
         if self.does_entry_exist(vector_id, namespace):
             return vector_id
@@ -134,3 +135,6 @@ def query(
         include_vectors: bool = False,
         **kwargs,
     ) -> list[Entry]: ...
+
+    def _get_default_vector_id(self, value: str) -> str:
+        return str(uuid.uuid5(uuid.NAMESPACE_OID, value))

tests/unit/drivers/vector/test_pinecone_vector_storage_driver.py

@@ -34,7 +34,7 @@ def driver(self):
     def test_upsert_text_artifact(self, driver):
         artifact = TextArtifact("foo")
 
-        assert driver.upsert_text_artifact(artifact) == utils.str_to_hash(artifact.value)
+        assert driver.upsert_text_artifact(artifact) == driver._get_default_vector_id("foo")
 
     def test_upsert_vector(self, driver):
         assert driver.upsert_vector([0, 1, 2], vector_id="foo") == "foo"