From fa20755d4bb158b770b44c8192a3e1b64ca61458 Mon Sep 17 00:00:00 2001 From: maicon Date: Wed, 3 Sep 2025 11:49:04 -0300 Subject: [PATCH] fix: Synchronously notify subscribers when writing Create events to CDK backend (#110476) * Remove goroutine when writing events on CDK backend Signed-off-by: Maicon Costa --------- Signed-off-by: Maicon Costa --- pkg/storage/unified/resource/cdk_backend.go | 22 ++++++++++----------- 1 file changed, 10 insertions(+), 12 deletions(-) diff --git a/pkg/storage/unified/resource/cdk_backend.go b/pkg/storage/unified/resource/cdk_backend.go index fdabaca6759..f54e427cf88 100644 --- a/pkg/storage/unified/resource/cdk_backend.go +++ b/pkg/storage/unified/resource/cdk_backend.go @@ -146,19 +146,17 @@ func (s *cdkBackend) WriteEvent(ctx context.Context, event WriteEvent) (rv int64 }) } - // Async notify all subscribers + // notify all subscribers if s.stream != nil { - go func() { - write := &WrittenEvent{ - Type: event.Type, - Key: event.Key, - PreviousRV: event.PreviousRV, - Value: event.Value, - Timestamp: time.Now().UnixMilli(), - ResourceVersion: rv, - } - s.stream <- write - }() + write := &WrittenEvent{ + Type: event.Type, + Key: event.Key, + PreviousRV: event.PreviousRV, + Value: event.Value, + Timestamp: time.Now().UnixMilli(), + ResourceVersion: rv, + } + s.stream <- write } return rv, err }