diff --git a/src/Appwrite/Platform/Workers/Migrations.php b/src/Appwrite/Platform/Workers/Migrations.php
index ba88ee0c8e..339084727d 100644
--- a/src/Appwrite/Platform/Workers/Migrations.php
+++ b/src/Appwrite/Platform/Workers/Migrations.php
@@ -196,17 +196,23 @@ class Migrations extends Action
         /** @var Database|null $projectDB */
         $projectDB = null;
         $useAppwriteApiSource = false;
-        if ($credentials['projectId']) {
+        if ($source === SourceAppwrite::getName() && empty($credentials['projectId'])) {
+            throw new \Exception('Source projectId is required for Appwrite migrations');
+        }
+
+        if (! empty($credentials['projectId'])) {
             $this->sourceProject = $this->dbForPlatform->getDocument('projects', $credentials['projectId']);
-            if (! $this->sourceProject->isEmpty()) {
-                $sourceRegion = $this->sourceProject->getAttribute('region', 'default');
-                $destinationRegion = $this->project->getAttribute('region', 'default');
-                $useAppwriteApiSource = $source === SourceAppwrite::getName()
-                    && $destination === DestinationAppwrite::getName()
-                    && $sourceRegion !== $destinationRegion;
-                if (! $useAppwriteApiSource) {
-                    $projectDB = call_user_func($this->getProjectDB, $this->sourceProject);
-                }
+            if ($this->sourceProject->isEmpty()) {
+                throw new \Exception('Source project not found for provided projectId');
+            }
+
+            $sourceRegion = $this->sourceProject->getAttribute('region', 'default');
+            $destinationRegion = $this->project->getAttribute('region', 'default');
+            $useAppwriteApiSource = $source === SourceAppwrite::getName()
+                && $destination === DestinationAppwrite::getName()
+                && $sourceRegion !== $destinationRegion;
+            if (! $useAppwriteApiSource) {
+                $projectDB = call_user_func($this->getProjectDB, $this->sourceProject);
             }
         }
         $getDatabasesDB = fn (Document $database): Database =>