@@ -305,21 +305,29 @@ def prepare_or_run_pipeline(
305
305
# Retrieve Executor arguments provided in the Step settings.
306
306
if use_training_step :
307
307
args_for_step_executor = step_settings .estimator_args or {}
308
+ args_for_step_executor .setdefault (
309
+ "volume_size" , step_settings .volume_size_in_gb
310
+ )
311
+ args_for_step_executor .setdefault (
312
+ "max_run" , step_settings .max_runtime_in_seconds
313
+ )
308
314
else :
309
315
args_for_step_executor = step_settings .processor_args or {}
316
+ args_for_step_executor .setdefault (
317
+ "volume_size_in_gb" , step_settings .volume_size_in_gb
318
+ )
319
+ args_for_step_executor .setdefault (
320
+ "max_runtime_in_seconds" ,
321
+ step_settings .max_runtime_in_seconds ,
322
+ )
310
323
311
324
# Set default values from configured orchestrator Component to
312
325
# arguments to be used when they are not present in processor_args.
313
326
args_for_step_executor .setdefault (
314
327
"role" ,
315
328
step_settings .execution_role or self .config .execution_role ,
316
329
)
317
- args_for_step_executor .setdefault (
318
- "volume_size_in_gb" , step_settings .volume_size_in_gb
319
- )
320
- args_for_step_executor .setdefault (
321
- "max_runtime_in_seconds" , step_settings .max_runtime_in_seconds
322
- )
330
+
323
331
tags = step_settings .tags
324
332
args_for_step_executor .setdefault (
325
333
"tags" ,
0 commit comments