Move uuid version check into the db

Author: cevian

nbs/00_vector.ipynb

@@ -326,6 +326,9 @@
     "                bytes bytea;\n",
     "                BEGIN\n",
     "                bytes := uuid_send(uuid);\n",
+    "                if  (get_byte(bytes, 6) >> 4)::int2 != 1 then\n",
+    "                    RAISE EXCEPTION 'UUID version is not 1';\n",
+    "                end if;\n",
     "                RETURN to_timestamp(\n",
     "                            (\n",
     "                                (\n",
@@ -647,12 +650,6 @@
     "            return rec == None\n",
     "\n",
     "    def munge_record(self, records) -> Iterable[Tuple[uuid.UUID, str, str, List[float]]]:\n",
-    "        if self.time_partition_interval is not None:\n",
-    "            for record in records:\n",
-    "                id = record[0]\n",
-    "                if id.variant != uuid.RFC_4122 or id.version != 1:\n",
-    "                    raise ValueError(\"When using time partitioning, id must be a v1 uuid\")\n",
-    "\n",
     "        metadata_is_dict = isinstance(records[0][1], dict)\n",
     "        if metadata_is_dict:\n",
     "           records = map(lambda item: Async._convert_record_meta_to_json(item), records)\n",
@@ -895,18 +892,6 @@
    "execution_count": null,
    "metadata": {},
    "outputs": [
-    {
-     "name": "stderr",
-     "output_type": "stream",
-     "text": [
-      "/Users/cevian/.pyenv/versions/3.11.4/envs/nbdev_env/lib/python3.11/site-packages/fastcore/docscrape.py:225: UserWarning: potentially wrong underline length... \n",
-      "Returns \n",
-      "-------- in \n",
-      "Retrieves similar records using a similarity query.\n",
-      "...\n",
-      "  else: warn(msg)\n"
-     ]
-    },
     {
      "data": {
       "text/markdown": [
@@ -1319,12 +1304,6 @@
     "                return rec == None\n",
     "    \n",
     "    def munge_record(self, records) -> Iterable[Tuple[uuid.UUID, str, str, List[float]]]:\n",
-    "        if self.time_partition_interval is not None:\n",
-    "            for record in records:\n",
-    "                id = record[0]\n",
-    "                if id.variant != uuid.RFC_4122 or id.version != 1:\n",
-    "                    raise ValueError(\"When using time partitioning, id must be a v1 uuid\")\n",
-    "\n",
     "        metadata_is_dict = isinstance(records[0][1], dict)\n",
     "        if metadata_is_dict:\n",
     "           records = map(lambda item: Sync._convert_record_meta_to_json(item), records)\n",

timescale_vector/client.py

@@ -243,6 +243,9 @@ def get_create_query(self):
                 bytes bytea;
                 BEGIN
                 bytes := uuid_send(uuid);
+                if  (get_byte(bytes, 6) >> 4)::int2 != 1 then
+                    RAISE EXCEPTION 'UUID version is not 1';
+                end if;
                 RETURN to_timestamp(
                             (
                                 (
@@ -510,12 +513,6 @@ async def table_is_empty(self):
             return rec == None
 
     def munge_record(self, records) -> Iterable[Tuple[uuid.UUID, str, str, List[float]]]:
-        if self.time_partition_interval is not None:
-            for record in records:
-                id = record[0]
-                if id.variant != uuid.RFC_4122 or id.version != 1:
-                    raise ValueError("When using time partitioning, id must be a v1 uuid")
-
         metadata_is_dict = isinstance(records[0][1], dict)
         if metadata_is_dict:
            records = map(lambda item: Async._convert_record_meta_to_json(item), records)
@@ -813,12 +810,6 @@ def table_is_empty(self):
                 return rec == None
 
     def munge_record(self, records) -> Iterable[Tuple[uuid.UUID, str, str, List[float]]]:
-        if self.time_partition_interval is not None:
-            for record in records:
-                id = record[0]
-                if id.variant != uuid.RFC_4122 or id.version != 1:
-                    raise ValueError("When using time partitioning, id must be a v1 uuid")
-
         metadata_is_dict = isinstance(records[0][1], dict)
         if metadata_is_dict:
            records = map(lambda item: Sync._convert_record_meta_to_json(item), records)