schrodinger.application.models.execution.modelrunner module

class schrodinger.application.models.execution.modelrunner.AbstractModelRunner(composite_model: CompositeModel, row_source: AbstractRowSource, row_sink: AbstractRowSink)

Bases: object

Base class for running a composite model.

runner_type: RunnerType = None

__init__(composite_model: CompositeModel, row_source: AbstractRowSource, row_sink: AbstractRowSink)

run(user: str) → ExecutionRecord

Run the model and return a partial execution record.

class schrodinger.application.models.execution.modelrunner.BeamYamlModelRunner(composite_model: CompositeModel, row_source: AbstractRowSource, row_sink: AbstractRowSink)

Bases: AbstractModelRunner

Run a model pipeline with the Beam Direct Runner.

runner_type: RunnerType = 'DIRECT-RUNNER'

class schrodinger.application.models.execution.modelrunner.SeamYamlModelRunner(composite_model: CompositeModel, row_source: AbstractRowSource, row_sink: AbstractRowSink)

Bases: BeamYamlModelRunner

Run a model pipeline with the Seam Runner.

runner_type: RunnerType = 'SEAM-RUNNER'

run(user: str) → ExecutionRecord

Run the model and attach the Seam directory when present.

schrodinger.application.models.execution.modelrunner.run_model(composite_model: CompositeModel, row_source: AbstractRowSource, row_sink: AbstractRowSink, user: str, runner_type: RunnerType = RunnerType.SEAM_RUNNER) → ExecutionRecord

Run a valid composite model using a Beam YAML runner.

class schrodinger.application.models.execution.modelrunner.ModelRunnerTask(*args, _param_type=<object object>, **kwargs)

Bases: BlockingFunctionTask

Task interface for running a composite model.

class Input(*args, _param_type=<object object>, **kwargs)

Bases: CompoundParam

composite: CompositeModel

A parameter of the class.

library: Library

A parameter of the class.

row_source: AbstractRowSource

A parameter of the class.

row_sink: AbstractRowSink

A parameter of the class.

compositeChanged

A pyqtSignal emitted by instances of the class.

compositeReplaced

A pyqtSignal emitted by instances of the class.

libraryChanged

A pyqtSignal emitted by instances of the class.

libraryReplaced

A pyqtSignal emitted by instances of the class.

row_sinkChanged

A pyqtSignal emitted by instances of the class.

row_sinkReplaced

A pyqtSignal emitted by instances of the class.

row_sourceChanged

A pyqtSignal emitted by instances of the class.

row_sourceReplaced

A pyqtSignal emitted by instances of the class.

class Output(*args, _param_type=<object object>, **kwargs)

Bases: CompoundParam

record: ExecutionRecord

A parameter of the class.

recordChanged

A pyqtSignal emitted by instances of the class.

recordReplaced

A pyqtSignal emitted by instances of the class.

mainFunction() → None

Run the configured model and store its execution record.

calling_contextChanged

A pyqtSignal emitted by instances of the class.

calling_contextReplaced

A pyqtSignal emitted by instances of the class.

failure_infoChanged

A pyqtSignal emitted by instances of the class.

failure_infoReplaced

A pyqtSignal emitted by instances of the class.

input: CompoundParam

A parameter of the class.

inputChanged

A pyqtSignal emitted by instances of the class.

inputReplaced

A pyqtSignal emitted by instances of the class.

max_progressChanged

A pyqtSignal emitted by instances of the class.

max_progressReplaced

A pyqtSignal emitted by instances of the class.

nameChanged

A pyqtSignal emitted by instances of the class.

nameReplaced

A pyqtSignal emitted by instances of the class.

output: CompoundParam

A parameter of the class.

outputChanged

A pyqtSignal emitted by instances of the class.

outputReplaced

A pyqtSignal emitted by instances of the class.

progressChanged

A pyqtSignal emitted by instances of the class.

progressReplaced

A pyqtSignal emitted by instances of the class.

progress_stringChanged

A pyqtSignal emitted by instances of the class.

progress_stringReplaced

A pyqtSignal emitted by instances of the class.

statusChanged

A pyqtSignal emitted by instances of the class.

statusReplaced

A pyqtSignal emitted by instances of the class.