pbcommand Resolved Tool Contract¶

Resolved Tool Contract Models

class pbcommand.models.ResolvedToolContractTask(task_id, is_distributed, input_files, output_files, options, nproc, resources, log_level='INFO')[source]¶

Bases: object

TASK_TYPE_ID = 'pbsmrtpipe.task_types.standard'¶

tmpdir_resources¶

tmpfile_resources¶

to_dict()[source]¶

class pbcommand.models.ResolvedScatteredToolContractTask(task_id, is_distributed, input_files, output_files, options, nproc, resources, max_nchunks, chunk_keys, log_level='INFO')[source]¶

Bases: pbcommand.models.tool_contract.ResolvedToolContractTask

TASK_TYPE_ID = 'pbsmrtpipe.task_types.scattered'¶

to_dict()[source]¶

class pbcommand.models.ResolvedGatherToolContractTask(task_id, is_distributed, input_files, output_files, options, nproc, resources, chunk_key, log_level='INFO')[source]¶

Bases: pbcommand.models.tool_contract.ResolvedToolContractTask

The chunk key is used in the pluck specific chunk values from PipelineChunks. This makes gather tasks (i.e., GffGather) generalized.

TASK_TYPE_ID = 'pbsmrtpipe.task_types.gathered'¶

to_dict()[source]¶

class pbcommand.models.ResolvedToolContract(task, driver)[source]¶

Bases: object

ResolvedScatteredToolContractTask | ResolvedGatherToolContractTask :type driver: ToolDriver

Parameters:	task – driver –
Returns:

to_dict()[source]¶