Package schrodinger :: Package infra :: Module mmjob
[hide private]
[frames] | no frames]

Module mmjob

Classes [hide private]
  SwigPyIterator
  SwigIntVector
  SwigUnsignedIntVector
  SwigStringVector
  SwigDoubleVector
  SwigUInt64Vector
  SwigIntIntPair
  SwigVectorIntIntPair
  SwigUnsignedIntVector2
  SwigDoubleVector3
  ostream
  ofstream
  istream
  ifstream
  TemporaryOFStream
A subclass of ofstream that uses the tempfile module to get a temporary filename and automatically deletes itself at garbage collection.
Functions [hide private]
 
_swig_setattr_nondynamic(self, class_type, name, value, static=1)
 
_swig_setattr(self, class_type, name, value)
 
_swig_getattr(self, class_type, name)
 
_swig_repr(self)
repr(x)
 
_swig_setattr_nondynamic_method(set)
Variables [hide private]
  _newclass = 1
  cout = <schrodinger.infra.mmjob.ostream; proxy of <Swig Object...
  cerr = <schrodinger.infra.mmjob.ostream; proxy of <Swig Object...
  mmjob_host_get_accountcodes = _mmjob.mmjob_host_get_accountcodes
  MMJOB_TRUE = 1
  MMJOB_FALSE = 0
hash(x)
  MMJOB_OK = 0
hash(x)
  MMJOB_UNINITIALIZED = 1
  MMJOB_BAD_HANDLE = 2
  MMJOB_BAD_ARGUMENT = 3
hash(x)
  MMJOB_JOBDB_MISSING = 4
  MMJOB_HOSTS_MISSING = 5
  MMJOB_INCLUDE_MISSING = 6
  MMJOB_NO_SUCH_HOST = 7
  MMJOB_FILE_NOT_FOUND = 8
  MMJOB_FILE_LOCKED = 9
  MMJOB_FILE_OPEN_ERROR = 10
  MMJOB_FILE_READ_ERROR = 11
  MMJOB_FILE_WRITE_ERROR = 12
  MMJOB_NO_SUCH_KEY = 13
  MMJOB_NOT_INTEGER = 14
  MMJOB_NOT_STRING = 15
  MMJOB_NOT_LIST = 16
  MMJOB_ILLEGAL_VALUE = 17
  MMJOB_ILLEGAL_QUERY = 18
  MMJOB_TRUNCATION = 19
  MMJOB_OUT_OF_MEMORY = 20
  MMJOB_NO_QUEUE = 21
  MMJOB_FILESIZE_MISMATCH = 22
  MMJOB_EMPTY_JOBRECORD = 23
  MMJOB_CONN_REFUSED = 24
  MMJOB_JSERVER_ERROR = 25
  MMJOB_RETRIABLE_NETWORK_ERROR = 26
  MMJOB_ERROR = 27
  MMJOB_STATUS_LAUNCHED = 1
  MMJOB_STATUS_SUBMITTED = 2
  MMJOB_STATUS_STARTED = 3
hash(x)
  MMJOB_STATUS_RUNNING = 4
  MMJOB_STATUS_PAUSED = 5
  MMJOB_STATUS_EXITED = 6
  MMJOB_STATUS_UNREACHABLE = 7
  MMJOB_STATUS_STRANDED = 8
  MMJOB_STATUS_COMPLETED = 127
  MMJOB_STATUS_INCORPORATED = 128
  MMJOB_DISPOSITION_IGNORE = 0
