fix: errors table is now based on Features when running a Vectorizer (#757)

Author: smoya

projects/pgai/pgai/vectorizer/vectorizer.py

@@ -163,6 +163,13 @@ async def run(
         Returns:
             Number of items processed
         """
+
+        if (
+            self.errors_table == DEFAULT_VECTORIZER_ERRORS_TABLE
+            and not features.has_vectorizer_errors_view
+        ):
+            self.errors_table = "vectorizer_errors"
+
         concurrency = concurrency or self.config.processing.concurrency
         tasks = [
             asyncio.create_task(

projects/pgai/pgai/vectorizer/worker.py

@@ -15,7 +15,7 @@
 from .. import __version__
 from .embeddings import ApiKeyMixin
 from .features import Features
-from .vectorizer import DEFAULT_VECTORIZER_ERRORS_TABLE, Vectorizer
+from .vectorizer import Vectorizer
 from .worker_tracking import WorkerTracking
 
 if sys.version_info >= (3, 11):
@@ -125,12 +125,6 @@ def _get_vectorizer(self, vectorizer_id: int, features: Features) -> Vectorizer:
             embedding = vectorizer["config"]["embedding"]
             vectorizer = Vectorizer.model_validate(vectorizer)
 
-            if (
-                vectorizer.errors_table == DEFAULT_VECTORIZER_ERRORS_TABLE
-                and not features.has_vectorizer_errors_view
-            ):
-                vectorizer.errors_table = "vectorizer_errors"
-
             # The Ollama API doesn't need a key, so `api_key_name` may be unset
             if "api_key_name" in embedding:
                 api_key_name = embedding["api_key_name"]