This commit is contained in:
@@ -21,6 +21,15 @@ func NewCronTracker(database db.Database) *CronTracker {
|
||||
}
|
||||
}
|
||||
|
||||
// ClearAllInProgress resets any stuck in-progress flags (e.g., after crashes).
|
||||
func (c *CronTracker) ClearAllInProgress(ctx context.Context) error {
|
||||
if err := c.ensureTable(ctx); err != nil {
|
||||
return err
|
||||
}
|
||||
_, err := c.db.DB().ExecContext(ctx, `UPDATE cron_status SET in_progress = FALSE`)
|
||||
return err
|
||||
}
|
||||
|
||||
func (c *CronTracker) ensureTable(ctx context.Context) error {
|
||||
conn := c.db.DB()
|
||||
driver := conn.DriverName()
|
||||
|
||||
Reference in New Issue
Block a user