retryDeadLetter method

  1. @override
Future<bool> retryDeadLetter(
  1. String jobId
)
override

Retries a dead-letter job by its jobId, moving it back to the queue.

Implementation

@override
Future<bool> retryDeadLetter(String jobId) async {
  final result = await _db.query('''
    UPDATE $_table
    SET status = 'pending',
        attempts = 0,
        last_error = NULL,
        available_at = NULL,
        finished_at = NULL,
        reserved_by = NULL
    WHERE id = @id AND status = 'failed'
  ''', {'id': jobId});

  return (result.affectedRows ?? 0) > 0;
}