swh.scheduler.cli.task module#

swh.scheduler.cli.task.iter_origins(storage: StorageInterface, page_token: str | None = None) → Iterator[swh.model.model.Origin][source]#

Iterate over origins in the storage. Optionally starting from page_token.

This logs regularly an info message during pagination with the page_token. This, in order to feed it back to the cli if the process interrupted.