diff --git a/src/Appwrite/Platform/Modules/Databases/Http/Databases/Collections/Documents/Create.php b/src/Appwrite/Platform/Modules/Databases/Http/Databases/Collections/Documents/Create.php
index e68a27ba34..6005495a68 100644
--- a/src/Appwrite/Platform/Modules/Databases/Http/Databases/Collections/Documents/Create.php
+++ b/src/Appwrite/Platform/Modules/Databases/Http/Databases/Collections/Documents/Create.php
@@ -56,7 +56,6 @@ class Create extends Action
             ->setHttpPath('/v1/databases/:databaseId/collections/:collectionId/documents')
             ->desc('Create document')
             ->groups(['api', 'database'])
-            ->label('event', 'databases.[databaseId].collections.[collectionId].documents.[documentId].create')
             ->label('scope', 'documents.write')
             ->label('resourceType', RESOURCE_TYPE_DATABASES)
             ->label('audits.event', 'document.create')
@@ -418,12 +417,6 @@ class Create extends Action
 
         $response->setStatusCode(SwooleResponse::STATUS_CODE_CREATED);
 
-        // BIG TODO: @itznotabug - need to check what to do for bulk api because there's not just one `[document/rowId]`.
-        $queueForEvents
-            ->setParam('documentId', $documents[0]->getId())
-            ->setParam('rowId', $documents[0]->getId())
-            // TODO: @itznotabug - check if the events mirroring works here!
-            ->setEvent('databases.[databaseId].collections.[collectionId].documents.[documentId].create');
 
         if ($isBulk) {
             $response->dynamic(new Document([
@@ -434,6 +427,11 @@ class Create extends Action
             return;
         }
 
+        $queueForEvents
+            ->setParam('documentId', $documents[0]->getId())
+            ->setParam('rowId', $documents[0]->getId())
+            ->setEvent('databases.[databaseId].collections.[collectionId].documents.[documentId].create');
+
         $response->dynamic(
             $documents[0],
             $this->getResponseModel()