clear method

@override Future<void> clear([ String queue = 'default' ])

Clears all jobs from the queue. Primarily for testing.

Implementation

@override
Future<void> clear([String queue = 'default']) async {
  await _db.query('''
    DELETE FROM $_table WHERE queue = @queue AND status IN ('pending', 'processing')
  ''', {'queue': queue});
}