diff --git a/services/accountmanager/dirk/parameters.go b/services/accountmanager/dirk/parameters.go index 4efac14..a8b0e91 100644 --- a/services/accountmanager/dirk/parameters.go +++ b/services/accountmanager/dirk/parameters.go @@ -156,17 +156,14 @@ func parseAndCheckParameters(params ...Parameter) (*parameters, error) { } } - if parameters.processConcurrency == 0 { - return nil, errors.New("no process concurrency specified") - } if parameters.monitor == nil { return nil, errors.New("no monitor specified") } if parameters.clientMonitor == nil { return nil, errors.New("no client monitor specified") } - if parameters.processConcurrency <= 0 { - return nil, errors.New("process concurrency must be > 0") + if parameters.processConcurrency < 1 { + return nil, errors.New("no process concurrency specified") } if len(parameters.endpoints) == 0 { return nil, errors.New("no endpoints specified") diff --git a/services/accountmanager/dirk/service_test.go b/services/accountmanager/dirk/service_test.go index f5b1273..ab1d0a4 100644 --- a/services/accountmanager/dirk/service_test.go +++ b/services/accountmanager/dirk/service_test.go @@ -108,7 +108,7 @@ func TestService(t *testing.T) { dirk.WithFarFutureEpochProvider(farFutureEpochProvider), dirk.WithCurrentEpochProvider(chainTime), }, - err: "problem with parameters: process concurrency must be > 0", + err: "problem with parameters: no process concurrency specified", }, { name: "EndpointsNil", diff --git a/services/synccommitteemessenger/standard/parameters.go b/services/synccommitteemessenger/standard/parameters.go index 95da047..df3e7a0 100644 --- a/services/synccommitteemessenger/standard/parameters.go +++ b/services/synccommitteemessenger/standard/parameters.go @@ -150,7 +150,7 @@ func parseAndCheckParameters(params ...Parameter) (*parameters, error) { } } - if parameters.processConcurrency == 0 { + if parameters.processConcurrency < 1 { return nil, errors.New("no process concurrency specified") } if parameters.monitor == nil {