chore: remove repetitive words

ingest/ledger_change_reader.go

@@ -120,7 +120,7 @@ func (c *compactingChangeReader) Close() error {
 }
 
 // NewCompactingChangeReader wraps a given ChangeReader and returns a ChangeReader
-// which compacts all the the Changes extracted from the input.
+// which compacts all the Changes extracted from the input.
 func NewCompactingChangeReader(input ChangeReader) ChangeReader {
 	return &compactingChangeReader{
 		input: input,

ingest/ledgerbackend/ledger_buffer.go

@@ -153,7 +153,7 @@ func (lb *ledgerBuffer) worker(ctx context.Context) {
 				// When we store an object we still maintain the ledger buffer invariant because
 				// at this point the current task is finished and we add 1 ledger object to the priority queue.
 				// Thus, the number of tasks decreases by 1 and the priority queue length increases by 1.
-				// This keeps the overall total the same (<= BufferSize). As long as the the ledger buffer invariant
+				// This keeps the overall total the same (<= BufferSize). As long as the ledger buffer invariant
 				// was maintained in the previous state, it is still maintained during this state transition.
 				lb.storeObject(ledgerObject, sequence)
 				break

services/horizon/internal/ingest/orderbook.go

@@ -315,7 +315,7 @@ func (o *OrderBookStream) verifyAllLiquidityPools(ctx context.Context, liquidity
 
 // Update will query the Horizon DB for offers which have been created, removed, or updated since the
 // last time Update() was called. Those changes will then be applied to the in memory order book graph.
-// After calling this function, the the in memory order book graph should be consistent with the
+// After calling this function, the in memory order book graph should be consistent with the
 // Horizon DB (assuming no error is returned).
 func (o *OrderBookStream) Update(ctx context.Context) error {
 	if err := o.historyQ.BeginTx(ctx, &sql.TxOptions{ReadOnly: true, Isolation: sql.LevelRepeatableRead}); err != nil {

services/regulated-assets-approval-server/internal/serve/tx_approve_test.go

@@ -233,7 +233,7 @@ func TestTxApproveHandler_handleActionRequiredResponseIfNeeded(t *testing.T) {
 		db:           conn,
 	}
 
-	// payments up to the the threshold won't trigger "action_required"
+	// payments up to the threshold won't trigger "action_required"
 	clientKP := keypair.MustRandom()
 	paymentOp := &txnbuild.Payment{
 		Amount: amount.StringFromInt64(kycThreshold),