hash(x)
  MMJOB_DISPOSITION_APPEND = 1
  MMJOB_DISPOSITION_REPLACE = 2
  MMJOB_JOB_DISPOSITION_FIELD_SEP = ':'
  mmjob_initialize = _mmjob.mmjob_initialize
  mmjob_terminate = _mmjob.mmjob_terminate
  mmjob_refcount = _mmjob.mmjob_refcount
  mmjob_errhandler = _mmjob.mmjob_errhandler
  mmjob_new = _mmjob.mmjob_new
  mmjob_delete = _mmjob.mmjob_delete
  mmjob_in_use = _mmjob.mmjob_in_use
  mmjob_object_counts = _mmjob.mmjob_object_counts
  mmjob_get_total_reads = _mmjob.mmjob_get_total_reads
  mmjob_jobdb_path = _mmjob.mmjob_jobdb_path
  mmjob_jobrecord_path = _mmjob.mmjob_jobrecord_path
  mmjob_read_db = _mmjob.mmjob_read_db
  mmjob_read_db_noretry = _mmjob.mmjob_read_db_noretry
  mmjob_write_db = _mmjob.mmjob_write_db
  mmjob_read_index = _mmjob.mmjob_read_index
  mmjob_read_file = _mmjob.mmjob_read_file
  mmjob_write_file = _mmjob.mmjob_write_file
  mmjob_read_again_noretry = _mmjob.mmjob_read_again_noretry
  mmjob_purge = _mmjob.mmjob_purge
  mmjob_cleanup = _mmjob.mmjob_cleanup
  mmjob_jobdb_index_reload = _mmjob.mmjob_jobdb_index_reload
  mmjob_is_detached = _mmjob.mmjob_is_detached
  MMJOB_QUERY_NEW = 0
hash(x)
  MMJOB_QUERY_BROADEN = 1
  MMJOB_QUERY_NARROW = 2
  MMJOB_OP_EQUAL = 1
  MMJOB_OP_NOT_EQUAL = 2
  MMJOB_OP_CONTAINS = 3
hash(x)
  MMJOB_OP_NOT_CONTAINS = 4
  MMJOB_OP_SINCE = 5
  MMJOB_OP_BEFORE = 6
  mmjob_query = _mmjob.mmjob_query
  mmjob_select_active = _mmjob.mmjob_select_active
  mmjob_select_all = _mmjob.mmjob_select_all
  mmjob_selection_length = _mmjob.mmjob_selection_length
  mmjob_selection = _mmjob.mmjob_selection
  mmjob_is_complete = _mmjob.mmjob_is_complete
  mmjob_is_queued = _mmjob.mmjob_is_queued
  mmjob_is_secure = _mmjob.mmjob_is_secure
  mmjob_keys_length = _mmjob.mmjob_keys_length
  mmjob_keys_item = _mmjob.mmjob_keys_item
  mmjob_set_str = _mmjob.mmjob_set_str
  mmjob_set_int = _mmjob.mmjob_set_int
  mmjob_get_int = _mmjob.mmjob_get_int
  mmjob_get_job_disposition = _mmjob.mmjob_get_job_disposition
  mmjob_nonempty_value = _mmjob.mmjob_nonempty_value
  mmjob_is_list = _mmjob.mmjob_is_list
  mmjob_list_length = _mmjob.mmjob_list_length
  mmjob_list_item = _mmjob.mmjob_list_item
  mmjob_get_input_files = _mmjob.mmjob_get_input_files
  mmjob_get_output_files = _mmjob.mmjob_get_output_files
  mmjob_get_log_files = _mmjob.mmjob_get_log_files
  mmjob_get_error_count = _mmjob.mmjob_get_error_count
  mmjob_get_subjob_count = _mmjob.mmjob_get_subjob_count
  mmjob_status_string = _mmjob.mmjob_status_string
  mmjob_disposition_string = _mmjob.mmjob_disposition_string
  mmjob_hostfile_path = _mmjob.mmjob_hostfile_path
  mmjob_hosts_reload = _mmjob.mmjob_hosts_reload
  mmjob_queue_parent_dir = _mmjob.mmjob_queue_parent_dir
  mmjob_hosts_length = _mmjob.mmjob_hosts_length
  mmjob_host_name = _mmjob.mmjob_host_name
  mmjob_host_keys_length = _mmjob.mmjob_host_keys_length
  mmjob_host_is_queue = _mmjob.mmjob_host_is_queue
  mmjob_host_is_parallel = _mmjob.mmjob_host_is_parallel
  mmjob_host_keys_item = _mmjob.mmjob_host_keys_item
  mmjob_host_get_str = _mmjob.mmjob_host_get_str
  mmjob_host_get_int = _mmjob.mmjob_host_get_int
  mmjob_get_progress_percentage = _mmjob.mmjob_get_progress_perc...
  mmjob_get_progress_string = _mmjob.mmjob_get_progress_string
  mmjob_get_progress_steps = _mmjob.mmjob_get_progress_steps
  mmjob_host_is_list = _mmjob.mmjob_host_is_list
  mmjob_host_list_length = _mmjob.mmjob_host_list_length
  mmjob_host_list_item = _mmjob.mmjob_host_list_item
  mmjob_host_gpgpu_length = _mmjob.mmjob_host_gpgpu_length
  mmjob_host_gpgpu_item = _mmjob.mmjob_host_gpgpu_item
  mmjob_host_maestrocontrols = _mmjob.mmjob_host_maestrocontrols
  mmjob_host_maestrocontrols_swig = _mmjob.mmjob_host_maestrocon...
  mmjob_host_get_walltime = _mmjob.mmjob_host_get_walltime
  mmjob_host_get_memory = _mmjob.mmjob_host_get_memory
  mmjob_host_get_qargs_memory = _mmjob.mmjob_host_get_qargs_memory
  mmjob_host_get_qargs_walltime = _mmjob.mmjob_host_get_qargs_wa...
  mmjob_host_get_qargs_accountcode = _mmjob.mmjob_host_get_qargs...
  mmjob_queue_config_path = _mmjob.mmjob_queue_config_path
  mmjob_queue_jobarrays = _mmjob.mmjob_queue_jobarrays
  mmjob_print_job = _mmjob.mmjob_print_job
  mmjob_print_error = _mmjob.mmjob_print_error
  mmjob_free_string_array = _mmjob.mmjob_free_string_array
  mmjob_find_job = _mmjob.mmjob_find_job
  mmjob_get_str = _mmjob.mmjob_get_str
  mmjob_is_valid_hostname = _mmjob.mmjob_is_valid_hostname
  mmjob_read_again = _mmjob.mmjob_read_again
  mmjob_err_string = _mmjob.mmjob_err_string
  MMJOBBE_TRUE = 1
  MMJOBBE_FALSE = 0
