laborchestrator package

Subpackages

• laborchestrator.database_integration package
  • Submodules
    • laborchestrator.database_integration.status_db_dummy module
      • StatusDBDummyImplementation
    • laborchestrator.database_integration.status_db_interface module
      • StatusDBInterface
  • Module contents
    • StatusDBDummyImplementation
      • StatusDBDummyImplementation._abc_impl
      • StatusDBDummyImplementation.add_container()
      • StatusDBDummyImplementation.add_process_to_db()
      • StatusDBDummyImplementation.create_experiment()
      • StatusDBDummyImplementation.get_all_positions()
      • StatusDBDummyImplementation.get_available_processes()
      • StatusDBDummyImplementation.get_cont_info_by_barcode()
      • StatusDBDummyImplementation.get_container_at_position()
      • StatusDBDummyImplementation.get_estimated_duration()
      • StatusDBDummyImplementation.get_estimated_durations()
      • StatusDBDummyImplementation.get_server_certificate()
      • StatusDBDummyImplementation.lidded_container()
      • StatusDBDummyImplementation.moved_container()
      • StatusDBDummyImplementation.position_empty()
      • StatusDBDummyImplementation.remove_container()
      • StatusDBDummyImplementation.safe_step_to_db()
      • StatusDBDummyImplementation.set_barcode()
      • StatusDBDummyImplementation.set_barcode_at_position()
      • StatusDBDummyImplementation.unlidded_container()
      • StatusDBDummyImplementation.update_lid_position()
      • StatusDBDummyImplementation.write_server_certificate()
    • StatusDBInterface
      • StatusDBInterface._abc_impl
      • StatusDBInterface.add_container()
      • StatusDBInterface.add_process_to_db()
      • StatusDBInterface.create_experiment()
      • StatusDBInterface.get_all_positions()
      • StatusDBInterface.get_available_processes()
      • StatusDBInterface.get_cont_info_by_barcode()
      • StatusDBInterface.get_container_at_position()
      • StatusDBInterface.get_estimated_duration()
      • StatusDBInterface.get_estimated_durations()
      • StatusDBInterface.get_process()
      • StatusDBInterface.get_server_certificate()
      • StatusDBInterface.lidded_container()
      • StatusDBInterface.moved_container()
      • StatusDBInterface.position_empty()
      • StatusDBInterface.remove_container()
      • StatusDBInterface.safe_step_to_db()
      • StatusDBInterface.set_barcode()
      • StatusDBInterface.unlidded_container()
      • StatusDBInterface.update_lid_position()
      • StatusDBInterface.write_server_certificate()
• laborchestrator.engine package
  • Submodules
    • laborchestrator.engine.schedule_manager module
      • ScheduleManager
      • ScheduleQuality
    • laborchestrator.engine.wfg_manager module
      • WFGManager
    • laborchestrator.engine.worker_interface module
      • DummyHandler
      • ObservableProtocolHandler
      • WorkerInterface
    • laborchestrator.engine.worker_observer module
      • WorkerObserver
  • Module contents
    • ScheduleManager
      • ScheduleManager._get_schedule_from_scheduler()
      • ScheduleManager._hold_rescheduling
      • ScheduleManager._manage_rescheduling()
      • ScheduleManager._processes_to_schedule
      • ScheduleManager._reschedule()
      • ScheduleManager._rescheduling
      • ScheduleManager._schedule_optimal
      • ScheduleManager._schedule_valid
      • ScheduleManager._scheduler_client
      • ScheduleManager.configure_lab()
      • ScheduleManager.continue_rescheduling()
      • ScheduleManager.db_client
      • ScheduleManager.extract_near_future()
      • ScheduleManager.hold_rescheduling()
      • ScheduleManager.is_connected_to_scheduler()
      • ScheduleManager.is_rescheduling()
      • ScheduleManager.jssp
      • ScheduleManager.keep_horizon()
      • ScheduleManager.mark_schedule_invalid()
      • ScheduleManager.mark_schedule_suboptimal()
      • ScheduleManager.schedule_executable()
      • ScheduleManager.schedule_quality
      • ScheduleManager.scheduler_client
      • ScheduleManager.scheduler_heart_beat()
      • ScheduleManager.time_limit_long
      • ScheduleManager.time_limit_short
      • ScheduleManager.try_scheduler_connection()
    • WFGManager
      • WFGManager._check_wfg()
      • WFGManager._do_computation()
      • WFGManager._eval_if()
      • WFGManager._set_variable()
      • WFGManager._wfg_checker()
      • WFGManager.complete_preferences()
      • WFGManager.jssp
      • WFGManager.set_origins()
    • WorkerInterface
      • WorkerInterface._work()
      • WorkerInterface.check_prerequisites()
      • WorkerInterface.db_client
      • WorkerInterface.determine_destination_position()
      • WorkerInterface.execute_process_step()
      • WorkerInterface.job_is_due()
      • WorkerInterface.observation_handlers
      • WorkerInterface.process_step_finished()
      • WorkerInterface.simulate_process_step()
      • WorkerInterface.simulation_mode
    • WorkerObserver
      • WorkerObserver._observe_protocol()
      • WorkerObserver.is_delayed_significantly()
      • WorkerObserver.jssp
      • WorkerObserver.observe()
      • WorkerObserver.observed_jobs
      • WorkerObserver.schedule_manager
      • WorkerObserver.wfg_manager
      • WorkerObserver.worker
