jobflow_remote.utils package

Submodules

• jobflow_remote.utils.data module
  • check_dict_keywords()
  • convert_store()
  • convert_utc_time()
  • deep_merge_dict()
  • get_past_time_rounded()
  • get_utc_offset()
  • remove_none()
  • store_from_dict()
  • suuid()
  • uuid_to_path()
• jobflow_remote.utils.db module
  • FlowLockedError
    • FlowLockedError.from_flow_doc()
  • JobLockedError
    • JobLockedError.from_job_doc()
  • LockedDocumentError
  • MissingDocumentError
  • MongoLock
    • MongoLock.LOCK_KEY
    • MongoLock.LOCK_TIME_KEY
    • MongoLock.acquire()
    • MongoLock.delete_on_release
    • MongoLock.get_lock_id()
    • MongoLock.get_lock_time()
    • MongoLock.is_locked
    • MongoLock.release()
    • MongoLock.update_on_release
  • RunnerLockedError
    • RunnerLockedError.from_runner_doc()
  • mongo_operation()
  • mongodump_from_store()
  • mongorestore_to_store()
  • pymongo_dump()
  • pymongo_restore()
• jobflow_remote.utils.examples module
  • add()
  • add_distributed()
  • add_many()
  • add_raise()
  • conditional_sum_replace()
  • make_list()
  • sleep()
  • value()
• jobflow_remote.utils.log module
  • CLIFormatter
    • CLIFormatter.formatException()
  • initialize_cli_logger()
  • initialize_remote_run_log()
  • initialize_runner_logger()
• jobflow_remote.utils.remote module
  • SharedHosts
    • SharedHosts.close_hosts()
    • SharedHosts.get_host()
  • UnsafeDeletionError
  • safe_remove_job_files()
• jobflow_remote.utils.schedule module
  • SafeScheduler

Module contents