From 506687987fc2f8f40b2918782fc2943285fdc602 Mon Sep 17 00:00:00 2001 From: Aleksandr Nogikh Date: Wed, 19 Feb 2025 15:57:58 +0100 Subject: syz-cluster/controller: add more logging That should hopefully shed more light on #5776. --- syz-cluster/controller/processor.go | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) (limited to 'syz-cluster/controller/processor.go') diff --git a/syz-cluster/controller/processor.go b/syz-cluster/controller/processor.go index 532bfca3a..809640f0e 100644 --- a/syz-cluster/controller/processor.go +++ b/syz-cluster/controller/processor.go @@ -140,19 +140,20 @@ func (sp *SeriesProcessor) handleSession(ctx context.Context, session *db.Sessio case <-ctx.Done(): return } - status, log, err := sp.workflows.Status(session.ID) + status, workflowLog, err := sp.workflows.Status(session.ID) if err != nil { app.Errorf("failed to query workflow %q status: %v", session.ID, err) continue } - if log != nil { - err := sp.updateSessionLog(ctx, session, log) + if workflowLog != nil { + err := sp.updateSessionLog(ctx, session, workflowLog) if err != nil { app.Errorf("failed to update session log: %v", err) } } switch status { case workflow.StatusNotFound: + log.Printf("scheduling a workflow for %q", session.ID) if err := sp.sessionRepo.Start(ctx, session.ID); err != nil { app.Errorf("failed to mark session started: %v", err) break @@ -162,6 +163,7 @@ func (sp *SeriesProcessor) handleSession(ctx context.Context, session *db.Sessio app.Errorf("failed to start a workflow: %v", err) } case workflow.StatusFinished, workflow.StatusFailed: + log.Printf("workflow for %q completed, mark the session finished", session.ID) // TODO: StatusFailed needs a different handling. err := sp.sessionRepo.Update(ctx, session.ID, func(session *db.Session) error { session.SetFinishedAt(time.Now()) -- cgit mrf-deployment