diff --git a/packages/server/modules/core/services/streams/clone.ts b/packages/server/modules/core/services/streams/clone.ts
index ae812402e..c17352ab6 100644
--- a/packages/server/modules/core/services/streams/clone.ts
+++ b/packages/server/modules/core/services/streams/clone.ts
@@ -18,9 +18,9 @@ import {
   getBatchedStreamCommits,
   generateCommitId,
   insertCommits,
-  insertStreamCommits,
   getBatchedBranchCommits,
-  insertBranchCommits
+  insertStreamCommitsFactory,
+  insertBranchCommitsFactory
 } from '@/modules/core/repositories/commits'
 import { chunk } from 'lodash'
 import {
@@ -192,7 +192,7 @@ async function createStreamCommitReferences(
   const batchedNewCommitIds = chunk(newCommitIds, batchSize)
 
   for (const newCommitIdBatch of batchedNewCommitIds) {
-    await insertStreamCommits(
+    await insertStreamCommitsFactory({ db })(
       newCommitIdBatch.map(
         (id): StreamCommitRecord => ({
           streamId: newStreamId,
@@ -257,7 +257,7 @@ async function createBranchCommitReferences(
       return { commitId: newCommitId, branchId: newBranchId }
     })
 
-    await insertBranchCommits(newBranchCommits, { trx: state.trx })
+    await insertBranchCommitsFactory({ db })(newBranchCommits, { trx: state.trx })
   }
 }