hash(x)
  MMJOBBE_OK = 0
hash(x)
  MMJOBBE_UNINITIALIZED = 1
  MMJOBBE_NO_JMONITOR = 2
  MMJOBBE_BAD_FIFO_DIR = 3
hash(x)
  MMJOBBE_BAD_MKFIFO = 4
  MMJOBBE_BAD_RMFIFO = 5
  MMJOBBE_BAD_FIFO = 6
  MMJOBBE_BAD_READ_OPEN = 7
  MMJOBBE_BAD_WRITE_OPEN = 8
  MMJOBBE_EMPTY_MESSAGE = 9
  MMJOBBE_BAD_MESSAGE = 10
  MMJOBBE_EMPTY_FIFO = 11
  MMJOBBE_FIFO_OVERFLOW = 12
  MMJOBBE_BAD_WRITE = 13
  MMJOBBE_BAD_READ = 14
  MMJOBBE_BAD_FILENAME = 15
  MMJOBBE_BAD_LISTNAME = 16
  MMJOBBE_BAD_MSGNAME = 17
  MMJOBBE_CANT_LOCK = 18
  MMJOBBE_CANT_UNLOCK = 19
  MMJOBBE_MALLOC = 20
  MMJOBBE_NO_JOBID = 21
  MMJOBBE_EMPTY_LIST = 22
  MMJOBBE_ERROR = 23
  mmjobbe_initialize = _mmjob.mmjobbe_initialize
  mmjobbe_initialize_subprocess = _mmjob.mmjobbe_initialize_subp...
  mmjobbe_terminate = _mmjob.mmjobbe_terminate
  mmjobbe_refcount = _mmjob.mmjobbe_refcount
  mmjobbe_job_record = _mmjob.mmjobbe_job_record
  mmjobbe_job_directory = _mmjob.mmjobbe_job_directory
  mmjobbe_need_monitor_files = _mmjob.mmjobbe_need_monitor_files
  mmjobbe_need_output_files = _mmjob.mmjobbe_need_output_files
  mmjobbe_halt_requested = _mmjob.mmjobbe_halt_requested
  mmjobbe_pause_requested = _mmjob.mmjobbe_pause_requested
  mmjobbe_resume_requested = _mmjob.mmjobbe_resume_requested
  mmjobbe_path_runtime = _mmjob.mmjobbe_path_runtime
  mmjobbe_subjob_status_changed = _mmjob.mmjobbe_subjob_status_c...
  mmjobbe_copy_outputs = _mmjob.mmjobbe_copy_outputs
  mmjobbe_add_outputfile = _mmjob.mmjobbe_add_outputfile
  mmjobbe_add_required_outputfile = _mmjob.mmjobbe_add_required_...
  mmjobbe_add_monitorfile = _mmjob.mmjobbe_add_monitorfile
  mmjobbe_add_logfile = _mmjob.mmjobbe_add_logfile
  mmjobbe_set_structure_monitor_file = _mmjob.mmjobbe_set_struct...
  mmjobbe_set_structure_output_file = _mmjob.mmjobbe_set_structu...
  mmjobbe_set_structurefile = _mmjob.mmjobbe_set_structurefile
  mmjobbe_copy_outputfile = _mmjob.mmjobbe_copy_outputfile
  mmjobbe_syncdb = _mmjob.mmjobbe_syncdb
  mmjobbe_set_jobprogress = _mmjob.mmjobbe_set_jobprogress
  mmjobbe_send_parent = _mmjob.mmjobbe_send_parent
  mmjobbe_send_subjob = _mmjob.mmjobbe_send_subjob
  mmjobbe_send_subjobs = _mmjob.mmjobbe_send_subjobs
  mmjobbe_send_message = _mmjob.mmjobbe_send_message
  mmjobbe_add_message_name = _mmjob.mmjobbe_add_message_name
  mmjobbe_next_message = _mmjob.mmjobbe_next_message
  MMJOBBE_STATUS_ACTIVE = 0
