- swh.storage.algos.origin.iter_origins(storage: StorageInterface, limit: int = 10000) Iterator[Origin] #
Iterates over origins in the storage.
storage – the storage object used for queries.
limit – maximum number of origins per page
origin model objects from the storage in page of limit origins
- swh.storage.algos.origin.origin_get_latest_visit_status(storage: StorageInterface, origin_url: str, type: Optional[str] = None, allowed_statuses: Optional[List[str]] = None, require_snapshot: bool = False) Optional[OriginVisitStatus] #
Get the latest origin visit (and status) of an origin. Optionally, a combination of criteria can be provided, origin type, allowed statuses or if a visit has a snapshot.
If no visit matching the criteria is found, returns None. Otherwise, returns a tuple of origin visit, origin visit status.
storage – A storage backend
origin – origin URL
type – Optional visit type to filter on (e.g git, tar, dsc, svn, hg, npm, pypi, …)
allowed_statuses – list of visit statuses considered to find the latest visit. For instance,
allowed_statuses=['full']will only consider visits that have successfully run to completion.
require_snapshot – If True, only a visit with a snapshot will be returned.
a tuple of (visit, visit_status) model object if the visit and the visit status exist (and match the search criteria), None otherwise.
- swh.storage.algos.origin.iter_origin_visits(storage: StorageInterface, origin: str, order: ListOrder = ListOrder.ASC) Iterator[OriginVisit] #
Iter over origin visits from an origin