mirror/hatchet
1
0
Fork 0
mirror of https://github.com/hatchet-dev/hatchet.git synced 2026-01-06 08:49:53 -06:00
Code Issues Packages Projects Releases Wiki Activity

debug: stuck queries

Browse Source
This commit is contained in:
mrkaye97
2025-10-10 20:58:35 -04:00
parent 8e54fe96fd
commit 8fda64adc4
1 changed files with 5 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
pkg/repository/v1/olap.go
View File

@@ -1250,7 +1250,7 @@ func (r *OLAPRepositoryImpl) UpdateDAGStatuses(ctx context.Context, tenantIds []
partitionNumber := i
eg.Go(func() error {
tx, commit, rollback, err := sqlchelpers.PrepareTx(ctx, r.pool, r.l, 15000)
tx, commit, rollback, err := sqlchelpers.PrepareTx(ctx, r.pool, r.l, 30000)
if err != nil {
return fmt.Errorf("failed to prepare transaction: %w", err)
@@ -1264,6 +1264,8 @@ func (r *OLAPRepositoryImpl) UpdateDAGStatuses(ctx context.Context, tenantIds []
Eventlimit: limit,
})
fmt.Println("minInsertedAt", minInsertedAt, err)
if err != nil {
return fmt.Errorf("failed to find min inserted at for DAG status updates: %w", err)
}
@@ -1275,6 +1277,8 @@ func (r *OLAPRepositoryImpl) UpdateDAGStatuses(ctx context.Context, tenantIds []
Mininsertedat: minInsertedAt,
})
fmt.Println("statusUpdateRes", statusUpdateRes, err)
if err != nil {
return fmt.Errorf("failed to update DAG statuses: %w", err)
}