update: [schedule] node_id change to node

weplanx · Aug 24, 2023 · 075c0a7 · 075c0a7
1 parent 5658975
commit 075c0a7
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/schedule/bootstrap/bootstrap.go b/schedule/bootstrap/bootstrap.go
@@ -63,6 +63,6 @@ func UseJetStream(nc *nats.Conn) (nats.JetStreamContext, error) {
 
 func UseKeyValue(values *common.Values, js nats.JetStreamContext) (nats.KeyValue, error) {
 	return js.CreateKeyValue(&nats.KeyValueConfig{
-		Bucket: fmt.Sprintf(`%s_schedules_%s`, values.Namespace, values.Id),
+		Bucket: fmt.Sprintf(`%s_schedules_%s`, values.Namespace, values.Node),
 	})
 }