diff --git a/internal/services/controllers/v1/olap/process_task_status_updates.go b/internal/services/controllers/v1/olap/process_task_status_updates.go
index 0cf371c4b..a5132513b 100644
--- a/internal/services/controllers/v1/olap/process_task_status_updates.go
+++ b/internal/services/controllers/v1/olap/process_task_status_updates.go
@@ -45,7 +45,7 @@ func (o *OLAPControllerImpl) runTaskStatusUpdates(ctx context.Context) func() {
 			shouldContinue, rows, err = o.repo.OLAP().UpdateTaskStatuses(ctx, tenantIds)
 
 			if err != nil {
-				o.l.Error().Err(err).Msg("could not update DAG statuses")
+				o.l.Error().Err(err).Msg("could not update task statuses")
 				return
 			}