• laborchestrator.logs package
  • Module contents
• laborchestrator.sila_server package
  • Subpackages
    • laborchestrator.sila_server.feature_implementations package
      • Submodules
      • Module contents
    • laborchestrator.sila_server.generated package
      • Subpackages
      • Submodules
      • Module contents
  • Submodules
    • laborchestrator.sila_server.__main__ module
      • initialize_logging()
      • main()
    • laborchestrator.sila_server.server module
      • Server
  • Module contents
    • Client
      • Client.CancelController
      • Client.LabOrchestratorService
      • Client.PauseController
      • Client.SimulationController
      • Client._expected_features
    • Server

Submodules

• laborchestrator.logging_manager module
  • get_standard_logger()
• laborchestrator.old_dash_app module
  • SMDashApp
    • SMDashApp.app
    • SMDashApp.importable_processes
    • SMDashApp.p
    • SMDashApp.run()
    • SMDashApp.selected_operation
    • SMDashApp.sm_interface
    • SMDashApp.stop()
  • create_timestamp()
  • to_process_id()
• laborchestrator.orchestrator_implementation module
  • Orchestrator
    • Orchestrator._abc_impl
    • Orchestrator._simulation_speed
    • Orchestrator.add_lab_resources_from_database()
    • Orchestrator.add_lab_resources_from_file()
    • Orchestrator.add_labware()
    • Orchestrator.add_process()
    • Orchestrator.add_to_schedule()
    • Orchestrator.available_processes
    • Orchestrator.change_step()
    • Orchestrator.check_labware_presence()
    • Orchestrator.continue_container()
    • Orchestrator.create_labware_location_graph()
    • Orchestrator.db_client
    • Orchestrator.error_resolved()
    • Orchestrator.execution_on_time()
    • Orchestrator.export_current_scheduling_problem()
    • Orchestrator.gantt_chart_executed_processes
    • Orchestrator.gantt_chart_scheduled_processes
    • Orchestrator.get_log()
    • Orchestrator.get_operable_node()
    • Orchestrator.get_parameter()
    • Orchestrator.get_process_state()
    • Orchestrator.get_process_step_state()
    • Orchestrator.human_did_job()
    • Orchestrator.in_time
    • Orchestrator.inject_db_interface()
    • Orchestrator.insert_process_step()
    • Orchestrator.interrupt_process_step()
    • Orchestrator.logging_level
    • Orchestrator.pause_processes()
    • Orchestrator.process_finished()
    • Orchestrator.process_reader
    • Orchestrator.process_step_executed_externally()
    • Orchestrator.processes
    • Orchestrator.remove_container()
    • Orchestrator.remove_labware()
    • Orchestrator.remove_process_step()
    • Orchestrator.remove_processes()
    • Orchestrator.reset_error_state()
    • Orchestrator.restart_process_from_datetime()
    • Orchestrator.resume_processes()
    • Orchestrator.retry_process_step()
    • Orchestrator.schedule_manager
    • Orchestrator.select_process_reader()
    • Orchestrator.set_parameter()
    • Orchestrator.set_process_priority()
    • Orchestrator.sila_server
    • Orchestrator.simulate_all_processes()
    • Orchestrator.simulation_speed
    • Orchestrator.start_processes()
    • Orchestrator.start_sila_interface()
    • Orchestrator.stop_and_remove_all_processes()
    • Orchestrator.stop_container()
    • Orchestrator.stop_processes()
    • Orchestrator.test_add_process()
    • Orchestrator.wfg_manager
    • Orchestrator.worker
    • Orchestrator.worker_observer
    • Orchestrator.workflow_graph_executed_processes
    • Orchestrator.workflow_graph_scheduled_processes
