calypso.dispatchers package

Subpackages

• calypso.dispatchers.orchestrator package
  • Orchestrator
    • Orchestrator.are_jobs_finished()
    • Orchestrator.as_dict()
    • Orchestrator.get_results()
    • Orchestrator.get_results_done()
    • Orchestrator.graceful_monitoring()
    • Orchestrator.handle_unexpected_state()
    • Orchestrator.how_jobs_going()
    • Orchestrator.monitoring()
    • Orchestrator.orchestrate()
    • Orchestrator.pickup_from_old_submit()
    • Orchestrator.serialize()
    • Orchestrator.start()
    • Orchestrator.start_monitoring()
    • Orchestrator.stop()
    • Orchestrator.terminate_monitoring()
  • Subpackages
    • calypso.dispatchers.orchestrator.executor package
      • get_executor()
      • Submodules
    • calypso.dispatchers.orchestrator.scheduler package
      • get_scheduler()
      • Submodules
  • Submodules
    • calypso.dispatchers.orchestrator.jobs module
      • Job
      • JobStatus
    • calypso.dispatchers.orchestrator.log module
    • calypso.dispatchers.orchestrator.machine module
      • Machine
      • MachineData
    • calypso.dispatchers.orchestrator.orchestrator module
      • Orchestrator
    • calypso.dispatchers.orchestrator.toolkit module
      • JobStatusEncoder
      • ProcInfo
      • ThreadLock
      • ThreadWithException
      • TimeParser
      • hashstr()
      • lower_case_key()
      • split_list()

Submodules

• calypso.dispatchers.dispatcher module
  • Dispatcher
    • Dispatcher.get_results()
    • Dispatcher.get_results_done()
    • Dispatcher.task_done()