flux.cli.bulksubmit module

class flux.cli.bulksubmit.BulkSubmitCmd(prog, usage=None, description=None)

Bases: SubmitBulkCmd

BulkSubmitCmd is like xargs for job submission. It takes a series of inputs on stdin (or the cmdline separated by :::), and substitutes them into the initial arguments, e.g:

$ echo 1 2 3 | flux bulksubmit echo {}

create_commands(args)

Create bulksubmit commands list

static input_file(filep, sep)

Read set of inputs from file object filep, using separator sep

main(args)

static split_before(iterable, pred)

Like more_itertools.split_before, but if predicate returns True on first element, then return an empty list

split_command_inputs(command, sep='\n', delim=':::')

Generate a list of inputs from command list

Splits the command list on the input delimiter delim, and returns 3 lists:

• the initial command list (everything before the first delim)

• a list of normal "input lists"

• a list of "linked" input lists, (delim + "+")

Special case delimiter values are handled here, e.g. ":::+" and ::::".