• laborchestrator.orchestrator_interface module
  • FormalLabwareManagerInterface
    • FormalLabwareManagerInterface._abc_impl
    • FormalLabwareManagerInterface.add_labware()
    • FormalLabwareManagerInterface.check_labware_presence()
    • FormalLabwareManagerInterface.create_labware_location_graph()
    • FormalLabwareManagerInterface.remove_labware()
  • FormalLoggingInterface
    • FormalLoggingInterface._abc_impl
    • FormalLoggingInterface.get_log()
    • FormalLoggingInterface.logging_level
  • FormalOrchestratorConfigInterface
    • FormalOrchestratorConfigInterface._abc_impl
    • FormalOrchestratorConfigInterface.add_lab_resources_from_database()
    • FormalOrchestratorConfigInterface.add_lab_resources_from_file()
  • FormalProcessControllerInterface
    • FormalProcessControllerInterface._abc_impl
    • FormalProcessControllerInterface.add_process()
    • FormalProcessControllerInterface.available_processes
    • FormalProcessControllerInterface.gantt_chart_executed_processes
    • FormalProcessControllerInterface.gantt_chart_scheduled_processes
    • FormalProcessControllerInterface.get_parameter()
    • FormalProcessControllerInterface.get_process_state()
    • FormalProcessControllerInterface.in_time
    • FormalProcessControllerInterface.pause_processes()
    • FormalProcessControllerInterface.processes
    • FormalProcessControllerInterface.remove_processes()
    • FormalProcessControllerInterface.restart_process_from_datetime()
    • FormalProcessControllerInterface.resume_processes()
    • FormalProcessControllerInterface.select_process_reader()
    • FormalProcessControllerInterface.set_parameter()
    • FormalProcessControllerInterface.set_process_priority()
    • FormalProcessControllerInterface.simulate_all_processes()
    • FormalProcessControllerInterface.simulation_speed
    • FormalProcessControllerInterface.start_processes()
    • FormalProcessControllerInterface.stop_processes()
    • FormalProcessControllerInterface.workflow_graph_executed_processes
    • FormalProcessControllerInterface.workflow_graph_scheduled_processes
  • FormalProcessStepControllerInterface
    • FormalProcessStepControllerInterface._abc_impl
    • FormalProcessStepControllerInterface.get_process_step_state()
    • FormalProcessStepControllerInterface.insert_process_step()
    • FormalProcessStepControllerInterface.interrupt_process_step()
    • FormalProcessStepControllerInterface.process_step_executed_externally()
    • FormalProcessStepControllerInterface.remove_process_step()
    • FormalProcessStepControllerInterface.reset_error_state()
    • FormalProcessStepControllerInterface.retry_process_step()
  • FormalSampleManagerInterface
    • FormalSampleManagerInterface._abc_impl
    • FormalSampleManagerInterface.get_sample_labware()
    • FormalSampleManagerInterface.sample_location_graph
  • LabwareInfo
    • LabwareInfo.URI
    • LabwareInfo.barcode
  • OrchestratorInterface
    • OrchestratorInterface._abc_impl
  • ProcessDescription
    • ProcessDescription.description
    • ProcessDescription.file_path
    • ProcessDescription.name
  • ProcessExecutionState
    • ProcessExecutionState.FINISHED
    • ProcessExecutionState.IDLE
    • ProcessExecutionState.PAUSED
    • ProcessExecutionState.RUNNING
    • ProcessExecutionState.SCHEDULED
  • ProcessInfo
    • ProcessInfo.name
    • ProcessInfo.priority
    • ProcessInfo.state
  • ProcessParsingError
  • ProcessReader
    • ProcessReader.PYTHONLABREADER
