Skip to content

Commit c01476b

Browse files
committed
make linter happy
1 parent 3fa3a56 commit c01476b

File tree

3 files changed

+4
-3
lines changed

3 files changed

+4
-3
lines changed

internal/model/model.go

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -4,6 +4,7 @@ import (
44
"net"
55

66
"github.com/bmc-toolbox/common"
7+
78
rctypes "github.com/metal-toolbox/rivets/condition"
89
)
910

@@ -25,8 +26,6 @@ const (
2526
// conditions fulfilled by this worker
2627
Inventory rctypes.Kind = "inventory"
2728

28-
29-
3029
StoreKindCsv StoreKind = "csv"
3130
StoreKindServerservice StoreKind = "serverservice"
3231
StoreKindMock StoreKind = "mock"

internal/worker/kv_status.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -46,9 +46,9 @@ func createOrBindKVBucketWithOpts(s events.Stream, opts *events.NatsKVOptions) (
4646

4747
// statusKVPublisher updates the kv with task status information
4848
type statusKVPublisher struct {
49-
workerID string
5049
kv nats.KeyValue
5150
log *logrus.Logger
51+
workerID string
5252
}
5353

5454
func newStatusKVPublisher(s events.Stream, log *logrus.Logger, workerID string, opts *events.NatsKVOptions) (*statusKVPublisher, error) {

internal/worker/liveness.go

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -67,6 +67,7 @@ func (w *Worker) checkinRoutine(ctx context.Context) {
6767
WithField("id", w.id.String()).
6868
Warn("worker checkin failed")
6969
metrics.NATSError("liveness checkin")
70+
7071
if err = refreshWorkerToken(w.id); err != nil {
7172
w.logger.WithError(err).
7273
WithField("id", w.id.String()).
@@ -75,6 +76,7 @@ func (w *Worker) checkinRoutine(ctx context.Context) {
7576
}
7677
case <-ctx.Done():
7778
w.logger.Info("liveness check-in stopping on done context")
79+
7880
stop = true
7981
}
8082
}

0 commit comments

Comments
 (0)