diff --git a/server/task.go b/server/task.go index f048fa3..6691b1f 100644 --- a/server/task.go +++ b/server/task.go @@ -366,7 +366,7 @@ func assignQueuedTasks(ctx context.Context) error { return fmt.Errorf("Error Querying Worker Task Count: %w", err) } - slog.Info("Assigning Queued Tasks Worker", "worker", i, "count", count) + slog.Debug("Assigning Queued Tasks Worker", "worker", i, "count", count) // Allow for Multiple Tasks at once in the future if count < 1 { diff --git a/server/worker.go b/server/worker.go index ed8322e..caffd57 100644 --- a/server/worker.go +++ b/server/worker.go @@ -129,7 +129,7 @@ func readMessage(ctx context.Context, c *websocket.Conn) error { if err != nil { return err } - slog.InfoContext(ctx, "Got Websocket Message", "type", t.String(), "data", data) + slog.DebugContext(ctx, "Got Websocket Message", "type", t.String(), "data", data) rpcServer.HandleMessage(ctx, c, data) return nil } diff --git a/worker/worker.go b/worker/worker.go index 411c872..75bd1bd 100644 --- a/worker/worker.go +++ b/worker/worker.go @@ -116,7 +116,7 @@ func readMessage(ctx context.Context, c *websocket.Conn) error { if err != nil { return err } - slog.InfoContext(ctx, "Got Websocket Message", "type", t.String(), "data", data) + slog.DebugContext(ctx, "Got Websocket Message", "type", t.String(), "data", data) rpcServer.HandleMessage(ctx, c, data) return nil }