From 7950a51b5188234f855b987bc086ec39d9eb02bd Mon Sep 17 00:00:00 2001 From: Andrea Frittoli Date: Fri, 24 Jul 2020 09:46:41 +0100 Subject: [PATCH] Use cloud event native retries The cloud events sdk supports retries with backoff. Enable them for cloud events sent by the cloud event pipeline resource. --- pkg/reconciler/events/cloudevent/cloud_event_controller.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pkg/reconciler/events/cloudevent/cloud_event_controller.go b/pkg/reconciler/events/cloudevent/cloud_event_controller.go index f7b5a6d1f9f..c2f213d626e 100644 --- a/pkg/reconciler/events/cloudevent/cloud_event_controller.go +++ b/pkg/reconciler/events/cloudevent/cloud_event_controller.go @@ -94,7 +94,7 @@ func SendCloudEvents(tr *v1beta1.TaskRun, ceclient CEClient, logger *zap.Sugared } // Send the event. - result := ceclient.Send(cloudevents.ContextWithTarget(context.Background(), cloudEventDelivery.Target), *event) + result := ceclient.Send(cloudevents.ContextWithTarget(cloudevents.ContextWithRetriesExponentialBackoff(context.Background(), 10*time.Millisecond, 10), cloudEventDelivery.Target), *event) // Record the result. eventStatus.SentAt = &metav1.Time{Time: time.Now()}