5050CWLArtifact = TypedDict ("CWLArtifact" , {"@id" : str })
5151
5252
53- class CWLDirectoryArtifact (CWLArtifact , CWLDirectoryType ):
53+ class _CWLDirectoryArtifact (CWLArtifact , CWLDirectoryType ):
5454 pass
5555
5656
57- class CWLFileArtifact (CWLArtifact , CWLFileType ):
57+ class _CWLFileArtifact (CWLArtifact , CWLFileType ):
5858 pass
5959
6060
@@ -260,7 +260,7 @@ def record_process_end(
260260 self .generate_output_prov (outputs , process_run_id , process_name )
261261 self .document .wasEndedBy (process_run_id , None , self .workflow_run_uri , when )
262262
263- def declare_file (self , value : CWLFileArtifact ) -> tuple [ProvEntity , ProvEntity , str ]:
263+ def declare_file (self , value : _CWLFileArtifact ) -> tuple [ProvEntity , ProvEntity , str ]:
264264 """Construct a FileEntity for the given CWL File object."""
265265 if not is_file (value ):
266266 raise ValueError ("Must have class:File: %s" % value )
@@ -315,9 +315,9 @@ def declare_file(self, value: CWLFileArtifact) -> tuple[ProvEntity, ProvEntity,
315315 for sec in cast (MutableSequence [CWLObjectType ], value .get ("secondaryFiles" , [])):
316316 # TODO: Record these in a specializationOf entity with UUID?
317317 if is_file (sec ):
318- (sec_entity , _ , _ ) = self .declare_file (cast (CWLFileArtifact , sec ))
318+ (sec_entity , _ , _ ) = self .declare_file (cast (_CWLFileArtifact , sec ))
319319 elif is_directory (sec ):
320- sec_entity = self .declare_directory (cast (CWLDirectoryArtifact , sec ))
320+ sec_entity = self .declare_directory (cast (_CWLDirectoryArtifact , sec ))
321321 else :
322322 raise ValueError (f"Got unexpected secondaryFiles value: { sec } " )
323323 # We don't know how/when/where the secondary file was generated,
@@ -332,7 +332,7 @@ def declare_file(self, value: CWLFileArtifact) -> tuple[ProvEntity, ProvEntity,
332332
333333 return file_entity , entity , checksum
334334
335- def declare_directory (self , value : CWLDirectoryArtifact ) -> ProvEntity :
335+ def declare_directory (self , value : _CWLDirectoryArtifact ) -> ProvEntity :
336336 """Register any nested files/directories."""
337337 # FIXME: Calculate a hash-like identifier for directory
338338 # so we get same value if it's the same filenames/hashes
@@ -492,11 +492,11 @@ def declare_artefact(self, value: Any) -> ProvEntity:
492492
493493 # Base case - we found a File we need to update
494494 case {"class" : "File" }:
495- entity = self .declare_file (cast (CWLFileArtifact , value ))[0 ]
495+ entity = self .declare_file (cast (_CWLFileArtifact , value ))[0 ]
496496 value ["@id" ] = entity .identifier .uri
497497 return entity
498498 case {"class" : "Directory" }:
499- entity = self .declare_directory (cast (CWLDirectoryArtifact , value ))
499+ entity = self .declare_directory (cast (_CWLDirectoryArtifact , value ))
500500 value ["@id" ] = entity .identifier .uri
501501 return entity
502502 case {** rest }:
0 commit comments