diff --git a/app/publisher.go b/app/publisher.go index d73b1b2..996aef0 100644 --- a/app/publisher.go +++ b/app/publisher.go @@ -223,7 +223,7 @@ func (p *P) Deliver(ev *event.E) { // Use a separate context with timeout for writes to prevent race conditions // where the publisher context gets cancelled while writing events writeCtx, cancel := context.WithTimeout( - context.Background(), WriteTimeout, + context.Background(), DefaultWriteTimeout, ) defer cancel() diff --git a/pkg/version/version b/pkg/version/version index be5bf2a..6466da5 100644 --- a/pkg/version/version +++ b/pkg/version/version @@ -1 +1 @@ -v0.4.1 \ No newline at end of file +v0.4.2 \ No newline at end of file