Sha256: 85b29340e74ec1214d085aa6556c57760ab1389da105da6c77bdce1f710125cf
Contents?: true
Size: 1.7 KB
Versions: 25
Compression:
Stored size: 1.7 KB
Contents
#!/usr/bin/env ruby
# encoding: utf-8
# 20121112 masa workflow manager client
Version = '20200324-134935'
require 'drb/drb'
require 'workflow_manager/optparse_ex'
require 'pstore'
class PStore
def each
self.roots.each do |key|
yield(key, self[key])
end
end
end
require 'redis'
class Redis
def [](key)
self.get(key)
end
def []=(key, value)
self.set(key, value)
end
def each
self.scan_each do |key|
value = self.get(key)
yield([key, value])
end
end
end
#require File.join((File.expand_path('../../lib',__FILE__)), 'optparse_ex.rb')
opt = OptionParser.new do |o|
o.banner = "Usage:\n #{File.basename(__FILE__)} [options]"
# o.on(:user, 'sushi lover', '-u user', '--user', 'who submitted?')
o.on(:job_ids, nil, '-j job_ids', '--job_ids', 'job id list (e.g. 10001,10002,10003: comma separate without space)')
o.on(:project, nil, '-p project', '--project', 'project number')
o.on(:server, 'druby://localhost:12345', '-d server', '--server', 'workflow manager URI (default: druby://localhost:12345)')
o.parse!(ARGV)
end
with_result = false
uri = opt.server||'druby://localhost:12345'
project_number = opt.project
wfmrc = if File.exist?(".wfmrc")
".wfmrc"
elsif File.exist?(File.expand_path("~/.wfmrc"))
File.expand_path("~/.wfmrc")
end
if wfmrc
File.readlines(wfmrc).each do |line|
if line =~ /server:\s*(druby.+)/
uri = $1
end
if line =~ /project:\s*(\d+)/
project_number = $1
end
end
end
workflow_manager = DRbObject.new_with_uri(uri)
if opt.job_ids
puts workflow_manager.job_list(with_result, project_number, job_ids:opt.job_ids)
else
puts workflow_manager.job_list(with_result, project_number)
end
Version data entries
25 entries across 25 versions & 1 rubygems