Changeset View
Changeset View
Standalone View
Standalone View
swh/provenance/revision.py
| import threading | |||||
| from .archive import ArchiveInterface | |||||
| from datetime import datetime | from datetime import datetime | ||||
| import threading | |||||
| from typing import Optional | from typing import Optional | ||||
| from swh.model.hashutil import hash_to_bytes | from swh.model.hashutil import hash_to_bytes | ||||
| from .archive import ArchiveInterface | |||||
| class RevisionEntry: | class RevisionEntry: | ||||
| def __init__( | def __init__( | ||||
| self, | self, | ||||
| archive: ArchiveInterface, | archive: ArchiveInterface, | ||||
| id: bytes, | id: bytes, | ||||
| date: Optional[datetime] = None, | date: Optional[datetime] = None, | ||||
| root: Optional[bytes] = None, | root: Optional[bytes] = None, | ||||
| ▲ Show 20 Lines • Show All 104 Lines • ▼ Show 20 Lines | |||||
| # revision, *self.records = self.records | # revision, *self.records = self.records | ||||
| # self.mutex.release() | # self.mutex.release() | ||||
| # return revision | # return revision | ||||
| # else: | # else: | ||||
| # self.mutex.release() | # self.mutex.release() | ||||
| # return None | # return None | ||||
| # | # | ||||
| # def make_record(self, row): | # def make_record(self, row): | ||||
| # # Only revision with author or commiter date are considered | # # Only revision with author or committer date are considered | ||||
| # if row[1] is not None: | # if row[1] is not None: | ||||
| # # If the revision has author date, it takes precedence | # # If the revision has author date, it takes precedence | ||||
| # return RevisionEntry(row[0], row[1], row[3]) | # return RevisionEntry(row[0], row[1], row[3]) | ||||
| # elif row[2] is not None: | # elif row[2] is not None: | ||||
| # # If not, we use the commiter date | # # If not, we use the committer date | ||||
| # return RevisionEntry(row[0], row[2], row[3]) | # return RevisionEntry(row[0], row[2], row[3]) | ||||
| ######################################################################################## | ######################################################################################## | ||||
| ######################################################################################## | ######################################################################################## | ||||
| # class RevisionWorker(threading.Thread): | # class RevisionWorker(threading.Thread): | ||||
| # def __init__( | # def __init__( | ||||
| ▲ Show 20 Lines • Show All 41 Lines • Show Last 20 Lines | |||||