hash(x)
  MMJOBBE_STATUS_NO_JMONITOR = 1
  MMJOBBE_STATUS_NO_FIFO = 2
  mmjobbe_jmonitor_fifo_path = _mmjob.mmjobbe_jmonitor_fifo_path
  mmjobbe_backend_fifo_path = _mmjob.mmjobbe_backend_fifo_path
  mmjobbe_has_jobcontrol = _mmjob.mmjobbe_has_jobcontrol
  mmjobbe_jobid = _mmjob.mmjobbe_jobid
  mmjobbe_taskid = _mmjob.mmjobbe_taskid
  mmjobbe_jobpid = _mmjob.mmjobbe_jobpid
  mmjobbe_print_state = _mmjob.mmjobbe_print_state
  mmjobbe_print_error = _mmjob.mmjobbe_print_error
  mmjobbe_set_in_unittest = _mmjob.mmjobbe_set_in_unittest
  mmjobbe_err_string = _mmjob.mmjobbe_err_string
  MMJOBFE_TRUE = 1
  MMJOBFE_FALSE = 0
hash(x)
  MMJOBFE_OK = 0
hash(x)
  MMJOBFE_UNINITIALIZED = 1
  MMJOBFE_BAD_HANDLE = 2
  MMJOBFE_OUT_OF_MEMORY = 3
