High-throughput computing flow
Project description
高通量计算流程
创建流程步骤
from htscf.core.createStep import create
create(
_id="xxxx", # 步骤id
program="python", # 执行的程序名
script="...........", # 执行的脚本内容
settings={"a": "12"}, # 执行脚本相关设置
dbName="htscf", # 数据库名
collectionName="xxx", # 集合名
host="192.1.1.100", # 数据库Ip
port=27017 # 数据库端口
)
脚本格式
from sys import argv
rootPath, settingsId, prevLogId = argv[1:]
# 输出到下一步的数组使用print,即可传递到下一步的prevData
print(rootPath, settingsId)
流程化运行
from htscf.core.flow import workflow
workflow(
"./xxx", # 流程执行根目录
stepIds=["xx", "yy"], # 按照该数组中排列一次执行每一步
dbName="test", # 数据库名
stepsCollectionName="steps", # 流程数组集合
stepLogCollectionName="log", #
host="42.244.24.75",
port=27000
)
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
htscf-0.0.73.tar.gz
(15.6 kB
view hashes)
Built Distribution
htscf-0.0.73-py3-none-any.whl
(19.5 kB
view hashes)