Если воркер работает долго (около 2 минут), и при падении транзакция остаётся в базе, значит транзакция не была корректно завершена (commit/rollback), и база держит блокировки.

Что делать:

Использовать контекст с таймаутом в Go для ограничения времени выполнения транзакции. Например:

ctx, cancel := context.WithTimeout(context.Background(), 30*time.Second)
defer cancel()

err := db.WithContext(ctx).Transaction(func(tx *gorm.DB) error {
    // операции
    return nil
})

Обрабатывать ошибки и гарантировать откат транзакции при сбоях.
Проверить логи базы данных на предмет зависших транзакций и вручную завершить их, если нужно.
Рассмотреть использование механизма heartbeat или health check для воркера, чтобы при падении автоматически перезапускать задачи.
Оптимизировать работу воркера, чтобы транзакции не держались долго — возможно, разбить задачу на более мелкие части.

Таким образом, важно контролировать время жизни транзакций и корректно их завершать, чтобы избежать блокировок и зависших состояний.

Воркер работает долго (2 минуты), транзакция остаётся в базе при падении — что делать?