schrodinger.job.server module

Interact with a Job Server.

class schrodinger.job.server.JobServersHealthCheck(interval: int, connect_deadline: int)

Bases: PyQt5.QtCore.QThread

serverStatusChanged

runHealthCheck()

Check the health of configured jobservers and report its information.

__init__(interval: int, connect_deadline: int)

Initializes the jobservers health check monitor.

Parameters

• interval – Interval in seconds to wait to trigger the health check of jobservers.

• connect_deadline – Deadline to wait in seconds for jobserver channel to setup if needed and query status.

run(self)

HighPriority = 4

HighestPriority = 5

IdlePriority = 0

InheritPriority = 7

LowPriority = 2

LowestPriority = 1

NormalPriority = 3

class Priority

Bases: int

TimeCriticalPriority = 6

blockSignals(self, bool) → bool

childEvent(self, QChildEvent)

children(self) → List[QObject]

connectNotify(self, QMetaMethod)

currentThread() → QThread

currentThreadId() → sip.voidptr

customEvent(self, QEvent)

deleteLater(self)

destroyed

destroyed(self, object: QObject = None) [signal]

disconnect(self)

disconnectNotify(self, QMetaMethod)

dumpObjectInfo(self)

dumpObjectTree(self)

dynamicPropertyNames(self) → List[QByteArray]

event(self, QEvent) → bool

eventDispatcher(self) → QAbstractEventDispatcher

eventFilter(self, QObject, QEvent) → bool

exec(self) → int

exec_(self) → int

exit(self, returnCode: int = 0)

findChild(self, type, name: str = '', options: Union[Qt.FindChildOptions, Qt.FindChildOption] = Qt.FindChildrenRecursively) → QObject

findChild(self, Tuple, name: str = ‘’, options: Union[Qt.FindChildOptions, Qt.FindChildOption] = Qt.FindChildrenRecursively) -> QObject

findChildren(self, type, name: str = '', options: Union[Qt.FindChildOptions, Qt.FindChildOption] = Qt.FindChildrenRecursively) → List[QObject]

findChildren(self, Tuple, name: str = ‘’, options: Union[Qt.FindChildOptions, Qt.FindChildOption] = Qt.FindChildrenRecursively) -> List[QObject] findChildren(self, type, QRegExp, options: Union[Qt.FindChildOptions, Qt.FindChildOption] = Qt.FindChildrenRecursively) -> List[QObject] findChildren(self, Tuple, QRegExp, options: Union[Qt.FindChildOptions, Qt.FindChildOption] = Qt.FindChildrenRecursively) -> List[QObject] findChildren(self, type, QRegularExpression, options: Union[Qt.FindChildOptions, Qt.FindChildOption] = Qt.FindChildrenRecursively) -> List[QObject] findChildren(self, Tuple, QRegularExpression, options: Union[Qt.FindChildOptions, Qt.FindChildOption] = Qt.FindChildrenRecursively) -> List[QObject]

finished

finished(self) [signal]

idealThreadCount() → int

inherits(self, str) → bool

installEventFilter(self, QObject)

isFinished(self) → bool

isInterruptionRequested(self) → bool

isRunning(self) → bool

isSignalConnected(self, QMetaMethod) → bool

isWidgetType(self) → bool

isWindowType(self) → bool

killTimer(self, int)

loopLevel(self) → int

metaObject(self) → QMetaObject

moveToThread(self, QThread)

msleep(int)

objectName(self) → str

objectNameChanged

objectNameChanged(self, str) [signal]

parent(self) → QObject

priority(self) → QThread.Priority

property(self, str) → Any

pyqtConfigure(...)

Each keyword argument is either the name of a Qt property or a Qt signal. For properties the property is set to the given value which should be of an appropriate type. For signals the signal is connected to the given value which should be a callable.

quit(self)

receivers(self, PYQT_SIGNAL) → int

removeEventFilter(self, QObject)

requestInterruption(self)

sender(self) → QObject

senderSignalIndex(self) → int

setEventDispatcher(self, QAbstractEventDispatcher)

setObjectName(self, str)

setParent(self, QObject)

setPriority(self, QThread.Priority)

setProperty(self, str, Any) → bool

setStackSize(self, int)

setTerminationEnabled(enabled: bool = True)

signalsBlocked(self) → bool

sleep(int)

stackSize(self) → int

start(self, priority: QThread.Priority = QThread.InheritPriority)

startTimer(self, int, timerType: Qt.TimerType = Qt.CoarseTimer) → int

started

started(self) [signal]

staticMetaObject = <PyQt5.QtCore.QMetaObject object>

terminate(self)

thread(self) → QThread

timerEvent(self, QTimerEvent)

tr(self, str, disambiguation: str = None, n: int = - 1) → str

usleep(int)

wait(self, msecs: int = ULONG_MAX) → bool

yieldCurrentThread()

schrodinger.job.server.ensure_localhost_server_running()

Makes sure there is a localhost jobserver running to do devtests. This server is configured in the default location.

schrodinger.job.server.jsc(schrodinger)

class schrodinger.job.server.ServerInfo(webServerSecret, hasLicenseChecking, hasServerAuth, hasSocketAuth, authSocketPath, versionString, APIVersion, hostname)

Bases: tuple

webServerSecret: str

Alias for field number 0

hasLicenseChecking: bool

Alias for field number 1

hasServerAuth: bool

Alias for field number 2

hasSocketAuth: bool

Alias for field number 3

authSocketPath: str

Alias for field number 4

versionString: str

Alias for field number 5

APIVersion: str

Alias for field number 6

hostname: str

Alias for field number 7

classmethod from_dict(data: dict) → schrodinger.job.server.ServerInfo

Convert a dict to a ServerInfo.

has_authenticator() → bool

__contains__(key, /)

Return key in self.

__len__()

Return len(self).

count(value, /)

Return number of occurrences of value.

index(value, start=0, stop=9223372036854775807, /)

Return first index of value.

Raises ValueError if the value is not present.

schrodinger.job.server.get_server_info(schrodinger: str, address: str) → schrodinger.job.server.ServerInfo

Subprocess ‘$SCHRODINGER/jsc server-info’ to get server information.

schrodinger.job.server.decode_to_server_info(data: Union[str, bytes]) → schrodinger.job.server.ServerInfo