Clear all jobs (for testing)
@override Future<void> clear() async { _queue.clear(); _processingJobs.clear(); if (metrics != null) { metrics!.recordQueueDepth(0); } }