From 1018f8c47c02ede844dd6bd880e9954014086846 Mon Sep 17 00:00:00 2001 From: Jon Clucas Date: Wed, 13 Mar 2024 14:29:46 -0400 Subject: [PATCH 1/3] :zap: Throttle `calc_ants_warp` --- CPAC/registration/registration.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/CPAC/registration/registration.py b/CPAC/registration/registration.py index cd3e69444a..8658aae219 100644 --- a/CPAC/registration/registration.py +++ b/CPAC/registration/registration.py @@ -1209,7 +1209,8 @@ def create_wf_calculate_ants_warp( imports=reg_imports), name='calc_ants_warp', mem_gb=2.8, - mem_x=(2e-7, 'moving_brain', 'xyz')) + mem_x=(2e-7, 'moving_brain', 'xyz'), + throttle=True) calculate_ants_warp.interface.num_threads = num_threads From dab49253641f2804047a39549176e1ab40ba83e7 Mon Sep 17 00:00:00 2001 From: Jon Clucas Date: Wed, 13 Mar 2024 14:31:49 -0400 Subject: [PATCH 2/3] :zap: Throttle `cal_DVARS` --- CPAC/generate_motion_statistics/generate_motion_statistics.py | 3 ++- CPAC/qc/xcp.py | 3 ++- 2 files changed, 4 insertions(+), 2 deletions(-) diff --git a/CPAC/generate_motion_statistics/generate_motion_statistics.py b/CPAC/generate_motion_statistics/generate_motion_statistics.py index f8400804ef..8d918dd07d 100644 --- a/CPAC/generate_motion_statistics/generate_motion_statistics.py +++ b/CPAC/generate_motion_statistics/generate_motion_statistics.py @@ -207,7 +207,8 @@ def motion_power_statistics(name='motion_stats', name='cal_DVARS', mem_gb=0.4, mem_x=(739971956005215 / 151115727451828646838272, - 'in_file')) + 'in_file'), + throttle=True) cal_DVARS_strip = pe.Node(Function(input_names=['file_1D'], output_names=['out_file', 'DVARS_val'], diff --git a/CPAC/qc/xcp.py b/CPAC/qc/xcp.py index 3104256c02..0f6494a69f 100644 --- a/CPAC/qc/xcp.py +++ b/CPAC/qc/xcp.py @@ -112,7 +112,8 @@ def _connect_motion(wf, nodes, strat_pool, qc_file, pipe_num): name=f'cal_DVARS_{pipe_num}', mem_gb=0.4, mem_x=(739971956005215 / 151115727451828646838272, - 'in_file')) + 'in_file'), + throttle=True) cal_DVARS_strip = pe.Node(Function(input_names=['file_1D'], output_names=['out_file'], function=DVARS_strip_t0, From a469562a43761a92ca7729b86584d85f7983de19 Mon Sep 17 00:00:00 2001 From: Jon Clucas Date: Wed, 13 Mar 2024 14:33:12 -0400 Subject: [PATCH 3/3] :zap: Throttle all cosine filters --- CPAC/nuisance/nuisance.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/CPAC/nuisance/nuisance.py b/CPAC/nuisance/nuisance.py index a2beb7d2c6..c19fd26080 100644 --- a/CPAC/nuisance/nuisance.py +++ b/CPAC/nuisance/nuisance.py @@ -1283,7 +1283,7 @@ def create_regressor_workflow(nuisance_selectors, imports=cosfilter_imports), name=f'{regressor_type}_cosine_filter', mem_gb=8.0, - throttle=regressor_type.lower() == "acompcor") + throttle=True) nuisance_wf.connect( summary_filter_input[0], summary_filter_input[1], cosfilter_node, 'input_image_path'