Skip to content

Commit

Permalink
fix: typo in batch job
Browse files Browse the repository at this point in the history
  • Loading branch information
highpon committed Oct 20, 2024
1 parent 0a8b332 commit 2961236
Show file tree
Hide file tree
Showing 5 changed files with 5 additions and 5 deletions.
2 changes: 1 addition & 1 deletion pkg/index/job/creation/service/indexer.go
Original file line number Diff line number Diff line change
Expand Up @@ -175,7 +175,7 @@ func (idx *index) doCreateIndex(
switch {
case errors.Is(err, context.Canceled):
err = status.WrapWithCanceled(
agent.CreateIndexRPCName+" API canceld", err,
agent.CreateIndexRPCName+" API canceled", err,
)
attrs = trace.StatusCodeCancelled(err.Error())
case errors.Is(err, context.DeadlineExceeded):
Expand Down
2 changes: 1 addition & 1 deletion pkg/index/job/creation/usecase/creation.go
Original file line number Diff line number Diff line change
Expand Up @@ -208,7 +208,7 @@ func (r *run) Stop(ctx context.Context) (errs error) {
return errs
}

// PtopStop is a method called after execution of Stop.
// PostStop is a method called after execution of Stop.
func (*run) PostStop(_ context.Context) error {
return nil
}
2 changes: 1 addition & 1 deletion pkg/index/job/readreplica/rotate/usecase/rotate.go
Original file line number Diff line number Diff line change
Expand Up @@ -165,7 +165,7 @@ func (r *run) Stop(ctx context.Context) (errs error) {
return errs
}

// PtopStop is a method called after execution of Stop.
// PostStop is a method called after execution of Stop.
func (*run) PostStop(_ context.Context) error {
return nil
}
2 changes: 1 addition & 1 deletion pkg/index/job/save/service/indexer.go
Original file line number Diff line number Diff line change
Expand Up @@ -171,7 +171,7 @@ func (idx *index) doSaveIndex(
switch {
case errors.Is(err, context.Canceled):
err = status.WrapWithCanceled(
agent.SaveIndexRPCName+" API canceld", err,
agent.SaveIndexRPCName+" API canceled", err,
)
attrs = trace.StatusCodeCancelled(err.Error())
case errors.Is(err, context.DeadlineExceeded):
Expand Down
2 changes: 1 addition & 1 deletion pkg/index/job/save/usecase/save.go
Original file line number Diff line number Diff line change
Expand Up @@ -207,7 +207,7 @@ func (r *run) Stop(ctx context.Context) (errs error) {
return errs
}

// PtopStop is a method called after execution of Stop.
// PostStop is a method called after execution of Stop.
func (*run) PostStop(_ context.Context) error {
return nil
}

0 comments on commit 2961236

Please sign in to comment.