fix: deepsource warning

Signed-off-by: hlts2 <[email protected]>
vdaas · Oct 31, 2023 · 381b0b7 · 381b0b7
1 parent c43d7c3
commit 381b0b7
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 3 deletions.
diff --git a/pkg/index/job/creation/service/options.go b/pkg/index/job/creation/service/options.go
@@ -48,7 +48,7 @@ func WithIndexingConcurrency(num int) Option {
 	}
 }
 
-// WithIndexingConcurrency returns Option that sets indexing pool size.
+// WithCreationPoolSize returns Option that sets indexing pool size.
 func WithCreationPoolSize(size uint32) Option {
 	return func(idx *index) error {
 		if size <= 0 {

diff --git a/pkg/index/job/creation/usecase/creation.go b/pkg/index/job/creation/usecase/creation.go
@@ -103,6 +103,9 @@ func New(cfg *config.Data) (_ runner.Runner, err error) {
 			}
 		}),
 	)
+	if err != nil {
+		return nil, err
+	}
 
 	var obs observability.Observability
 	if cfg.Observability.Enabled {
@@ -191,7 +194,7 @@ func (r *run) Start(ctx context.Context) (<-chan error, error) {
 }
 
 // PreStop is a method called before execution of Stop.
-func (_ *run) PreStop(_ context.Context) error {
+func (*run) PreStop(_ context.Context) error {
 	return nil
 }
 
@@ -211,6 +214,6 @@ func (r *run) Stop(ctx context.Context) (errs error) {
 }
 
 // PtopStop is a method called after execution of Stop.
-func (_ *run) PostStop(_ context.Context) error {
+func (*run) PostStop(_ context.Context) error {
 	return nil
 }