tardis.adapters.sites.htcondor module

class tardis.adapters.sites.htcondor.HTCondorAdapter(machine_type: str, site_name: str)[source]

Bases: SiteAdapter

async deploy_resource(resource_attributes: AttributeDict) → AttributeDict[source]

Abstract method to define the interface to deploy a new resource at a resource provider. :param resource_attributes: Contains describing attributes of the resource, defined in the Drone implementation! :type resource_attributes: AttributeDict :return: Contains updated describing attributes of the resource. :rtype: AttributeDict

handle_exceptions()[source]

Abstract method defining the interface to handle exception occurring during interacting with the resource provider. :return: None

htcondor_machine_meta_data_translation_mapping = {'Cores': 1, 'Disk': 1048576, 'Memory': 1024}
async resource_status(resource_attributes: AttributeDict) → AttributeDict[source]

Abstract method to define the interface to check the status of resources at a resource provider. :param resource_attributes: Contains describing attributes of the resource, defined in the Drone implementation! :type resource_attributes: AttributeDict :return: Contains updated describing attributes of the resource. :rtype: AttributeDict

async stop_resource(resource_attributes: AttributeDict) → None[source]

Stopping machines is equivalent to suspending jobs in HTCondor, therefore condor_suspend is called!

async terminate_resource(resource_attributes: AttributeDict) → None[source]

Abstract method to define the interface to terminate resources at a resource provider. :param resource_attributes: Contains describing attributes of the resource, defined in the Drone implementation! :type resource_attributes: AttributeDict :return: None

async tardis.adapters.sites.htcondor.condor_q(*resource_attributes: Tuple[AttributeDict, ...], executor: Executor) → Iterable[Mapping][source]
tardis.adapters.sites.htcondor.condor_rm(*resource_attributes: AttributeDict, executor: Executor) → Awaitable[Iterable[bool]][source]

Remove a number of resources, indicating success for each

async tardis.adapters.sites.htcondor.condor_submit(*resource_jdls: str, executor: Executor) → Iterable[str][source]

Submit a number of resources from their JDL, reporting the new Job ID for each

tardis.adapters.sites.htcondor.condor_suspend(*resource_attributes: AttributeDict, executor: Executor) → Awaitable[Iterable[bool]][source]

Suspend a number of resources, indicating success for each