From 08effb6bbef48c4975c527d0683f2e164c27c0d2 Mon Sep 17 00:00:00 2001 From: Katrina Rogan Date: Wed, 31 May 2023 15:53:51 -0700 Subject: [PATCH] Test out deadline with grpc Signed-off-by: Katrina Rogan --- events/event_recorder.go | 3 +++ 1 file changed, 3 insertions(+) diff --git a/events/event_recorder.go b/events/event_recorder.go index b07cc412b..bf7ce29bc 100644 --- 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)