We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 831e53b commit 7a4b798Copy full SHA for 7a4b798
cmd/etl_worker/etl_worker.go
@@ -285,6 +285,11 @@ func runPubSubHandler() error {
285
// concurrently processed, but NOT the number of messages
286
// in some kind of queue.
287
sub.ReceiveSettings.MaxOutstandingMessages = int(maxInFlight)
288
+ // The Receive function will automatically extend the deadline
289
+ // to this value.
290
+ // TODO(gfr) This may not be enough. Do we need to add logic
291
+ // inside ProcessAllTests?
292
+ sub.ReceiveSettings.MaxExtension = 600 * time.Second
293
294
// This seems to have no impact on the number of concurrent
295
// messages, and each concurrently processed message is
0 commit comments