Skip to content

Commit c895042

Browse files
committed
debug log messages
1 parent 005cc02 commit c895042

File tree

1 file changed

+1
-4
lines changed

1 file changed

+1
-4
lines changed

internal/watcher/watcher_plugin.go

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -175,7 +175,6 @@ func (w *Watcher) handleConfigApplyRequest(ctx context.Context, msg *bus.Message
175175
defer w.watcherMutex.Unlock()
176176
w.instancesWithConfigApplyInProgress = append(w.instancesWithConfigApplyInProgress, instanceID)
177177

178-
slog.DebugContext(ctx, "Config Apply in progress: Disabling watchers...")
179178
w.fileWatcherService.SetEnabled(false)
180179
}
181180

@@ -198,7 +197,6 @@ func (w *Watcher) handleConfigApplySuccess(ctx context.Context, msg *bus.Message
198197
},
199198
)
200199

201-
slog.DebugContext(ctx, "Config Apply succeeded: re-enabling watchers...")
202200
w.fileWatcherService.SetEnabled(true)
203201
w.watcherMutex.Unlock()
204202

@@ -232,11 +230,10 @@ func (w *Watcher) handleConfigApplyComplete(ctx context.Context, msg *bus.Messag
232230
)
233231

234232
w.fileWatcherService.SetEnabled(true)
235-
w.credentialWatcherService.SetEnabled(true)
236233
}
237234

238235
func (w *Watcher) handleCredentialUpdate(ctx context.Context) {
239-
slog.DebugContext(ctx, "Watcher plugin received credential update: resetting grpc connection")
236+
slog.DebugContext(ctx, "Received credential update topic")
240237

241238
conn, err := grpc.NewGrpcConnection(ctx, w.agentConfig)
242239
if err != nil {

0 commit comments

Comments
 (0)