diff options
Diffstat (limited to 'pkg/pool')
| -rwxr-xr-x | pkg/pool/static_pool.go | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/pkg/pool/static_pool.go b/pkg/pool/static_pool.go index 8c9d69b9..b5d97b8b 100755 --- a/pkg/pool/static_pool.go +++ b/pkg/pool/static_pool.go @@ -245,7 +245,7 @@ func (sp *StaticPool) Destroy(ctx context.Context) { func defaultErrEncoder(sp *StaticPool) ErrorEncoder { return func(err error, w worker.BaseProcess) (payload.Payload, error) { - const op = errors.Op("error encoder") + const op = errors.Op("error_encoder") // just push event if on any stage was timeout error switch { case errors.Is(errors.ExecTTL, err): |