• laborchestrator.process_reader module
  • ProcessReader
    • ProcessReader._abc_impl
    • ProcessReader.adjust_opacities()
    • ProcessReader.get_available_processes()
    • ProcessReader.read_process()
• laborchestrator.pythonlab_process_finder module
  • ImportableProcess
    • ImportableProcess._asdict()
    • ImportableProcess._field_defaults
    • ImportableProcess._fields
    • ImportableProcess._make()
    • ImportableProcess._replace()
    • ImportableProcess.file_path
    • ImportableProcess.module
    • ImportableProcess.name
  • ProcessFinder
    • ProcessFinder._find_processes()
    • ProcessFinder.create_process()
    • ProcessFinder.create_process_from_id()
    • ProcessFinder.get_processes()
    • ProcessFinder.importable_processes_from_string()
    • ProcessFinder.to_process_id()
• laborchestrator.pythonlab_reader module
  • PythonLabReader
    • PythonLabReader._abc_impl
    • PythonLabReader.costs_from_prio()
    • PythonLabReader.fill_transfer_times()
    • PythonLabReader.find_origin()
    • PythonLabReader.get_available_processes()
    • PythonLabReader.preprocess_wfg()
    • PythonLabReader.read_computations()
    • PythonLabReader.read_containers()
    • PythonLabReader.read_if_nodes()
    • PythonLabReader.read_jobs()
    • PythonLabReader.read_precedences()
    • PythonLabReader.read_process()
    • PythonLabReader.read_variables()
    • PythonLabReader.read_wait_cons()
    • PythonLabReader.relabel_nodes()
  • read_process_test()
  • try_to_read_process()
• laborchestrator.start_script module
  • start_up()
