tardis.agents.batchsystemagent module

class tardis.agents.batchsystemagent.BatchSystemAgent(batch_system_adapter: tardis.interfaces.batchsystemadapter.BatchSystemAdapter)[source]

Bases: tardis.interfaces.batchsystemadapter.BatchSystemAdapter

async disintegrate_machine(drone_uuid: str) None[source]

Disintegrate a machine from the overlay batch system.

Parameters

drone_uuid (str) – Uuid of the worker node, for some sites corresponding to the host name of the drone.

Returns

None

async drain_machine(drone_uuid: str) None[source]

Drain a machine in the overlay batch system, which means that no new jobs will be accepted

Parameters

drone_uuid (str) – Uuid of the worker node, for some sites corresponding to the host name of the drone.

Returns

None

async get_allocation(drone_uuid: str) float[source]

Get the allocation of a worker node in the overlay batch system, which is defined as maximum of the ratios of requested over total resources (CPU, Memory, Disk, etc.).

Parameters

drone_uuid (str) – Uuid of the worker node, for some sites corresponding to the host name of the drone.

Returns

The allocation of a worker node as described above.

Return type

float

async get_machine_status(drone_uuid: str) tardis.interfaces.batchsystemadapter.MachineStatus[source]

Get the status of a worker node in the overlay batch system (Available, Draining, Drained, NotAvailable)

Parameters

drone_uuid (str) – Uuid of the worker node, for some sites corresponding to the host name of the drone.

Returns

The machine status in HTCondor (Available, Draining, Drained, NotAvailable)

Return type

MachineStatus

async get_utilisation(drone_uuid: str) float[source]

Get the utilisation of a worker node in the overlay batch system, which is defined as minimum of the ratios of requested over total resources (CPU, Memory, Disk, etc.).

Parameters

drone_uuid (str) – Uuid of the worker node, for some sites corresponding to the host name of the drone.

Returns

The utilisation of a worker node as described above.

Return type

float

async integrate_machine(drone_uuid: str) None[source]

Integrate a machine into the overlay batch system.

Parameters

drone_uuid (str) – Uuid of the worker node, for some sites corresponding to the host name of the drone.

Returns

None

property machine_meta_data_translation_mapping: tardis.utilities.attributedict.AttributeDict

The machine meta data translation mapping is used to translate units of the machine meta data in TARDIS as expected by the overlay batch system.

Returns

machine meta data translation mapping

Return type

AttributeDict