libmuscle.manager.instantiator module

class libmuscle.manager.instantiator.CancelAllRequest[source]

Bases: InstantiatorRequest

Requests stopping all running processes.

class libmuscle.manager.instantiator.CrashedResult[source]

Bases: object

Signals that the instantiator process crashed.

class libmuscle.manager.instantiator.InstantiationRequest(instance: Reference, implementation: Implementation, res_req: ResourceRequirements, resources: Resources, instance_dir: Path, work_dir: Path, stdout_path: Path, stderr_path: Path)[source]

Bases: InstantiatorRequest

Requests instantiating a new process.

instance

The name of the instance

implementation

The implementation to start for it

resources

The resources to start it on

class libmuscle.manager.instantiator.InstantiatorRequest[source]

Bases: object

Base class for requests to an instantiator.

class libmuscle.manager.instantiator.Process(instance: Reference, resources: Resources)[source]

Bases: object

Represents a process.

instance

Name of instance this is the process of

resources

The resources allocated to this process

status

Current status of the process

exit_code

Exit code, if status is ERROR

error_msg

Error message, if status is ERROR

class libmuscle.manager.instantiator.ProcessStatus(value)[source]

Bases: Enum

Status of a process (instance).

CANCELED = 4
ERROR = 3
RUNNING = 1
STARTED = 0
SUCCESS = 2
is_finished() → bool[source]

Returns whether the job is finished.

Canceled jobs are considered finished, even if they’ve never run.

class libmuscle.manager.instantiator.QueueingLogHandler(queue: Queue)[source]

Bases: Handler

A logging Handler that enqueues records.

emit(record: LogRecord) → None[source]

Emit the record by enqueueing it.

Parameters:

record – A log record to enqueue.

class libmuscle.manager.instantiator.ShutdownRequest[source]

Bases: InstantiatorRequest

Requests shutting down the background process.

The process will stop once all running processes are done.