• laborchestrator.structures module
  • Computation
    • Computation.evaluation
    • Computation.name
    • Computation.opacity
    • Computation.prior
    • Computation.result
    • Computation.status
    • Computation.var_name
  • ContainerInfo
    • ContainerInfo.barcode
    • ContainerInfo.content
    • ContainerInfo.current_device
    • ContainerInfo.current_pos
    • ContainerInfo.filled
    • ContainerInfo.finished
    • ContainerInfo.in_error_state
    • ContainerInfo.is_reagent
    • ContainerInfo.labware_type
    • ContainerInfo.lid_site
    • ContainerInfo.lidded
    • ContainerInfo.name
    • ContainerInfo.start_device
  • IfNode
    • IfNode.decision
    • IfNode.evaluation
    • IfNode.false_tree
    • IfNode.name
    • IfNode.opacity
    • IfNode.prior
    • IfNode.status
    • IfNode.true_tree
  • MoveStep
    • MoveStep.destination_pos
    • MoveStep.origin_device
    • MoveStep.origin_pos
    • MoveStep.pref_dest_pos
    • MoveStep.target_device
  • ProcessStep
    • ProcessStep.cont
    • ProcessStep.cont_names
    • ProcessStep.data
    • ProcessStep.duration
    • ProcessStep.finish
    • ProcessStep.function
    • ProcessStep.is_start
    • ProcessStep.label
    • ProcessStep.main_device
    • ProcessStep.max_wait
    • ProcessStep.min_wait
    • ProcessStep.name
    • ProcessStep.opacity
    • ProcessStep.prior
    • ProcessStep.priors_done()
    • ProcessStep.process_name
    • ProcessStep.result
    • ProcessStep.start
    • ProcessStep.status
    • ProcessStep.used_devices
    • ProcessStep.wait_cost
    • ProcessStep.wait_to_start_costs
  • SMProcess
    • SMProcess._status
    • SMProcess.computations
    • SMProcess.containers
    • SMProcess.experiment_uuid
    • SMProcess.get_info()
    • SMProcess.if_nodes
    • SMProcess.min_start
    • SMProcess.name
    • SMProcess.starting_nodes
    • SMProcess.status
    • SMProcess.steps
    • SMProcess.update_reagent_opacity()
    • SMProcess.variables
    • SMProcess.wfg
  • Schedule
  • ScheduledAssignment
    • ScheduledAssignment.device
    • ScheduledAssignment.machine_prior
    • ScheduledAssignment.participating
    • ScheduledAssignment.start
  • SchedulingInstance
    • SchedulingInstance.add_process()
    • SchedulingInstance.combined_wfg
    • SchedulingInstance.computation_by_id
    • SchedulingInstance.container_info_by_name
    • SchedulingInstance.definite_computation_by_id
    • SchedulingInstance.definite_if_node_by_id
    • SchedulingInstance.definite_step_by_id
    • SchedulingInstance.definite_var_by_id
    • SchedulingInstance.deleted_operable
    • SchedulingInstance.gannt_chart()
    • SchedulingInstance.if_node_by_id
    • SchedulingInstance.naming_consistent()
    • SchedulingInstance.operable
    • SchedulingInstance.process_by_name
    • SchedulingInstance.process_stati_by_name
    • SchedulingInstance.remove_operable()
    • SchedulingInstance.remove_process()
    • SchedulingInstance.running_processes_names
    • SchedulingInstance.schedule
    • SchedulingInstance.schedule_violated()
    • SchedulingInstance.set_schedule()
    • SchedulingInstance.start_process()
    • SchedulingInstance.step_by_id
    • SchedulingInstance.stop_process()
    • SchedulingInstance.unique_job_names()
    • SchedulingInstance.update_reagent_opacity()
    • SchedulingInstance.var_by_id
    • SchedulingInstance.visualize_wfg()
  • StepStatus
    • StepStatus.ERROR
    • StepStatus.FINISHED
    • StepStatus.RUNNING
    • StepStatus.WAITING
  • UsedDevice
    • UsedDevice.device_type
    • UsedDevice.name
    • UsedDevice.preferred
    • UsedDevice.tag
  • Variable
    • Variable.name
    • Variable.opacity
    • Variable.prior
    • Variable.result
    • Variable.status
    • Variable.var_name
• laborchestrator.traffic_light module
  • TrafficLight()
  • register_traffic_light_callbacks()
• laborchestrator.workflowgraph module
  • Assignment
    • Assignment.machine_assignments
    • Assignment.machine_prior
    • Assignment.start
  • Edge
    • Edge.Head
    • Edge.MaxWaitingTime
    • Edge.MinWaitingTime
    • Edge.Tail
    • Edge.WaitCost
    • Edge._asdict()
    • Edge._field_defaults
    • Edge._fields
    • Edge._make()
    • Edge._replace()
  • Graph
    • Graph.Edges
    • Graph.Nodes
    • Graph._asdict()
    • Graph._field_defaults
    • Graph._fields
    • Graph._make()
    • Graph._replace()
  • Node
    • Node.Duration
    • Node.Finish
    • Node.Idx
    • Node.RequiredResources
    • Node.StartTime
    • Node.WaitToStartCost
    • Node._asdict()
    • Node._field_defaults
    • Node._fields
    • Node._make()
    • Node._replace()
  • Resource
    • Resource.Preferred
    • Resource.Tag
    • Resource.Type
    • Resource._asdict()
    • Resource._field_defaults
    • Resource._fields
    • Resource._make()
    • Resource._replace()
  • WorkFlowGraph
    • WorkFlowGraph.add_waiting_dummies()
    • WorkFlowGraph.create_schedule_from_sila_struct()
    • WorkFlowGraph.create_sila_structure_from_jobs()

Module contents

Top-level package for pythonLab Orchestrator.