Changeset View
Changeset View
Standalone View
Standalone View
swh/provenance/origin.py
Show First 20 Lines • Show All 54 Lines • ▼ Show 20 Lines | for origin in origins: | ||||
origin.retrieve_revisions(archive) | origin.retrieve_revisions(archive) | ||||
for revision in origin.revisions: | for revision in origin.revisions: | ||||
graph = HistoryGraph(archive, provenance, revision) | graph = HistoryGraph(archive, provenance, revision) | ||||
origin_add_revision(provenance, origin, graph) | origin_add_revision(provenance, origin, graph) | ||||
done = time.time() | done = time.time() | ||||
provenance.flush() | provenance.flush() | ||||
stop = time.time() | stop = time.time() | ||||
logging.debug( | logging.debug( | ||||
"Origins " | "Origins %s were processed in %s secs (commit took %s secs)!", | ||||
";".join([origin.id.hex() + ":" + origin.snapshot.hex() for origin in origins]) | ";".join(origin.id.hex() + ":" + origin.snapshot.hex() for origin in origins), | ||||
+ f" were processed in {stop - start} secs (commit took {stop - done} secs)!" | stop - start, | ||||
stop - done, | |||||
) | ) | ||||
def origin_add_revision( | def origin_add_revision( | ||||
provenance: ProvenanceInterface, | provenance: ProvenanceInterface, | ||||
origin: OriginEntry, | origin: OriginEntry, | ||||
graph: HistoryGraph, | graph: HistoryGraph, | ||||
) -> None: | ) -> None: | ||||
Show All 34 Lines |