Processes

class pipeliner.process.Process(name: str, p_type: str, status: str, alias: str | None = None)

A Process represents a job that has been run by the Pipeliner

name

The name of the process. It should be in the format “<jobtype>/jobxxx/”. The trailing slash is required

alias

An alternate name for the process to make it easier to identify

outdir

The directory the process was written into

type

The process’s type

status

The process’s status. One of ‘running, scheduled, successful, failed, or aborted’

input_nodes

Node objects for files the process use as inputs

output_nodes

Node objects for files the process produces

remove_nonexistent_nodes() → List[str]

Checks the files for the output nodes of the process actually exist

Removes them from the output node list if the files are not found