seamm_scheduler

• seamm_scheduler package
  • Submodules
  • seamm_scheduler.backend module
    • QueueBackend
      • QueueBackend.cancel()
      • QueueBackend.cancel_many()
      • QueueBackend.count_jobs()
      • QueueBackend.find_jobs()
      • QueueBackend.host
      • QueueBackend.poll_many()
      • QueueBackend.submit()
  • seamm_scheduler.config module
    • The keys of a section
    • FieldLimits
      • FieldLimits.choices
      • FieldLimits.maximum
      • FieldLimits.minimum
    • SlurmSection
    • TargetSection
      • TargetSection.batch_scheduler
      • TargetSection.build_backend()
      • TargetSection.build_stager()
      • TargetSection.build_task_backend()
      • TargetSection.build_task_stager()
      • TargetSection.bundle_tasks
      • TargetSection.bundle_walltime
      • TargetSection.directives
      • TargetSection.estimate_scale
      • TargetSection.from_settings()
      • TargetSection.host
      • TargetSection.inline_below
      • TargetSection.is_batch
      • TargetSection.limits
      • TargetSection.max_concurrent_jobs
      • TargetSection.max_queued_tasks
      • TargetSection.max_resubmits
      • TargetSection.max_walltime
      • TargetSection.merge_overrides()
      • TargetSection.min_task_walltime
      • TargetSection.name
      • TargetSection.poll_interval
      • TargetSection.remote_conda_env
      • TargetSection.remote_python
      • TargetSection.remote_root
      • TargetSection.remote_run_from_jobserver
      • TargetSection.remote_seamm_root
      • TargetSection.remote_wdir_for()
      • TargetSection.scheduler
      • TargetSection.setup
      • TargetSection.shared_filesystem
      • TargetSection.task_scheduler
      • TargetSection.task_settings()
      • TargetSection.task_transport
      • TargetSection.tasks
      • TargetSection.tasks_share_filesystem
      • TargetSection.transport
      • TargetSection.type
      • TargetSection.url
    • list_sections()
    • load_slurm_config()
    • load_target()
  • seamm_scheduler.local module
    • LocalTransport
      • LocalTransport.host
      • LocalTransport.name
      • LocalTransport.run()
  • seamm_scheduler.pbs module
    • Pbs
      • Pbs.cancel_cmd()
      • Pbs.classify()
      • Pbs.count_cmd()
      • Pbs.directive_lines()
      • Pbs.directive_prefix
      • Pbs.directives()
      • Pbs.env_names
      • Pbs.env_prefixes
      • Pbs.find_cmd()
      • Pbs.log_directives()
      • Pbs.name
      • Pbs.parse_status()
      • Pbs.parse_submit()
      • Pbs.poll()
      • Pbs.prologue_lines()
      • Pbs.status_cmd()
      • Pbs.submit_cmd()
    • classify()
  • seamm_scheduler.scheduler module
    • JobStatus
      • JobStatus.category
      • JobStatus.exit_code
      • JobStatus.is_terminal
      • JobStatus.job_id
      • JobStatus.raw
      • JobStatus.reason
      • JobStatus.state
      • JobStatus.task_state
      • JobStatus.timed_out
    • SCHEDULERS
    • Scheduler
      • Scheduler.cancel_cmd()
      • Scheduler.classify()
      • Scheduler.count_cmd()
      • Scheduler.directive_lines()
      • Scheduler.directive_prefix
      • Scheduler.directives()
      • Scheduler.env_names
      • Scheduler.find()
      • Scheduler.find_cmd()
      • Scheduler.log_directives()
      • Scheduler.name
      • Scheduler.parse_status()
      • Scheduler.parse_submit()
      • Scheduler.poll()
      • Scheduler.poll_failed
      • Scheduler.prologue_lines()
      • Scheduler.status_cmd()
      • Scheduler.submit_cmd()
    • SchedulerError
    • SubmitError
    • TASK_STATES
    • format_memory_mb()
    • format_walltime()
    • get_scheduler()
  • seamm_scheduler.script module
    • build_script()
  • seamm_scheduler.seamm module
    • Seamm
      • Seamm.cancel_cmd()
      • Seamm.classify()
      • Seamm.count_cmd()
      • Seamm.directive_lines()
      • Seamm.directive_prefix
      • Seamm.directives()
      • Seamm.env_names
      • Seamm.env_prefixes
      • Seamm.find_cmd()
      • Seamm.log_directives()
      • Seamm.name
      • Seamm.parse_status()
      • Seamm.parse_submit()
      • Seamm.python
      • Seamm.root
      • Seamm.status_cmd()
      • Seamm.submit_cmd()
    • classify()
  • seamm_scheduler.slurm module
    • LocalSlurm
    • Slurm
      • Slurm.cancel_cmd()
      • Slurm.classify()
      • Slurm.count_cmd()
      • Slurm.directive_lines()
      • Slurm.directive_prefix
      • Slurm.directives()
      • Slurm.env_names
      • Slurm.env_prefixes
      • Slurm.find()
      • Slurm.find_cmd()
      • Slurm.log_directives()
      • Slurm.name
      • Slurm.parse_status()
      • Slurm.parse_submit()
      • Slurm.poll()
      • Slurm.status_cmd()
      • Slurm.submit_cmd()
    • SlurmBackend
    • SlurmError
    • SlurmSubmitError
    • SshSlurm
      • SshSlurm.host
      • SshSlurm.ssh_command
    • classify()
  • seamm_scheduler.ssh module
    • SshTransport
      • SshTransport.name
      • SshTransport.run()
    • TASK_SSH_OPTIONS
  • seamm_scheduler.stage module
    • JobStager
      • JobStager.pull()
      • JobStager.push()
      • JobStager.stage_in()
      • JobStager.stage_out()
    • LocalStager
      • LocalStager.stage_in()
      • LocalStager.stage_out()
    • RsyncStager
      • RsyncStager.pull()
      • RsyncStager.push()
      • RsyncStager.stage_in()
      • RsyncStager.stage_out()
    • StageError
  • seamm_scheduler.taskserver module
    • DEFAULT_MEMORY_PER_CORE
    • EVALUATOR_MEMORY
    • KEEP_ENVIRONMENT
    • KEEP_FINISHED
    • KILL_GRACE
    • MACHINE_MEMORY_FLOOR
    • MEMORY_GRACE
    • MEMORY_LIMIT_FACTOR
    • QUEUED
    • Queue
      • Queue.cancel()
      • Queue.charge()
      • Queue.check()
      • Queue.close()
      • Queue.finish()
      • Queue.get()
      • Queue.jobs()
      • Queue.schedule()
      • Queue.submit()
    • RESERVE_AFTER
    • SCHEMA_VERSION
    • START_TIMEOUT
    • capacity()
    • default_root()
    • format_memory()
    • main()
    • parse_directives()
    • parse_memory()
    • parse_time()
    • run_job()
    • settings()
  • Module contents