diff --git a/scheduler/queue/worker.go b/scheduler/queue/worker.go
index 9e17b859de..556051f804 100644
--- 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
index db9cd57833..666ef31f76 100644
--- 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.