Merge pull request #356 from appwrite/fix/python-sdk-model-access

Fix Python templates for Appwrite SDK 23 models

Author: ChiragAgg5k

.github/workflows/audit.yml

@@ -141,7 +141,7 @@ jobs:
           sdk: stable
       - uses: actions/setup-go@b7ad1dad31e06c5925ef5d2fc7ad053ef454303e # v7.0.0
         with:
-          go-version: "1.26.5"
+          go-version: "1.26.6"
       - name: Install OSV Scanner
         run: go install github.com/google/osv-scanner/v2/cmd/osv-scanner@${{ env.OSV_SCANNER_VERSION }}
       - name: Audit Dart templates
@@ -167,7 +167,7 @@ jobs:
       - uses: actions/checkout@3d3c42e5aac5ba805825da76410c181273ba90b1 # v7.0.1
       - uses: actions/setup-go@b7ad1dad31e06c5925ef5d2fc7ad053ef454303e # v7.0.0
         with:
-          go-version: "1.26.5"
+          go-version: "1.26.6"
           cache: false
       - name: Install govulncheck
         run: go install golang.org/x/vuln/cmd/govulncheck@v1.1.4
@@ -247,7 +247,7 @@ jobs:
       - uses: actions/checkout@3d3c42e5aac5ba805825da76410c181273ba90b1 # v7.0.1
       - uses: actions/setup-go@b7ad1dad31e06c5925ef5d2fc7ad053ef454303e # v7.0.0
         with:
-          go-version: "1.26.5"
+          go-version: "1.26.6"
       - name: Install OSV Scanner
         run: go install github.com/google/osv-scanner/v2/cmd/osv-scanner@${{ env.OSV_SCANNER_VERSION }}
       - name: Audit Maven coordinates in deps.gradle

python-ml/starter/requirements.txt

@@ -1,2 +1,2 @@
-appwrite
+appwrite==23.0.0
 numpy

python-ml/starter/src/main.py

@@ -12,15 +12,15 @@ def main(context):
         Client()
         .set_endpoint(os.environ["APPWRITE_FUNCTION_API_ENDPOINT"])
         .set_project(os.environ["APPWRITE_FUNCTION_PROJECT_ID"])
-        .set_key(context.req.headers["x-appwrite-key"])
+        .set_key(context.req.headers.get("x-appwrite-key", ""))
     )
     users = Users(client)
 
     try:
         response = users.list()
         # Log messages and errors to the Appwrite Console
         # These logs won't be seen by your end users
-        context.log("Total users: " + str(response["total"]))
+        context.log("Total users: " + str(response.total))
     except AppwriteException as err:
         context.error("Could not list users: " + repr(err))
 

python/starter/requirements.txt

@@ -1 +1 @@
-appwrite
+appwrite==23.0.0

python/starter/src/main.py

@@ -11,15 +11,15 @@ def main(context):
         Client()
         .set_endpoint(os.environ["APPWRITE_FUNCTION_API_ENDPOINT"])
         .set_project(os.environ["APPWRITE_FUNCTION_PROJECT_ID"])
-        .set_key(context.req.headers["x-appwrite-key"])
+        .set_key(context.req.headers.get("x-appwrite-key", ""))
     )
     users = Users(client)
 
     try:
         response = users.list()
         # Log messages and errors to the Appwrite Console
         # These logs won't be seen by your end users
-        context.log("Total users: " + str(response["total"]))
+        context.log("Total users: " + str(response.total))
     except AppwriteException as err:
         context.error("Could not list users: " + repr(err))
 

python/storage-cleaner/requirements.txt

@@ -1 +1 @@
-appwrite
+appwrite==23.0.0

python/storage-cleaner/src/appwrite_service.py

@@ -46,22 +46,22 @@ def clean_bucket(self, bucket_id: str):
                 raise RuntimeError(
                     f"Failed to list files from bucket {bucket_id}: {str(e)}"
                 ) from e
-            files = response.get("files", [])
+            files = response.files
 
             if not files:
                 break
 
             batch_failed = False
             with ThreadPoolExecutor() as executor:
                 future_to_file = {
-                    executor.submit(self.storage.delete_file, bucket_id, f.get("$id")): f
+                    executor.submit(self.storage.delete_file, bucket_id, f.id): f
                     for f in files
-                    if f.get("$id")
+                    if f.id
                 }
 
                 for future in as_completed(future_to_file):
                     file_info = future_to_file[future]
-                    file_id = file_info.get("$id")
+                    file_id = file_info.id
                     try:
                         future.result()
                         deleted_files_count += 1

python/sync_with_algolia/requirements.txt

@@ -1,2 +1,2 @@
-appwrite
+appwrite==23.0.0
 algoliasearch

python/sync_with_algolia/src/main.py

@@ -1,6 +1,7 @@
 import os
 from algoliasearch.search_client import SearchClient
 from appwrite.client import Client
+from appwrite.models import Document
 from appwrite.services.databases import Databases
 from appwrite.query import Query
 from .utils import get_static_file, throw_if_missing, interpolate
@@ -55,16 +56,19 @@ def main(context):
             queries,
         )
 
-        if len(response.documents) > 0:
-            cursor = response.documents[len(response.documents) - 1]["$id"]
+        documents: list[Document] = response.documents
+
+        if len(documents) > 0:
+            cursor = documents[-1].id
         else:
             context.log("No more documents found.")
             cursor = None
             break
 
-        context.log(f"Syncing chunk of {len(response.documents)} documents...")
+        context.log(f"Syncing chunk of {len(documents)} documents...")
         documents_with_object_ids = [
-            {"objectID": document["$id"], **document} for document in response.documents
+            {"objectID": document.id, "$id": document.id, **document.data}
+            for document in documents
         ]
         index.save_objects(documents_with_object_ids)
 

python/sync_with_meilisearch/requirements.txt

@@ -1,2 +1,2 @@
-appwrite
+appwrite==23.0.0
 meilisearch