Commit ad956c47 authored by Marian Babik's avatar Marian Babik
Browse files

added support for arc-ce endpoint URL (native client)

parent 0861078c
......@@ -75,6 +75,8 @@ app.add_argument('--arc-gmlog', action='store_true', default=False,
help='ARC backend: request gmlog')
app.add_argument('--arc-rsl', dest='arc_rsl',
help='ARC backend: add-ons for nordugrid_rsl')
app.add_argument('--arc-ce', dest='arc_ce',
help='ARC backend: arcsub computing element endpoint (arc6 client only)')
app.add_argument('--arc-sub-type', dest='arc_sub_type',
help='ARC backend: arcsub submission endpoint type (arc6 client only)')
app.add_argument('--arc-info-type', dest='arc_info_type',
......@@ -514,7 +516,7 @@ def test_js_state(args, io):
os.environ['ARC_LOCATION'] = '/usr'
jmi = jess.jobs.JMI(wd, args.backend, args.proxy, jdl, tb, resource=args.resource, arc_debug=args.arc_debug,
arc_sub_type=args.arc_sub_type, arc_info_type=args.arc_info_type,
arc_registry=args.arc_registry)
arc_registry=args.arc_registry, arc_ce=args.arc_ce)
tr = jess.jobs.Tracker(wd, jmi, job_schedule=args.job_schedule)
elif args.backend == 'cream':
jmi = jess.jobs.JMI(wd, args.backend, args.proxy, jdl, tb, resource=args.resource)
......
......@@ -69,7 +69,8 @@ class JMI(object):
def __init__(self, working_dir, backend, proxy, jdl, payload, resource=None,
pool=None, schedd=None, arc_wd=None, arc_debug='INFO',
arc_sub_type=None, arc_info_type=None, arc_registry=None, excludes=['.pyc', '.pyo', '.git']):
arc_sub_type=None, arc_info_type=None, arc_registry=None, arc_ce=None,
excludes=['.pyc', '.pyo', '.git']):
jess_log.debug('JMI init:')
self._jdl = jdl
self._working_dir = working_dir
......@@ -87,6 +88,7 @@ class JMI(object):
self._arc_wd = working_dir
self._arc_resource = None
self._arc_debug = arc_debug
self._arc_comp_element = arc_ce
self._arc_sub_type = arc_sub_type
self._arc_info_type = arc_info_type
self._arc_registry = arc_registry
......@@ -127,8 +129,11 @@ class JMI(object):
args = list()
if self._backend == 'arc':
kwargs['joblist'] = self._arc_job_file
if self._arc_registry or self._arc_info_type or self._arc_sub_type:
kwargs['computing-element'] = self._arc_resource
if self._arc_registry or self._arc_info_type or self._arc_sub_type or self._arc_comp_element:
if self._arc_comp_element:
kwargs['computing-element'] = self._arc_comp_element
else:
kwargs['computing-element'] = self._arc_resource
if self._arc_registry:
kwargs['registry'] = self._arc_registry
if self._arc_sub_type:
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment