一个介绍如何 从 一个 C 程序中 提交并行作业 的例子
2009-03-12 09:35
337 查看
http://g2.trac.bx.psu.edu/browser/lib/galaxy/jobs/runners/pbs.py?rev=1696%3Aaac0403bbe68
199 # write the job script
200 if self.app.config.pbs_stage_path != '':
201 script = pbs_symlink_template % (job_wrapper.galaxy_lib_dir, " ".join(job_wrapper.get_input_fnames() + job_wrapper.get_output_fnames()), self.app.config.pbs_stage_path, exec_dir, command_line)
202 else:
203 script = pbs_template % (job_wrapper.galaxy_lib_dir, exec_dir, command_line)
204 job_file = "%s/%s.sh" % (self.app.config.cluster_files_directory, job_wrapper.job_id)
205 fh = file(job_file, "w")
206 fh.write(script)
207 fh.close()
.
.
# submit
218 galaxy_job_id = job_wrapper.job_id
219 log.debug("(%s) submitting file %s" % ( galaxy_job_id, job_file ) )
220 log.debug("(%s) command is: %s" % ( galaxy_job_id, command_line ) )
221 job_id = pbs.pbs_submit(c, job_attrs, job_file, pbs_queue_name, None)
222 pbs.pbs_disconnect(c)
从此 例可看出 脚本文件 *.sh 是 在 C程序中动态生成的.
199 # write the job script
200 if self.app.config.pbs_stage_path != '':
201 script = pbs_symlink_template % (job_wrapper.galaxy_lib_dir, " ".join(job_wrapper.get_input_fnames() + job_wrapper.get_output_fnames()), self.app.config.pbs_stage_path, exec_dir, command_line)
202 else:
203 script = pbs_template % (job_wrapper.galaxy_lib_dir, exec_dir, command_line)
204 job_file = "%s/%s.sh" % (self.app.config.cluster_files_directory, job_wrapper.job_id)
205 fh = file(job_file, "w")
206 fh.write(script)
207 fh.close()
.
.
# submit
218 galaxy_job_id = job_wrapper.job_id
219 log.debug("(%s) submitting file %s" % ( galaxy_job_id, job_file ) )
220 log.debug("(%s) command is: %s" % ( galaxy_job_id, command_line ) )
221 job_id = pbs.pbs_submit(c, job_attrs, job_file, pbs_queue_name, None)
222 pbs.pbs_disconnect(c)
从此 例可看出 脚本文件 *.sh 是 在 C程序中动态生成的.
相关文章推荐
- 通过一个简单的例子学习编译器是如何执行程序的
- 如何向hadoop集群定时提交一个jar作业?
- 如何快速地编写和运行一个属于自己的 MapReduce 例子程序
- linux内核分析作业:操作系统是如何工作的进行:完成一个简单的时间片轮转多道程序内核代码
- Linux内核分析作业7:Linux内核如何装载和启动一个可执行程序
- 作业七:Linux内核如何装载和启动一个可执行程序
- 如何用程序提交一个上传文件的请求
- RunLoop学习笔记,从CF层面了解由于CFRunLoopMode机制iOS程序ScrollView的滑动为何如此平滑的原因。还有介绍AFNetworking如何单独发起一个global threa
- 如何快速地编写和运行一个属于自己的MapReduce例子程序
- (作业1)将一个简单的C程序编译成汇编代码,讨论计算机是如何工作的进行
- 通过一个简单的例子,介绍如何使用LDAP(转)
- 《LInux内核分析》第七周作业:Linux内核如何装载和启动一个可执行程序
- Linux下如何结束一个应用程序(比如死循环的程序)?两种方法介绍给大家
- 设计一个学生作业完成情况的管理程序
- java程序中,如何安全的结束一个正在运行的线程
- 作业二:编写一个自动生成四则运算的程序
- 详解如何开发一个凤蝶H5(支付宝小程序)的组件
- 一个在程序中实现plugin机制的简单例子
- 一个程序在计算机中到底是如何运行的?
- 分析一个简单C程序的汇编代码,理解计算机是如何工作的