diff --git a/pkg/repository/v1/olap.go b/pkg/repository/v1/olap.go
index ffd234b06..9816770de 100644
--- a/pkg/repository/v1/olap.go
+++ b/pkg/repository/v1/olap.go
@@ -1247,11 +1247,14 @@ func (r *OLAPRepositoryImpl) UpdateDAGStatuses(ctx context.Context, tenantIds []
 	}
 
 	for i := 0; i < NUM_PARTITIONS; i++ {
+		fmt.Println("running dag status updates for partition", i)
 		partitionNumber := i
 
 		eg.Go(func() error {
 			tx, commit, rollback, err := sqlchelpers.PrepareTx(ctx, r.pool, r.l, 30000)
 
+			fmt.Println("prepared tx")
+
 			if err != nil {
 				return fmt.Errorf("failed to prepare transaction: %w", err)
 			}