diff --git a/packages/server/modules/core/services/streams/clone.ts b/packages/server/modules/core/services/streams/clone.ts
index 5b5dc9b50..4060c4db8 100644
--- a/packages/server/modules/core/services/streams/clone.ts
+++ b/packages/server/modules/core/services/streams/clone.ts
@@ -521,19 +521,16 @@ export const cloneStreamFactory =
       const { newStream } = coreCloneResult
       // Clone comments
       await cloneStreamCommentsFactory(deps)(state, coreCloneResult)
-      // Create activity item
-      await deps.addStreamClonedActivity(
-        {
-          sourceStreamId,
-          newStream,
-          clonerId: userId
-        },
-        { trx: state.trx }
-      )
 
       // Commit transaction
       await state.trx.commit()
 
+      // Create activity item
+      await deps.addStreamClonedActivity({
+        sourceStreamId,
+        newStream,
+        clonerId: userId
+      })
       return coreCloneResult.newStream
     } catch (e) {
       await state.trx.rollback()