diff --git a/src/Appwrite/Databases/TransactionState.php b/src/Appwrite/Databases/TransactionState.php
index 495a7b70ef..c20eac3d1a 100644
--- a/src/Appwrite/Databases/TransactionState.php
+++ b/src/Appwrite/Databases/TransactionState.php
@@ -79,7 +79,9 @@ class TransactionState
                     break;
 
                 case 'upsert':
-                    $state[$collectionId][$documentId] = [
+                    $docId = $documentId ?? ($data['$id'] ?? null);
+                    if (!$docId) { break; }
+                    $state[$collectionId][$docId] = [
                         'action' => 'upsert',
                         'document' => new Document($data),
                         'exists' => true