@@ -801,10 +801,13 @@ def used_artefacts(self,
801
801
base += "/" + name
802
802
for key , value in job_order .items ():
803
803
prov_role = self .wf_ns ["%s/%s" % (base , key )]
804
- entity = self .declare_artefact (value )
805
- self .document .used (
806
- process_run_id , entity , datetime .datetime .now (), None ,
807
- {"prov:role" : prov_role })
804
+ try :
805
+ entity = self .declare_artefact (value )
806
+ self .document .used (
807
+ process_run_id , entity , datetime .datetime .now (), None ,
808
+ {"prov:role" : prov_role })
809
+ except FileNotFoundError :
810
+ pass
808
811
809
812
def generate_output_prov (self ,
810
813
final_output , # type: Union[Dict[Text, Any], List[Dict[Text, Any]]]
@@ -1577,7 +1580,10 @@ def _relativise_files(self, structure):
1577
1580
del structure ["location" ]
1578
1581
1579
1582
for val in structure .values ():
1580
- self ._relativise_files (val )
1583
+ try :
1584
+ self ._relativise_files (val )
1585
+ except FileNotFoundError :
1586
+ pass
1581
1587
return
1582
1588
1583
1589
if isinstance (structure , (str , Text )):
0 commit comments