From 982262c6b899cc882a2b5707f58c236e489eea96 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Sybren=20A=2E=20St=C3=BCvel?= Date: Wed, 26 Jun 2024 12:36:35 +0200 Subject: [PATCH] Manager: add more logging of job & task creation This may help to debug things like task dependencies. --- internal/manager/persistence/jobs.go | 29 ++++++++++++++++++++++++++++ 1 file changed, 29 insertions(+) diff --git a/internal/manager/persistence/jobs.go b/internal/manager/persistence/jobs.go index 17333bdb..30a1af21 100644 --- a/internal/manager/persistence/jobs.go +++ b/internal/manager/persistence/jobs.go @@ -162,6 +162,13 @@ func (db *DB) StoreAuthoredJob(ctx context.Context, authoredJob job_compilers.Au }, } + log.Debug(). + Str("job", dbJob.UUID). + Str("type", dbJob.JobType). + Str("name", dbJob.Name). + Str("status", string(dbJob.Status)). + Msg("persistence: storing authored job") + // Find and assign the worker tag. if authoredJob.WorkerTagUUID != "" { dbTag, err := fetchWorkerTag(tx, authoredJob.WorkerTagUUID) @@ -218,6 +225,15 @@ func (db *DB) storeAuthoredJobTaks( Commands: commands, // dependencies are stored below. } + + log.Debug(). + Str("task", dbTask.UUID). + Str("job", dbJob.UUID). + Str("type", dbTask.Type). + Str("name", dbTask.Name). + Str("status", string(dbTask.Status)). + Msg("persistence: storing authored task") + if err := tx.Create(&dbTask).Error; err != nil { return taskError(err, "storing task: %v", err) } @@ -244,6 +260,19 @@ func (db *DB) storeAuthoredJobTaks( } deps[i] = depTask } + + if log.Debug().Enabled() { + depNames := make([]string, len(deps)) + for i, dep := range deps { + depNames[i] = dep.Name + } + log.Debug(). + Str("task", dbTask.UUID). + Str("name", dbTask.Name). + Strs("dependencies", depNames). + Msg("persistence: storing authored task dependencies") + } + dependenciesbatchsize := 1000 for j := 0; j < len(deps); j += dependenciesbatchsize { end := j + dependenciesbatchsize