diff --git a/federationapi/storage/shared/storage.go b/federationapi/storage/shared/storage.go
index d2924aaa2..289a71f50 100644
--- a/federationapi/storage/shared/storage.go
+++ b/federationapi/storage/shared/storage.go
@@ -384,7 +384,11 @@ func (d *Database) GetAsyncTransaction(
 		return nil, nil, nil
 	}
 
-	txns, err := d.FederationTransactionJSON.SelectTransactionJSON(ctx, nil, nids)
+	txns := map[int64][]byte{}
+	err = d.Writer.Do(d.DB, nil, func(txn *sql.Tx) error {
+		txns, err = d.FederationTransactionJSON.SelectTransactionJSON(ctx, txn, nids)
+		return err
+	})
 	if err != nil {
 		return nil, nil, fmt.Errorf("d.SelectTransactionJSON: %w", err)
 	}