This document is for an old release of Galaxy. You can alternatively view this page in the latest release if it exists or view the top of the latest release's documentation.

Source code for galaxy.jobs.runners.util.cli.job.slurm_torque

import re

from .torque import Torque

__all__ = ("SlurmTorque",)

[docs]class SlurmTorque(Torque): """A CLI job executor for Slurm's Torque compatibility mode. This differs from real torque CLI in that -x command line is not available so job status needs to be parsed from qstat table instead of XML. """
[docs] def get_status(self, job_ids=None): return "qstat"
[docs] def parse_status(self, status, job_ids): rval = {} for line in status.strip().splitlines(): if line.startswith("Job ID"): continue line_parts = re.compile(r"\s+").split(line) if len(line_parts) < 5: continue id = line_parts[0] state = line_parts[4] if id in job_ids: # map PBS job states to Galaxy job states. rval[id] = self._get_job_state(state) return rval