Commit 0adb99d5 authored by Maria Arsuaga Rios's avatar Maria Arsuaga Rios
Browse files

FTS-1232: Add nostreams to the easy bindings' new_job interface

parent 42b6c789
Pipeline #655689 passed with stage
in 1 minute and 36 seconds
......@@ -108,7 +108,7 @@ def new_job(transfers=None, deletion=None, verify_checksum=False, reuse=None, ov
bring_online=None, copy_pin_lifetime=None,
retry=-1, retry_delay=0, metadata=None, priority=None, strict_copy=False,
max_time_in_queue=None, timeout=None,
id_generator=JobIdGenerator.standard, sid=None, s3alternate=False):
id_generator=JobIdGenerator.standard, sid=None, s3alternate=False, nostreams=1):
"""
Creates a new dictionary representing a job
......@@ -130,6 +130,7 @@ def new_job(transfers=None, deletion=None, verify_checksum=False, reuse=None, ov
id_generator: Job id generator algorithm
sid: Specific id given by the client
s3alternate: Use S3 alternate url schema
nostreams: Number of streams
Returns:
An initialized dictionary representing a job
......@@ -160,7 +161,8 @@ def new_job(transfers=None, deletion=None, verify_checksum=False, reuse=None, ov
timeout=timeout,
id_generator=id_generator,
sid=sid,
s3alternate=s3alternate
s3alternate=s3alternate,
nostreams=nostreams
)
job = dict(
files=transfers,
......
Markdown is supported
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