Skip to content
Snippets Groups Projects
Commit 9396e29c authored by Wen Guan's avatar Wen Guan
Browse files

[RUCIO-1619] fix normal conveyor submitter with scheme selection

Change-Id: Ia71fd6ff19fff0f64ff87e9c4f7fef6dce65cf51
parent 854c1b0a
No related branches found
No related tags found
No related merge requests found
......@@ -314,7 +314,9 @@ def get_transfer(rse, req, scheme, mock, max_sources=4):
if scheme is None:
sources, metadata = get_sources(rse, None, req, max_sources=max_sources)
else:
sources, metadata = get_sources(rse, [scheme], req, max_sources=max_sources)
if not isinstance(scheme, list):
scheme = scheme.split(',')
sources, metadata = get_sources(rse, scheme, req, max_sources=max_sources)
record_timer('daemons.conveyor.submitter.get_sources', (time.time() - ts) * 1000)
logging.debug('Sources for request %s: %s' % (req['request_id'], sources))
if sources is None:
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment