diff --git a/notebooks/AGIPD/AGIPD_Correct_and_Verify.ipynb b/notebooks/AGIPD/AGIPD_Correct_and_Verify.ipynb index 8ce400170dc49e01d52349f6a7d71ca7f2213938..f49c2c540b6eb28194e2658df639eca21000e1c9 100644 --- a/notebooks/AGIPD/AGIPD_Correct_and_Verify.ipynb +++ b/notebooks/AGIPD/AGIPD_Correct_and_Verify.ipynb @@ -87,10 +87,11 @@ "n_cores_correct = 16 # Number of chunks to be processed in parallel\n", "n_cores_files = 4 # Number of files to be processed in parallel\n", "sequences_per_node = 2 # number of sequence files per cluster node if run as slurm job, set to 0 to not run SLURM parallel\n", + "max_nodes = 8 # Maximum number of Slurm jobs to split correction work into\n", "\n", - "def balance_sequences(in_folder, run, sequences, sequences_per_node, karabo_da):\n", + "def balance_sequences(in_folder, run, sequences, sequences_per_node, karabo_da, max_nodes):\n", " from xfel_calibrate.calibrate import balance_sequences as bs\n", - " return bs(in_folder, run, sequences, sequences_per_node, karabo_da)" + " return bs(in_folder, run, sequences, sequences_per_node, karabo_da, max_nodes=max_nodes)" ] }, {