diff --git a/src/Appwrite/Platform/Workers/Migrations.php b/src/Appwrite/Platform/Workers/Migrations.php
index db2b778834..4782de001e 100644
--- a/src/Appwrite/Platform/Workers/Migrations.php
+++ b/src/Appwrite/Platform/Workers/Migrations.php
@@ -308,6 +308,9 @@ class Migrations extends Action
             $migrationDocument->setAttribute('stage', 'migrating');
             $log->addBreadcrumb(new Breadcrumb("debug", "migration", "Migration hit stage 'migrating'", \microtime(true)));
             $this->updateMigrationDocument($migrationDocument, $projectDocument);
+
+            $destination->init();
+
             $transfer->run($migrationDocument->getAttribute('resources'), function () use ($migrationDocument, $transfer, $projectDocument) {
                 $migrationDocument->setAttribute('resourceData', json_encode($transfer->getCache()));
                 $migrationDocument->setAttribute('statusCounters', json_encode($transfer->getStatusCounters()));
@@ -315,6 +318,8 @@ class Migrations extends Action
                 $this->updateMigrationDocument($migrationDocument, $projectDocument);
             });
 
+            $destination->shutDown();
+
             $sourceErrors = $source->getErrors();
             $destinationErrors = $destination->getErrors();