release method

  1. @override
Future<void> release(
  1. Job job
)
override

Returns a job to the queue for retry, respecting its availableAt.

Implementation

@override
Future<void> release(Job job) async {
  await _db.query('''
    UPDATE $_table
    SET status = 'pending',
        attempts = @attempts,
        available_at = @availableAt,
        last_error = @lastError,
        reserved_by = NULL
    WHERE id = @id
  ''', {
    'id': job.id,
    'attempts': job.attempts,
    'availableAt': job.availableAt,
    'lastError': job.lastError?.toString(),
  });
}