@@ -148,8 +148,8 @@ def run(self, **kwargs):
148
148
149
149
# map files to assigned path inside a container. We need to also explicitly
150
150
# walk over input as implicit reassignment doesn't reach everything in builder.bindings
151
- def check_adjust (builder , stepname , f ):
152
- # type: (Builder, Text, Dict[Text, Any]) -> Dict[Text, Any]
151
+ def check_adjust (builder , f ):
152
+ # type: (Builder, Dict[Text, Any]) -> Dict[Text, Any]
153
153
154
154
f ["path" ] = builder .pathmapper .mapper (f ["location" ])[1 ]
155
155
f ["dirname" ], f ["basename" ] = os .path .split (f ["path" ])
@@ -300,7 +300,7 @@ def rm_pending_output_callback(output_callbacks, jobcachepending,
300
300
_logger .debug (u"[job %s] path mappings is %s" , j .name ,
301
301
json .dumps ({p : builder .pathmapper .mapper (p ) for p in builder .pathmapper .files ()}, indent = 4 ))
302
302
303
- _check_adjust = partial (check_adjust , builder , jobname )
303
+ _check_adjust = partial (check_adjust , builder )
304
304
305
305
visit_class ([builder .files , builder .bindings ], ("File" , "Directory" ), _check_adjust )
306
306
0 commit comments