From e3778b711f752922a1d9d47010d799f2ab4cec3e Mon Sep 17 00:00:00 2001
From: luke-lombardi <33990301+luke-lombardi@users.noreply.github.com>
Date: Sun, 6 Oct 2024 13:02:21 -0400
Subject: [PATCH] bump processing interval back up to 100ms

---
 pkg/abstractions/endpoint/buffer.go | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/pkg/abstractions/endpoint/buffer.go b/pkg/abstractions/endpoint/buffer.go
index 1e410b1d3..0fe2583ae 100644
--- a/pkg/abstractions/endpoint/buffer.go
+++ b/pkg/abstractions/endpoint/buffer.go
@@ -26,7 +26,7 @@ import (
 )
 
 const (
-	requestProcessingInterval time.Duration = time.Millisecond * 50
+	requestProcessingInterval time.Duration = time.Millisecond * 100
 )
 
 type request struct {
@@ -478,6 +478,8 @@ func (rb *RequestBuffer) heartBeat(req request, containerId string) {
 	rb.rdb.Set(rb.ctx, Keys.endpointRequestHeartbeat(rb.workspace.Name, rb.stubId, req.task.msg.TaskId), containerId, endpointRequestHeartbeatInterval)
 	for {
 		select {
+		case <-req.done:
+			return
 		case <-ctx.Done():
 			if err := req.ctx.Request().Context().Err(); err == context.Canceled {
 				rb.cancelInFlightTask(req.task)