pandaharvester/harvestercore/file_spec.py

0001 """
0002 File spec class
0003
0004 """
0005
0006 from .spec_base import SpecBase
0007
0008
0009 class FileSpec(SpecBase):
0010     # file type
0011     AUX_INPUT = "aux_input"
0012
0013     # attributes
0014     attributesWithTypes = (
0015         "fileID:integer primary key autoincrement",
0016         "PandaID:integer / index",
0017         "taskID:integer",
0018         "lfn:text / index",
0019         "status:text / index",
0020         "fsize:integer",
0021         "chksum:text",
0022         "path:text",
0023         "fileType:text",
0024         "eventRangeID:text",
0025         "modificationTime:timestamp",
0026         "fileAttributes:blob",
0027         "isZip:integer",
0028         "zipFileID:integer / index",
0029         "objstoreID:integer",
0030         "endpoint:text",
0031         "groupID:text / index",
0032         "groupStatus:text / index",
0033         "groupUpdateTime:timestamp / index",
0034         "attemptNr:integer",
0035         "todelete:integer / index",
0036         "scope:text",
0037         "pathConvention:integer",
0038         "provenanceID:text / index",
0039         "workerID:integer / index",
0040         "url:text",
0041     )
0042
0043     # attributes initialized with 0
0044     zeroAttrs = ("attemptNr", "todelete")
0045
0046     # constructor
0047     def __init__(self):
0048         SpecBase.__init__(self)
0049         object.__setattr__(self, "associatedFiles", set())
0050
0051     # add associated files
0052     def add_associated_file(self, filespec):
0053         self.associatedFiles.add(filespec)