Merge 08effb6 into 85ae7d6

flyteorg · May 31, 2023 · 120c0be · 120c0be
2 parents 85ae7d6 + 08effb6
commit 120c0be
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/events/event_recorder.go b/events/event_recorder.go
@@ -42,6 +42,9 @@ type eventRecorder struct {
 }
 
 func (r *eventRecorder) sinkEvent(ctx context.Context, event proto.Message) error {
+	deadline := time.Now().Add(10 * time.Minute)
+	ctx, cancelCtx := context.WithDeadline(ctx, deadline)
+	defer cancelCtx()
 	startTime := time.Now()
 
 	err := r.eventSink.Sink(ctx, event)