Fix FetchJobUpdates log line (armadaproject#3193)

Signed-off-by: Noah Held <[email protected]>
sarthaksarthak9 · Dec 13, 2023 · 4d19adf · 4d19adf
1 parent fd899b2
commit 4d19adf
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/internal/scheduler/database/job_repository.go b/internal/scheduler/database/job_repository.go
@@ -131,7 +131,9 @@ func (r *PostgresJobRepository) FetchJobUpdates(ctx *armadacontext.Context, jobS
 	var updatedRuns []Run = nil
 
 	start := time.Now()
-	defer ctx.Infof("received %d updated jobs and %d updated job runs from postgres in %s", len(updatedJobs), len(updatedRuns), time.Since(start))
+	defer func() {
+		ctx.Infof("received %d updated jobs and %d updated job runs from postgres in %s", len(updatedJobs), len(updatedRuns), time.Since(start))
+	}()
 
 	// Use a RepeatableRead transaction here so that we get consistency between jobs and dbRuns
 	err := pgx.BeginTxFunc(ctx, r.db, pgx.TxOptions{