calypso.dispatchers.orchestrator.scheduler.base_scheduler module

class calypso.dispatchers.orchestrator.scheduler.base_scheduler.BaseScheduler(name: str, executor: BaseExecutor, **kwargs)

Bases: object

abstractmethod generate_job_script(job)

abstractmethod generate_task_env(jobs: list[Job])

abstractmethod generate_task_head(name: str)

abstractmethod generate_task_script(jobs: list[Job], submit_script_name: str)

generate_task_script_name(jobs: list[Job], len_job_name: int = 40)

abstractmethod kill(job)

abstractmethod query(job)

abstractmethod submit(jobs, timeout=3600)