feat: Add logger to context

Przemyslaw Stepien · Przemyslaw Stepien · commit e31cdcfd705d · 2025-04-22T16:07:42.000+02:00
diff --git a/scheduler/queue/worker.go b/scheduler/queue/worker.go
@@ -75,6 +75,7 @@ func (w *worker) resolveTable(ctx context.Context, table *schema.Table, client s
 	)
 	defer span.End()
 	logger := w.logger.With().Str("table", table.Name).Str("client", clientName).Logger()
+	ctx = logger.WithContext(ctx)
 	startTime := time.Now()
 	if parent == nil { // Log only for root tables, otherwise we spam too much.
 		logger.Info().Msg("top level table resolver started")
diff --git a/scheduler/scheduler_dfs.go b/scheduler/scheduler_dfs.go
@@ -87,6 +87,7 @@ func (s *syncClient) resolveTableDfs(ctx context.Context, table *schema.Table, c
 	)
 	defer span.End()
 	logger := s.logger.With().Str("table", table.Name).Str("client", clientName).Logger()
+	ctx = logger.WithContext(ctx)
 
 	startTime := time.Now()
 	if parent == nil { // Log only for root tables, otherwise we spam too much.

Original file line number	Diff line number	Diff line change
`@@ -75,6 +75,7 @@ func (w worker) resolveTable(ctx context.Context, table schema.Table, client s`
`75`	`75`	`)`
`76`	`76`	`defer span.End()`
`77`	`77`	`logger := w.logger.With().Str("table", table.Name).Str("client", clientName).Logger()`
	`78`	`+ ctx = logger.WithContext(ctx)`
`78`	`79`	`startTime := time.Now()`
`79`	`80`	`if parent == nil { // Log only for root tables, otherwise we spam too much.`
`80`	`81`	`logger.Info().Msg("top level table resolver started")`
Original file line number	Diff line number	Diff line change
`@@ -87,6 +87,7 @@ func (s syncClient) resolveTableDfs(ctx context.Context, table schema.Table, c`
`87`	`87`	`)`
`88`	`88`	`defer span.End()`
`89`	`89`	`logger := s.logger.With().Str("table", table.Name).Str("client", clientName).Logger()`
	`90`	`+ ctx = logger.WithContext(ctx)`
`90`	`91`
`91`	`92`	`startTime := time.Now()`
`92`	`93`	`if parent == nil { // Log only for root tables, otherwise we spam too much.`