Method Wait

adapters/repos/db/queue/queue.go:477–479

Wait blocks until all currently running tasks are finished.

(ctx context.Context)

// Wait blocks until all currently running tasks are finished.
func (q *DiskQueue) Wait(ctx context.Context) error {
	return q.scheduler.Wait(ctx, q.id)
}

// PrepareForBackup pauses the queue and flushes all tasks to disk to prepare
// for backup. It also promotes the current partial chunk into a sealed file