@@ -266,7 +266,7 @@ def run_workflow(args):
266
266
pfn = top_dir / "bin/preprocess/preprocess.py" ,
267
267
is_stageable = True ,
268
268
container = unet_wf_preprocess_cont
269
- )
269
+ ). add_pegasus_profile ( cores = 8 , memory = "12 GB" , runtime = 14400 )
270
270
271
271
unet = Transformation (
272
272
"unet" ,
@@ -290,7 +290,7 @@ def run_workflow(args):
290
290
pfn = top_dir / "bin/model/hpo.py" ,
291
291
is_stageable = True ,
292
292
container = unet_wf_cont
293
- ).add_pegasus_profile (cores = 8 , runtime = 14400 )
293
+ ).add_pegasus_profile (cores = 8 , memory = "12 GB" , runtime = 14400 )
294
294
295
295
296
296
train_model = Transformation (
@@ -299,23 +299,23 @@ def run_workflow(args):
299
299
pfn = top_dir / "bin/model/train_model.py" ,
300
300
is_stageable = True ,
301
301
container = unet_wf_cont
302
- ).add_pegasus_profile (cores = 8 , runtime = 7200 )
302
+ ).add_pegasus_profile (cores = 8 , memory = "24 GB" , runtime = 14400 )
303
303
304
304
predict_masks = Transformation (
305
305
"predict_masks" ,
306
306
site = "local" ,
307
307
pfn = top_dir / "bin/model/prediction.py" ,
308
308
is_stageable = True ,
309
309
container = unet_wf_cont
310
- ).add_pegasus_profile (cores = 8 , runtime = 3600 )
310
+ ).add_pegasus_profile (cores = 8 , memory = "12 GB" , runtime = 14400 )
311
311
312
312
evaluate_model = Transformation (
313
313
"evaluate" ,
314
314
site = "local" ,
315
315
pfn = top_dir / "bin/model/evaluate.py" ,
316
316
is_stageable = True ,
317
317
container = unet_wf_cont
318
- )
318
+ ). add_pegasus_profile ( cores = 8 , memory = "12 GB" , runtime = 14400 )
319
319
320
320
if args .gpus :
321
321
hpo_task .add_pegasus_profile (gpus = 1 )
0 commit comments