diff --git a/pkg/agent/worker.go b/pkg/agent/worker.go index f7aed2aed..c8e011d53 100644 --- a/pkg/agent/worker.go +++ b/pkg/agent/worker.go @@ -280,6 +280,10 @@ func (w *Worker) sendRequest(req *livekit.ServerMessage) { } } +func (w *Worker) APIKey() string { + return w.apiKey +} + func (w *Worker) Status() livekit.WorkerStatus { w.mu.Lock() defer w.mu.Unlock() diff --git a/pkg/service/agentservice.go b/pkg/service/agentservice.go index b4fc76d2c..09234f223 100644 --- a/pkg/service/agentservice.go +++ b/pkg/service/agentservice.go @@ -404,7 +404,7 @@ func (h *AgentHandler) JobRequest(ctx context.Context, job *livekit.Job) (*rpc.J state, err := selected.AssignJob(ctx, job) switch state.GetStatus() { case livekit.JobStatus_JS_RUNNING: - logger.Infow("assigned job to worker") + logger.Infow("assigned job to worker", "apiKey", selected.APIKey()) h.mu.Lock() h.jobToWorker[livekit.JobID(job.Id)] = selected h.mu.Unlock()