schrodinger.application.models.execution.modelrunner module

class schrodinger.application.models.execution.modelrunner.AbstractModelRunner(composite_model: CompositeModel)

Bases: object

runner_type: RunnerType = None

__init__(composite_model: CompositeModel)

Parameters:

composite_model – The composite model to run. It must have a row source and a row sink set. The model’s logic type must match the runner class.

run(user: str) → ExecutionRecord

Run the model and return an execution record.

The returned ExecutionRecord is a partial object without a record_id, which will be assigned when stored in the library.

Parameters:

user – The username of the user running the model.

Returns:

Partial ExecutionRecord (without record_id).

class schrodinger.application.models.execution.modelrunner.MapFunctionModelRunner(composite_model: CompositeModel)

Bases: AbstractModelRunner

runner_type: RunnerType = 'MAP-FUNCTION'

class schrodinger.application.models.execution.modelrunner.BeamYamlModelRunner(composite_model: CompositeModel)

Bases: AbstractModelRunner

Direct Runner for Beam pipelines.

runner_type: RunnerType = 'DIRECT-RUNNER'

class schrodinger.application.models.execution.modelrunner.SeamYamlModelRunner(composite_model: CompositeModel)

Bases: BeamYamlModelRunner

Seam Runner for Beam pipelines.

runner_type: RunnerType = 'SEAM-RUNNER'

schrodinger.application.models.execution.modelrunner.run_model(composite_model: CompositeModel, user: str, runner_type: RunnerType = None) → ExecutionRecord

Run the given composite model using the specified or default runner. The composite model must have a row source and a row sink set.

Parameters:

• composite_model – The composite model to run

• user – The username of the user running the model

• runner_type – The type of runner to use, or None for default

Returns:

Partial ExecutionRecord (without record_id)

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

Bases: BlockingFunctionTask

Task interface for running a 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()

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.