deepdrivemd.deepdrivemd_stream

Functions

compute_number_of_nodes(cfg)
generate_task(cfg)

Classes

PipelineManager(cfg)

class deepdrivemd.deepdrivemd_stream.PipelineManager(cfg: deepdrivemd.config.StreamingExperimentConfig)

AGENT_PIPELINE_NAME = 'AgentPipeline'

AGENT_STAGE_NAME = 'Agent'

AGGREGATION_PIPELINE_NAME = 'AggregatingPipeline'

AGGREGATION_STAGE_NAME = 'Aggregating'

MACHINE_LEARNING_PIPELINE_NAME = 'MachineLearningPipeline'

MACHINE_LEARNING_STAGE_NAME = 'MachineLearning'

MOLECULAR_DYNAMICS_PIPELINE_NAME = 'MolecularDynamicsPipeline'

MOLECULAR_DYNAMICS_STAGE_NAME = 'MolecularDynamics'

generate_agent_stage() → radical.entk.stage.Stage

generate_aggregating_stage() → radical.entk.stage.Stage

generate_machine_learning_stage() → radical.entk.stage.Stage

generate_molecular_dynamics_stage() → radical.entk.stage.Stage

generate_pipelines() → List[radical.entk.pipeline.Pipeline]

deepdrivemd.deepdrivemd_stream.compute_number_of_nodes(cfg: deepdrivemd.config.StreamingExperimentConfig) → int

deepdrivemd.deepdrivemd_stream.generate_task(cfg: deepdrivemd.config.BaseStageConfig) → radical.entk.task.Task