reporter: make custom query fetch timeout configurable

Author: root

README.md

@@ -46,6 +46,8 @@ Custom query API keys are read from the generated `custom_query_config.toml` ent
 
 Custom query JSON API responses are cached briefly in memory to reduce duplicate upstream calls during fast cycle-list polling. Set `CUSTOM_QUERY_CACHE_TTL` to a Go duration such as `3s` or `500ms` to tune the freshness window. The default is `3s`; set it to `0` to disable this cache.
 
+The full custom-query fetch is limited to five seconds by default. Set `CUSTOM_QUERY_FETCH_TIMEOUT` to a positive Go duration such as `2s` to preserve more of the reporting window for transaction submission when an optional source is slow.
+
 ## Task loops
 
 ## PriceFetcher

custom_query/request.go

@@ -4,6 +4,7 @@ import (
 	"context"
 	"fmt"
 	"math"
+	"os"
 	"strconv"
 	"strings"
 	"sync"
@@ -19,6 +20,25 @@ import (
 	"github.com/cosmos/cosmos-sdk/telemetry"
 )
 
+const (
+	customQueryFetchTimeoutEnv     = "CUSTOM_QUERY_FETCH_TIMEOUT"
+	defaultCustomQueryFetchTimeout = 5 * time.Second
+)
+
+func customQueryFetchTimeout() time.Duration {
+	rawTimeout := strings.TrimSpace(os.Getenv(customQueryFetchTimeoutEnv))
+	if rawTimeout == "" {
+		return defaultCustomQueryFetchTimeout
+	}
+
+	timeout, err := time.ParseDuration(rawTimeout)
+	if err != nil || timeout <= 0 {
+		return defaultCustomQueryFetchTimeout
+	}
+
+	return timeout
+}
+
 // Result holds the value returned from an endpoint
 type Result struct {
 	Value      float64
@@ -65,8 +85,8 @@ func FetchPrice(
 	query QueryConfig,
 	priceCache *pricefeedservertypes.MarketToExchangePrices,
 ) (*FetchPriceResult, error) {
-	// Create a context with timeout
-	ctx, cancel := context.WithTimeout(ctx, 5*time.Second)
+	// Bound the full fetch so reporting still has time to submit before the cycle closes.
+	ctx, cancel := context.WithTimeout(ctx, customQueryFetchTimeout())
 	defer cancel()
 
 	totalEndpoints := len(query.RpcReaders) + len(query.ContractReaders) + len(query.CombinedReaders)

custom_query/request_timeout_test.go

@@ -0,0 +1,53 @@
+package customquery
+
+import (
+	"testing"
+	"time"
+
+	"github.com/stretchr/testify/require"
+)
+
+func TestCustomQueryFetchTimeout(t *testing.T) {
+	tests := []struct {
+		name     string
+		value    string
+		expected time.Duration
+	}{
+		{
+			name:     "unset uses default",
+			expected: defaultCustomQueryFetchTimeout,
+		},
+		{
+			name:     "valid duration",
+			value:    "2s",
+			expected: 2 * time.Second,
+		},
+		{
+			name:     "surrounding whitespace",
+			value:    " 1500ms ",
+			expected: 1500 * time.Millisecond,
+		},
+		{
+			name:     "invalid duration uses default",
+			value:    "soon",
+			expected: defaultCustomQueryFetchTimeout,
+		},
+		{
+			name:     "zero duration uses default",
+			value:    "0s",
+			expected: defaultCustomQueryFetchTimeout,
+		},
+		{
+			name:     "negative duration uses default",
+			value:    "-1s",
+			expected: defaultCustomQueryFetchTimeout,
+		},
+	}
+
+	for _, test := range tests {
+		t.Run(test.name, func(t *testing.T) {
+			t.Setenv(customQueryFetchTimeoutEnv, test.value)
+			require.Equal(t, test.expected, customQueryFetchTimeout())
+		})
+	}
+}