Public Member Functions | |
| def | __init__ |
| def | get_input |
| def | get_output |
| def | get_error |
| def | add |
| def | extend |
| def | remove |
| def | clear |
| def | rewind |
| def | start |
| def | stop |
| def | is_alive |
| def | on_started |
| def | on_executor_stopped |
Sequence of jobs that can be monitored via signals. The "job-started" signal is emitted when a new job starts executing (callbacks are invoked with the Job as a parameter). "finished" is emitted when a job fails or the whole batch finishes (callbacks are invoked with the exit status as a parameter).
Definition at line 324 of file execution.py.
| def encode.execution.Batch.__init__ | ( | self, | ||
jobs = None | ||||
| ) |
| def encode.execution.Batch.add | ( | self, | ||
| job | ||||
| ) |
| def encode.execution.Batch.clear | ( | self | ) |
Remove all jobs from this batch. The batch must not be running.
Definition at line 394 of file execution.py.
| def encode.execution.Batch.extend | ( | self, | ||
| jobs | ||||
| ) |
| def encode.execution.Batch.get_error | ( | self | ) |
| def encode.execution.Batch.get_input | ( | self, | ||
fileno = 0 | ||||
| ) |
| def encode.execution.Batch.get_output | ( | self, | ||
fileno = 1 | ||||
| ) |
| def encode.execution.Batch.is_alive | ( | self | ) |
| def encode.execution.Batch.on_executor_stopped | ( | self, | ||
| executor, | ||||
| status | ||||
| ) |
Definition at line 442 of file execution.py.
| def encode.execution.Batch.on_started | ( | self, | ||
| batch, | ||||
| job | ||||
| ) |
Definition at line 439 of file execution.py.
| def encode.execution.Batch.remove | ( | self, | ||
| job | ||||
| ) |
Remove JOB from this batch. The batch must not be running.
Definition at line 388 of file execution.py.
| def encode.execution.Batch.rewind | ( | self | ) |
Batch position will be reset. The batch must not be running.
Definition at line 400 of file execution.py.
| def encode.execution.Batch.start | ( | self | ) |
| def encode.execution.Batch.stop | ( | self | ) |
1.4.7