diff --git a/services/horizon/internal/txsub/results.go b/services/horizon/internal/txsub/results.go
index 21b5939aca..060497188a 100644
--- a/services/horizon/internal/txsub/results.go
+++ b/services/horizon/internal/txsub/results.go
@@ -55,7 +55,7 @@ func txResultFromHistory(tx history.Transaction) (history.Transaction, error) {
 // queries execute on different ledgers. In this case, txsub can mistakenly respond with a bad_seq error
 // because the first query occurs when the tx is not yet ingested and the second query occurs when the tx
 // is ingested.
-func checkTxAlreadyExists(ctx context.Context, db HorizonDB, hash, sourceAddress string) (history.Transaction, error) {
+func checkTxAlreadyExists(ctx context.Context, db HorizonDB, hash string) (history.Transaction, error) {
 	err := db.BeginTx(ctx, &sql.TxOptions{
 		Isolation: sql.LevelRepeatableRead,
 		ReadOnly:  true,
diff --git a/services/horizon/internal/txsub/system.go b/services/horizon/internal/txsub/system.go
index a6fcc4f282..4f57976284 100644
--- a/services/horizon/internal/txsub/system.go
+++ b/services/horizon/internal/txsub/system.go
@@ -120,7 +120,7 @@ func (sys *System) Submit(
 		return
 	}
 
-	tx, err := checkTxAlreadyExists(ctx, db, hash, sourceAddress)
+	tx, err := checkTxAlreadyExists(ctx, db, hash)
 	if err == nil {
 		sys.Log.Ctx(ctx).WithField("hash", hash).Info("Found submission result in a DB")
 		sys.finish(ctx, hash, resultCh, Result{Transaction: tx})