@@ -332,7 +332,6 @@ def __init__(self,
332
332
self .workflow_run_uuid = run_uuid
333
333
self .workflow_run_uri = run_uuid .urn
334
334
self .generate_prov_doc ()
335
- self .secondaries = {}
336
335
337
336
def __str__ (self ):
338
337
return "CreateProvProfile <%s> in <%s>" % (
@@ -513,9 +512,9 @@ def start_process(self, process_name, process_run_id=None):
513
512
def declare_file (self , value ):
514
513
# type: (Dict) -> Tuple[ProvEntity,ProvEntity,str]
515
514
if value ["class" ] != "File" :
516
- raise ValueError ("Must have class:File" % value )
515
+ raise ValueError ("Must have class:File: %s " % value )
517
516
# Need to determine file hash aka RO filename
518
- entity = None
517
+ entity = None # type: Optional[ProvEntity]
519
518
checksum = None
520
519
if 'checksum' in value :
521
520
csum = value ['checksum' ]
@@ -558,7 +557,7 @@ def declare_file(self, value):
558
557
file_entity = self .document .entity (file_id ,
559
558
[(provM .PROV_TYPE , WFPROV ["Artifact" ]),
560
559
(provM .PROV_TYPE , WF4EVER ["File" ])
561
- ])
560
+ ]) # type: ProvEntity
562
561
563
562
if "basename" in value :
564
563
file_entity .add_attributes ({CWLPROV ["basename" ]: value ["basename" ]})
@@ -578,11 +577,8 @@ def declare_file(self, value):
578
577
# then prov:Quotation is not appropriate.
579
578
self .document .derivation (sec_entity , file_entity ,
580
579
other_attributes = {PROV ["type" ]: CWLPROV ["SecondaryFile" ]})
581
- # Add to self.secondaries so it can later
582
- # be augmented into primary-job.json
583
- secondaries = self .secondaries .setdefault (checksum , set ())
584
- secondaries .add (self .research_object .relativise_files (sec ))
585
580
581
+ assert entity
586
582
return file_entity , entity , checksum
587
583
588
584
def declare_artefact (self , value ):
0 commit comments