From add2f31b6ca97c0cac2e64f0d11e19d361a81bd3 Mon Sep 17 00:00:00 2001
From: kaleofduty <59616916+kaleofduty@users.noreply.github.com>
Date: Fri, 12 May 2023 01:15:51 +0200
Subject: [PATCH] Experimental LOOPP-enabling adjustment to MaxDurationQuery

---
 .../internal/protocol/report_generation_leader.go         | 8 +++++++-
 1 file changed, 7 insertions(+), 1 deletion(-)

diff --git a/offchainreporting2/internal/protocol/report_generation_leader.go b/offchainreporting2/internal/protocol/report_generation_leader.go
index 0c689914..733b9a45 100644
--- a/offchainreporting2/internal/protocol/report_generation_leader.go
+++ b/offchainreporting2/internal/protocol/report_generation_leader.go
@@ -75,7 +75,13 @@ func (repgen *reportGenerationState) startRound() {
 	repgen.leaderState.readyToStartRound = false
 	var query types.Query
 	{
-		ctx, cancel := context.WithTimeout(repgen.ctx, repgen.config.MaxDurationQuery)
+		maxDurationQuery := repgen.config.MaxDurationQuery
+		if maxDurationQuery == 0 {
+			// Some feeds are configured to zero due to the in-memory implementation of Query being a no-op.
+			// This is incompatible with GRPC/LOOPPs, which short circuits on the cancelled context, so we override the value.
+			maxDurationQuery = 500 * time.Millisecond // TODO from config?
+		}
+		ctx, cancel := context.WithTimeout(repgen.ctx, maxDurationQuery)
 		defer cancel()
 
 		ins := loghelper.NewIfNotStopped(