Set OMP_NUM_THREADS now also for FastWarm and FastProd

analysis/tasks/FastProd.py

@@ -167,6 +167,12 @@ class FastProd(Task, TarballExtractionMixin, HTCondorWorkflow, law.LocalWorkflow
                     )
                     f.write(runcard)
 
+                # KR: With hyperthreading it might be necessary to request more cpus on a node than one wants to use for the calculation!
+                #     --> Differentiate between request and use CPUs!
+                #      os.environ['OMP_NUM_THREADS'] = self.htcondor_request_cpus
+                logger.debug("Setting no. of threads to use: self.htcondor_use_cpus[index] = {}".format(self.htcondor_use_cpus[self.branch_data['index']]))
+                os.environ['OMP_NUM_THREADS'] = self.htcondor_use_cpus[self.branch_data['index']]
+
                 logger.debug("Starting NNLOJET with runcard: %s", runfile)
 
                 command_line_args = ['NNLOJET', '-run', runfile]

analysis/tasks/FastWarm.py

@@ -157,6 +157,12 @@ class FastWarm(Task, TarballExtractionMixin, HTCondorWorkflow, law.LocalWorkflow
                     )
                     f.write(runcard)
 
+                # KR: With hyperthreading it might be necessary to request more cpus on a node than one wants to use for the calculation!
+                #     --> Differentiate between request and use CPUs!
+                #      os.environ['OMP_NUM_THREADS'] = self.htcondor_request_cpus
+                logger.debug("Setting no. of threads to use: self.htcondor_use_cpus[index] = {}".format(self.htcondor_use_cpus[self.branch_data['index']]))
+                os.environ['OMP_NUM_THREADS'] = self.htcondor_use_cpus[self.branch_data['index']]
+
                 logger.debug("Starting NNLOJET with runcard: %s", runfile)
 
                 command_line_args = ['NNLOJET', '-run', runfile]