hash(x)
  MMJOBFE_JOBDB_MISSING = 4
  MMJOBFE_JOBID_MISSING = 5
  MMJOBFE_FILE_NOT_FOUND = 6
  MMJOBFE_FILE_OPEN_ERROR = 7
  MMJOBFE_FILE_READ_ERROR = 8
  MMJOBFE_NO_SUCH_KEY = 9
  MMJOBFE_NOT_INTEGER = 10
  MMJOBFE_NOT_STRING = 11
  MMJOBFE_NOT_LIST = 12
  MMJOBFE_ILLEGAL_VALUE = 13
  MMJOBFE_FILE_LOCKED = 14
  MMJOBFE_BAD_FILENAME = 15
  MMJOBFE_BAD_LISTNAME = 16
  MMJOBFE_BAD_ARGUMENT = 17
  MMJOBFE_NO_CONNECTION = 18
  MMJOBFE_EMPTY_MESSAGE = 19
  MMJOBFE_BAD_MESSAGE = 20
  MMJOBFE_SEND_FAILURE = 21
  MMJOBFE_READ_FAILURE = 22
  MMJOBFE_SOCKET_CLOSED = 23
  MMJOBFE_TRUNCATION = 24
  MMJOBFE_NO_LAUNCH = 25
  MMJOBFE_SYS_SIGNAL = 26
  MMJOBFE_SYS_IPADDR = 27
  MMJOBFE_SYS_SOCKET = 28
  MMJOBFE_SYS_CONNECT = 29
  MMJOBFE_DEAF_BACKEND = 30
  MMJOBFE_MMJOB_ERROR = 31
  MMJOBFE_ERROR = 127
  mmjobfe_initialize = mmjob.mmjobfe_initialize
  mmjobfe_terminate = _mmjob.mmjobfe_terminate
  mmjobfe_refcount = _mmjob.mmjobfe_refcount
  mmjobfe_launch_job = _mmjob.mmjobfe_launch_job
  mmjobfe_new = _mmjob.mmjobfe_new
  mmjobfe_new_noretry = _mmjob.mmjobfe_new_noretry
  mmjobfe_refresh = _mmjob.mmjobfe_refresh
  mmjobfe_refresh_noretry = _mmjob.mmjobfe_refresh_noretry
  mmjobfe_delete = _mmjob.mmjobfe_delete
  mmjobfe_in_use = _mmjob.mmjobfe_in_use
  mmjobfe_object_counts = _mmjob.mmjobfe_object_counts
  mmjobfe_connection_open = _mmjob.mmjobfe_connection_open
  mmjobfe_connection_close = _mmjob.mmjobfe_connection_close
  mmjobfe_ping_job = _mmjob.mmjobfe_ping_job
  mmjobfe_halt = _mmjob.mmjobfe_halt
  mmjobfe_halt_no_output = _mmjob.mmjobfe_halt_no_output
  mmjobfe_halt_gracefully = _mmjob.mmjobfe_halt_gracefully
  mmjobfe_pause = _mmjob.mmjobfe_pause
  mmjobfe_pause_gracefully = _mmjob.mmjobfe_pause_gracefully
  mmjobfe_resume = _mmjob.mmjobfe_resume
  mmjobfe_resume_gracefully = _mmjob.mmjobfe_resume_gracefully
  mmjobfe_update_output = _mmjob.mmjobfe_update_output
  mmjobfe_send_message = _mmjob.mmjobfe_send_message
  mmjobfe_is_complete = _mmjob.mmjobfe_is_complete
  mmjobfe_is_queued = _mmjob.mmjobfe_is_queued
  mmjobfe_keys_length = _mmjob.mmjobfe_keys_length
  mmjobfe_keys_item = _mmjob.mmjobfe_keys_item
  mmjobfe_get_str = _mmjob.mmjobfe_get_str
  mmjobfe_get_int = _mmjob.mmjobfe_get_int
  mmjobfe_get_job_disposition = _mmjob.mmjobfe_get_job_disposition
  mmjobfe_get_progress_percentage = _mmjob.mmjobfe_get_progress_...
  mmjobfe_get_progress_steps = _mmjob.mmjobfe_get_progress_steps
  mmjobfe_get_progress_string = _mmjob.mmjobfe_get_progress_string
  mmjobfe_set_status_incorporated = _mmjob.mmjobfe_set_status_in...
  mmjobfe_set_project = _mmjob.mmjobfe_set_project
  mmjobfe_is_list = _mmjob.mmjobfe_is_list
  mmjobfe_list_length = _mmjob.mmjobfe_list_length
  mmjobfe_list_item = _mmjob.mmjobfe_list_item
  mmjobfe_get_input_files = _mmjob.mmjobfe_get_input_files
  mmjobfe_get_output_files = _mmjob.mmjobfe_get_output_files
  mmjobfe_get_log_files = _mmjob.mmjobfe_get_log_files
  mmjobfe_file_changed = _mmjob.mmjobfe_file_changed
  mmjobfe_open_outputfile = _mmjob.mmjobfe_open_outputfile
  mmjobfe_set_readlock = _mmjob.mmjobfe_set_readlock
  mmjobfe_release_readlock = _mmjob.mmjobfe_release_readlock
  mmjobfe_print_job = _mmjob.mmjobfe_print_job
  mmjobfe_print_error = _mmjob.mmjobfe_print_error
  mmjobfe_err_string = _mmjob.mmjobfe_err_string
  mmjob_get_jobserver_err_handler = _mmjob.mmjob_get_jobserver_e...
  Null = object()
  _failure_dict = {'mmjob_disposition_string': Null, 'mmjob_err_...
  _ignored_functions = set(['mmjob_get_list'])
  _return_code_lists = [['MMJOB_ERROR', 'MMJOB_OK', 'MMJOB_UNINI...
  return_codes = mmcheck.generate_return_code_dict(globals(), _r...
  __package__ = 'schrodinger.infra'
Variables Details [hide private]

cout

Value:
<schrodinger.infra.mmjob.ostream; proxy of <Swig Object of type 'std::\
ostream *' at 0x7f5962731690> >

cerr

Value:
<schrodinger.infra.mmjob.ostream; proxy of <Swig Object of type 'std::\
ostream *' at 0x7f59627316f0> >

mmjob_get_progress_percentage

Value:
_mmjob.mmjob_get_progress_percentage

mmjob_host_maestrocontrols_swig

Value:
_mmjob.mmjob_host_maestrocontrols_swig

mmjob_host_get_qargs_walltime

Value:
_mmjob.mmjob_host_get_qargs_walltime

mmjob_host_get_qargs_accountcode

Value:
_mmjob.mmjob_host_get_qargs_accountcode

mmjobbe_initialize_subprocess

Value:
_mmjob.mmjobbe_initialize_subprocess

mmjobbe_subjob_status_changed

Value:
_mmjob.mmjobbe_subjob_status_changed

mmjobbe_add_required_outputfile

Value:
_mmjob.mmjobbe_add_required_outputfile

mmjobbe_set_structure_monitor_file

Value:
_mmjob.mmjobbe_set_structure_monitor_file

mmjobbe_set_structure_output_file

Value:
_mmjob.mmjobbe_set_structure_output_file

mmjobfe_get_progress_percentage

Value:
_mmjob.mmjobfe_get_progress_percentage

mmjobfe_set_status_incorporated

Value:
_mmjob.mmjobfe_set_status_incorporated

mmjob_get_jobserver_err_handler

Value:
_mmjob.mmjob_get_jobserver_err_handler

_failure_dict

Value:
{'mmjob_disposition_string': Null, 'mmjob_err_string': Null, 'mmjob_ho\
stfile_path': Null, 'mmjob_in_use': Null, 'mmjob_is_valid_hostname': N\
ull, 'mmjob_jobdb_path': Null, 'mmjob_jobrecord_path': Null, 'mmjob_pr\
int_error': Null, 'mmjob_refcount': Null, 'mmjob_status_string': Null,\
 'mmjob_terminate': Null, 'mmjobbe_backend_fifo_path': Null, 'mmjobbe_\
has_jobcontrol': Null, 'mmjobbe_jmonitor_fifo_path': Null, 'mmjobbe_jo\
b_directory': Null, 'mmjobbe_jobid': Null, 'mmjobbe_print_error': Null\
, 'mmjobbe_print_state': Null, 'mmjobbe_refcount': Null, 'mmjobbe_term\
...

_return_code_lists

Value:
[['MMJOB_ERROR',
  'MMJOB_OK',
  'MMJOB_UNINITIALIZED',
  'MMJOB_BAD_HANDLE',
  'MMJOB_BAD_ARGUMENT',
  'MMJOB_JOBDB_MISSING',
  'MMJOB_HOSTS_MISSING',
  'MMJOB_INCLUDE_MISSING',
...

return_codes

Value:
mmcheck.generate_return_code_dict(globals(), _return_code_lists)