找到nextflow_wrapper.py这个文件的这几行:
def dump_to_file(self):
"""Write the respective config file,"""
filename = f"{self.label}_config.nf"
self.config_path = os.path.join(self.config_dir, filename)
f = open(self.config_path, "w")
f.write(f"// Nextflow config for {self.label} jobs\n")
f.write(f"process.executor = '{self.executor}'\n")
f.write(f"process.memory = '{self.memory} G'\n")
f.write(f"process.time = '{self.time}'\n")
f.write(f"process.cpus = '{self.cpus}'\n")
if self.queue:
f.write(f"process.queue = '{self.queue}'\n")
f.write(f"executor.queueSize = '{self.queue_size}'\n")
f.close()
return self.config_path
然后根据自己的服务器情况进行修改;
如果服务器有单次提交任务数限制,增加一行executor.queueSize = '90' 限制提交数量为90个;
不能设置时间,就删掉f.write(f"process.time = '{self.time}'\n")这行