@@ -1493,14 +1493,14 @@ def _add_to_bagit(self, rel_path, **checksums):
1493
1493
self .add_to_manifest (rel_path , checksums )
1494
1494
1495
1495
def create_job (self ,
1496
- builder_job , # type: Dict[Text, Any]
1496
+ builder_job , # type: Dict
1497
1497
wf_job = None , # type: Callable[[Dict[Text, Text], Callable[[Any, Any], Any], RuntimeContext], Generator[Any, None, None]]
1498
1498
is_output = False
1499
1499
): # type: (...) -> Dict
1500
1500
#TODO customise the file
1501
1501
"""Generate the new job object with RO specific relative paths."""
1502
1502
copied = copy .deepcopy (builder_job )
1503
- relativised_input_objecttemp = {} # type: Dict[Text, Any]
1503
+ relativised_input_objecttemp = {} # type: Dict
1504
1504
self ._relativise_files (copied )
1505
1505
if is_output :
1506
1506
rel_path = posixpath .join (_posix_path (WORKFLOW ), "primary-output.json" )
@@ -1527,7 +1527,7 @@ def create_job(self,
1527
1527
return self .relativised_input_object
1528
1528
1529
1529
def _relativise_files (self , structure ):
1530
- # type: (Any, Dict[Any, Any] ) -> None
1530
+ # type: (Any, Dict) -> None
1531
1531
"""Save any file objects into the RO and update the local paths."""
1532
1532
# Base case - we found a File we need to update
1533
1533
_logger .debug (u"[provenance] Relativising: %s" , structure )
0 commit comments