pulsar.managers.base package¶
Submodules¶
pulsar.managers.base.base_drmaa module¶
Module defines a base class for Pulsar managers using DRMAA.
- class pulsar.managers.base.base_drmaa.BaseDrmaaManager(name, app, **kwds)[source]¶
Bases:
ExternalBaseManager
Base class for Pulsar managers using DRMAA.
pulsar.managers.base.directory module¶
- class pulsar.managers.base.directory.DirectoryBaseManager(name, app, **kwds)[source]¶
Bases:
BaseManager
- job_stderr_contents(job_id)[source]¶
After completion, return contents of stderr of the job as produced by the job runner.
- job_stdout_contents(job_id)[source]¶
After completion, return contents of stdout of the job as produced by the job runner.
pulsar.managers.base.external module¶
- class pulsar.managers.base.external.ExternalBaseManager(name, app, **kwds)[source]¶
Bases:
DirectoryBaseManager
Base class for managers that interact with external distributed resource managers.
- clean(job_id)[source]¶
Delete job directory and clean up resources associated with job with id job_id.
Module contents¶
Base Classes and Infrastructure Supporting Concret Manager Implementations.
- class pulsar.managers.base.BaseManager(name, app, **kwds)[source]¶
Bases:
ManagerInterface
- clean(job_id)[source]¶
Delete job directory and clean up resources associated with job with id job_id.
- job_directory(job_id)¶
Return a JobDirectory abstraction describing the state of the job working directory.
- class pulsar.managers.base.JobDirectory(staging_directory, job_id, lock_manager=None, directory_maker=None)[source]¶
Bases:
RemoteJobDirectory