Index

_

__AMS_FILE__ (C macro) __AMS_LINE__ (C macro) __call__() built-in function, [1], [2], [3], [4], [5], [6], [7], [8], [9], [10], [11], [12] __contains__() built-in function __enter__() built-in function, [1], [2], [3], [4] __exit__() built-in function, [1], [2], [3], [4] __getitem__() built-in function, [1] __init__() built-in function, [1], [2], [3], [4], [5], [6], [7], [8], [9], [10], [11], [12], [13], [14], [15], [16], [17], [18], [19], [20], [21], [22], [23], [24], [25], [26], [27], [28], [29], [30], [31], [32], [33], [34], [35], [36], [37], [38], [39] __len__() built-in function __repr__() built-in function, [1], [2] __setitem__() built-in function, [1] __str__() built-in function, [1], [2], [3] __subclasshook__() built-in function, [1] _active_domains _ams_id _ams_log (ams_jobs.AMSJob attribute) _ams_log_dir (ams_jobs.AMSJob attribute) _ams_log_prefix (ams_jobs.AMSJob attribute) _ams_object _ams_object_fn _application_name (store.AMSDataStore attribute) (wf_manager.AMSWorkflowManager attribute) _cacert _candidate_data (orchestrator.DomainSpec attribute) _cert _channel, [1] _cli_args (ams_jobs.AMSJob attribute) _cli_kwargs (ams_jobs.AMSJob attribute) _closing _connected (rmq.AMSSyncProducer attribute) _connection _connection_parameters _consumer_tag _consumers _consuming _copy _count (monitor.AMSMonitor attribute) _create_future() built-in function, [1] _data_cb() built-in function _data_files _data_queue _db_dir (wf_manager.AMSWorkflowManager attribute) _decode() built-in function _domain, [1], [2], [3] _domain_jobs (wf_manager.AMSWorkflowManager attribute) _domain_name (stage.DataBlob attribute) _domain_names _domains, [1] (orchestrator.RequestProcessor attribute) (orchestrator.TrainJobScheduler attribute) _engine (store.AMSDataStore attribute) _entry, [1], [2], [3] _environ (ams_jobs.AMSJob attribute) _executable (ams_jobs.AMSJob attribute) _execute_tasks() built-in function _executors _fake_flux (orchestrator.TrainJobScheduler attribute) _fd _field _flux_job_id _flux_uri (orchestrator.TrainJobScheduler attribute) _fn (views.AMSHDF5VirtualDBReader attribute) _from_file _generate_ams_object() built-in function _generate_ams_objects_store() built-in function _get_jobid() built-in function _get_uri() built-in function _global_lock _gracefull_shutdown

_host, [1] _hvds _i_shape (views.AMSHDF5VirtualDBReader.DataDescr attribute), [1] _i_type (views.AMSHDF5VirtualDBReader.DataDescr attribute), [1] _in_queue (orchestrator.DomainSpec attribute) _inputs (stage.DataBlob attribute) _invoke_flux_callback() built-in function _is_mpi (ams_jobs.AMSJob attribute) _link_pipeline() built-in function _lock (monitor.AMSMonitor attribute) (orchestrator.DomainSpec attribute) _manager (monitor.AMSMonitor attribute) _map_name_to_index() built-in function _md, [1], [2] _model_update_cb() built-in function _model_update_queue _name (ams_jobs.AMSJob attribute) (AMSStore.StoreCommand attribute) (orchestrator.DomainSpec attribute) _next_thread, [1] _num_confirmed_messages (rmq.AMSSyncProducer attribute) _num_sent_messages (rmq.AMSSyncProducer attribute) _o_queue, [1], [2] _o_shape (views.AMSHDF5VirtualDBReader.DataDescr attribute), [1] _o_type (views.AMSHDF5VirtualDBReader.DataDescr attribute), [1] _on_close_cb _on_message_cb _outputs (stage.DataBlob attribute) _pack_dsets_to_list() built-in function _parallel_execute() built-in function _parse_data() built-in function _parse_header() built-in function _parse_tensor() built-in function _passwd _password _path _pattern _port, [1] _prefetch_count _publish_queue (rmq.AMSSyncProducer attribute) _purge _queue, [1] _queues _reserved_keys (monitor.AMSMonitor attribute) _resources (ams_jobs.AMSJob attribute) _rmq_config (wf_manager.AMSWorkflowManager attribute) _seq_execute() built-in function _session (store.AMSDataStore attribute) _set_event() built-in function _set_jobid() built-in function _set_uri() built-in function _signal_pid _src _src_type _stage_jobs (wf_manager.AMSWorkflowManager attribute) _state (orchestrator.DomainSpec attribute) _stats (monitor.AMSMonitor attribute) _stderr (ams_jobs.AMSJob attribute) _stdout (ams_jobs.AMSJob attribute) _store _store_dataset() built-in function _sub_select_job_spec (orchestrator.DomainSpec attribute) _sub_select_jobs (wf_manager.AMSWorkflowManager attribute) _tasks _track_uri _train_job_spec (orchestrator.DomainSpec attribute) _train_jobs (wf_manager.AMSWorkflowManager attribute) _trained_data (orchestrator.DomainSpec attribute) _ts_format (monitor.AMSMonitor attribute) _url (AMSStore.StoreCommand attribute) (store.AMSDataStore attribute) (wf_manager.AMSWorkflowManager attribute) _user, [1] _version, [1], [2] _versions _vhost, [1] _writer

A

accumulate (monitor.AMSMonitor attribute) acknowledge_message() built-in function add_cli_args() built-in function, [1], [2], [3] add_done_callback() built-in function add_event_callback() built-in function add_jobid_callback() built-in function add_on_cancel_callback() built-in function add_on_channel_close_callback() built-in function add_uri_callback() built-in function add_user_action() built-in function ams::Action (C++ class) ams::Action::name (C++ function) ams::Action::run (C++ function) ams::Action::~Action (C++ function) ams::AMSAllocator (C++ struct) ams::AMSAllocator::allocate (C++ function) ams::AMSAllocator::AMSAllocator (C++ function) ams::AMSAllocator::deallocate (C++ function) ams::AMSAllocator::getName (C++ function) ams::AMSAllocator::name (C++ member) ams::AMSAllocator::~AMSAllocator (C++ function) ams::AMSCAbstrModel (C++ type) ams::AMSCExecute (C++ function) ams::AMSConfigureFSDatabase (C++ function) ams::AMSCreateExecutor (C++ function) ams::AMSDBType (C++ enum) ams::AMSDBType::AMS_HDF5 (C++ enumerator) ams::AMSDBType::AMS_NONE (C++ enumerator) ams::AMSDBType::AMS_RMQ (C++ enumerator) ams::AMSDefaultDeviceAllocator (C++ struct) ams::AMSDefaultDeviceAllocator::allocate (C++ function) ams::AMSDefaultDeviceAllocator::AMSDefaultDeviceAllocator (C++ function) ams::AMSDefaultDeviceAllocator::deallocate (C++ function) ams::AMSDefaultDeviceAllocator::~AMSDefaultDeviceAllocator (C++ function) ams::AMSDefaultHostAllocator (C++ struct) ams::AMSDefaultHostAllocator::allocate (C++ function) ams::AMSDefaultHostAllocator::AMSDefaultHostAllocator (C++ function) ams::AMSDefaultHostAllocator::deallocate (C++ function) ams::AMSDefaultHostAllocator::~AMSDefaultHostAllocator (C++ function) ams::AMSDefaultPinnedAllocator (C++ struct) ams::AMSDefaultPinnedAllocator::allocate (C++ function) ams::AMSDefaultPinnedAllocator::AMSDefaultPinnedAllocator (C++ function) ams::AMSDefaultPinnedAllocator::deallocate (C++ function) ams::AMSDefaultPinnedAllocator::~AMSDefaultPinnedAllocator (C++ function) ams::AMSDestroyExecutor (C++ function) ams::AMSDType (C++ enum) ams::AMSDType::AMS_DOUBLE (C++ enumerator) ams::AMSDType::AMS_INT32 (C++ enumerator) ams::AMSDType::AMS_INT64 (C++ enumerator) ams::AMSDType::AMS_SINGLE (C++ enumerator) ams::AMSDType::AMS_UNKNOWN_TYPE (C++ enumerator) ams::AMSError (C++ class) ams::AMSError::AMSError (C++ function), [1], [2] ams::AMSError::getFile (C++ function) ams::AMSError::getLine (C++ function) ams::AMSError::getMessage (C++ function) ams::AMSError::getType (C++ function) ams::AMSError::operator= (C++ function), [1] ams::AMSErrorType (C++ enum) ams::AMSErrorType::FileDoesNotExist (C++ enumerator) ams::AMSErrorType::Generic (C++ enumerator) ams::AMSErrorType::InvalidModel (C++ enumerator) ams::AMSErrorType::InvalidShapes (C++ enumerator) ams::AMSErrorType::Success (C++ enumerator) ams::AMSErrorType::TorchInternal (C++ enumerator) ams::AMSExecPolicy (C++ enum) ams::AMSExecPolicy::AMS_BALANCED (C++ enumerator) ams::AMSExecPolicy::AMS_UBALANCED (C++ enumerator) ams::AMSExecute (C++ function) ams::AMSExecutor (C++ type) ams::AMSExpected (C++ type) ams::AMSFinalize (C++ function) ams::AMSGetAllocatorName (C++ function) ams::AMSGetDatabaseName (C++ function) ams::AMSInit (C++ function) ams::AMSQueryModel (C++ function) ams::AMSRegisterAbstractModel (C++ function) ams::AMSResourceType (C++ enum) ams::AMSResourceType::AMS_DEVICE (C++ enumerator) ams::AMSResourceType::AMS_HOST (C++ enumerator) ams::AMSResourceType::AMS_PINNED (C++ enumerator) ams::AMSResourceType::AMS_RSEND (C++ enumerator) ams::AMSResourceType::AMS_UNKNOWN (C++ enumerator) ams::AMSSetAllocator (C++ function) ams::AMSStatus (C++ type) ams::AMSTensor (C++ class) ams::AMSTensor::AMSTensor (C++ function), [1] ams::AMSTensor::contiguous (C++ function) ams::AMSTensor::create (C++ function) ams::AMSTensor::data (C++ function) ams::AMSTensor::dType (C++ function) ams::AMSTensor::element_size (C++ function) ams::AMSTensor::elements (C++ function) ams::AMSTensor::IntDimType (C++ type) ams::AMSTensor::location (C++ function) ams::AMSTensor::operator= (C++ function), [1] ams::AMSTensor::raw_data (C++ function) ams::AMSTensor::shape (C++ function) ams::AMSTensor::strides (C++ function) ams::AMSTensor::transpose (C++ function) ams::AMSTensor::view (C++ function), [1] ams::AMSTensor::~AMSTensor (C++ function) ams::AMSWorkflow (C++ class) ams::AMSWorkflow::AMSWorkflow (C++ function) ams::AMSWorkflow::evaluate (C++ function) ams::AMSWorkflow::getDBFilename (C++ function) ams::AMSWorkflow::getDBName (C++ function) ams::AMSWorkflow::MLDomainToApplication (C++ function) ams::AMSWorkflow::ScatterPhysicOutputsToOrigDomain (C++ function) ams::AMSWorkflow::set_exec_policy (C++ function) ams::AMSWorkflow::should_load_balance (C++ function) ams::AMSWorkflow::subSelectTensors (C++ function) ams::AMSWorkflow::~AMSWorkflow (C++ function) ams::ArrayRef (C++ class) ams::ArrayRef::ArrayRef (C++ function), [1], [2], [3], [4], [5], [6], [7], [8], [9], [10], [11] ams::ArrayRef::back (C++ function) ams::ArrayRef::begin (C++ function) ams::ArrayRef::const_iterator (C++ type) ams::ArrayRef::const_pointer (C++ type) ams::ArrayRef::const_reference (C++ type) ams::ArrayRef::const_reverse_iterator (C++ type) ams::ArrayRef::copy (C++ function) ams::ArrayRef::data (C++ function) ams::ArrayRef::difference_type (C++ type) ams::ArrayRef::drop_back (C++ function) ams::ArrayRef::drop_front (C++ function) ams::ArrayRef::drop_until (C++ function) ams::ArrayRef::drop_while (C++ function) ams::ArrayRef::empty (C++ function) ams::ArrayRef::end (C++ function) ams::ArrayRef::equals (C++ function) ams::ArrayRef::front (C++ function) ams::ArrayRef::iterator (C++ type) ams::ArrayRef::operator std::vector<T> (C++ function) ams::ArrayRef::operator= (C++ function), [1] ams::ArrayRef::operator[] (C++ function) ams::ArrayRef::pointer (C++ type) ams::ArrayRef::rbegin (C++ function) ams::ArrayRef::reference (C++ type) ams::ArrayRef::rend (C++ function) ams::ArrayRef::reverse_iterator (C++ type) ams::ArrayRef::size (C++ function) ams::ArrayRef::size_type (C++ type) ams::ArrayRef::slice (C++ function), [1] ams::ArrayRef::take_back (C++ function) ams::ArrayRef::take_front (C++ function) ams::ArrayRef::take_until (C++ function) ams::ArrayRef::take_while (C++ function) ams::ArrayRef::value_type (C++ type) ams::ArrayRef::vec (C++ function) ams::CalculateSmallVectorDefaultInlinedElements (C++ struct) ams::CalculateSmallVectorDefaultInlinedElements::kPreferredSmallVectorSizeof (C++ member) ams::CalculateSmallVectorDefaultInlinedElements::NumElementsThatFit (C++ member) ams::CalculateSmallVectorDefaultInlinedElements::PreferredInlineBytes (C++ member) ams::CalculateSmallVectorDefaultInlinedElements::value (C++ member) ams::capacity_in_bytes (C++ function) ams::db::BaseDB (C++ class) ams::db::BaseDB::allowModelUpdate (C++ function) ams::db::BaseDB::BaseDB (C++ function), [1], [2] ams::db::BaseDB::close (C++ function) ams::db::BaseDB::dbType (C++ function) ams::db::BaseDB::getFilename (C++ function) ams::db::BaseDB::getId (C++ function) ams::db::BaseDB::getLatestModel (C++ function) ams::db::BaseDB::operator= (C++ function) ams::db::BaseDB::store (C++ function) ams::db::BaseDB::type (C++ function) ams::db::BaseDB::updateModel (C++ function) ams::db::BaseDB::~BaseDB (C++ function) ams::db::DBManager (C++ class) ams::db::DBManager::clean (C++ function) ams::db::DBManager::createDB (C++ function) ams::db::DBManager::DBManager (C++ function), [1] ams::db::DBManager::dropDB (C++ function) ams::db::DBManager::fs_interface (C++ member) ams::db::DBManager::getDB (C++ function) ams::db::DBManager::getInstance (C++ function) ams::db::DBManager::getNumInstances (C++ function) ams::db::DBManager::instantiate_fs_db (C++ function) ams::db::DBManager::instantiate_rmq_db (C++ function) ams::db::DBManager::isInitialized (C++ function) ams::db::DBManager::operator= (C++ function), [1] ams::db::DBManager::rmq_interface (C++ member) ams::db::DBManager::~DBManager (C++ function) ams::db::FileDB (C++ class) ams::db::FileDB::checkError (C++ function) ams::db::FileDB::FileDB (C++ function) ams::db::FileDB::fn (C++ member) ams::db::FileDB::fp (C++ member) ams::db::FileDB::getFilename (C++ function) ams::db::FilesystemInterface (C++ class) ams::db::FilesystemInterface::connect (C++ function) ams::db::FilesystemInterface::FilesystemInterface (C++ function) ams::db::FilesystemInterface::isConnected (C++ function) ams::db::FilesystemInterface::path (C++ function) ams::db::getDBType (C++ function) ams::db::getDBTypeAsStr (C++ function) ams::db::RMQInterface (C++ class) ams::db::RMQInterface::close (C++ function) ams::db::RMQInterface::connect (C++ function) ams::db::RMQInterface::isConnected (C++ function) ams::db::RMQInterface::RMQInterface (C++ function) ams::detectRank (C++ function) ams::DomainCFn (C++ type) ams::DomainLambda (C++ type) ams::EnableIfConvertibleToInputIterator (C++ type) ams::EvalContext (C++ struct) ams::EvalContext::EvalContext (C++ function), [1] ams::EvalContext::FallbackIndices (C++ member) ams::EvalContext::Inouts (C++ member) ams::EvalContext::Inputs (C++ member) ams::EvalContext::Layout (C++ member) ams::EvalContext::Model (C++ member) ams::EvalContext::ModelInput (C++ member) ams::EvalContext::ModelOutput (C++ member) ams::EvalContext::Outputs (C++ member) ams::EvalContext::Threshold (C++ member) ams::EvalContext::Uncertainties (C++ member) ams::IndexMap (C++ struct) ams::IndexMap::FieldInfo (C++ struct), [1] ams::IndexMap::FieldInfo::Cols (C++ member), [1] ams::IndexMap::FieldInfo::EKind (C++ member), [1] ams::IndexMap::FieldInfo::Kind (C++ enum), [1] ams::IndexMap::FieldInfo::Kind::InOut (C++ enumerator), [1] ams::IndexMap::FieldInfo::Kind::Input (C++ enumerator), [1] ams::IndexMap::FieldInfo::Kind::Output (C++ enumerator), [1] ams::IndexMap::FieldInfo::Name (C++ member), [1] ams::IndexMap::FieldInfo::Offset (C++ member), [1] ams::IndexMap::Fields (C++ member) ams::internal::_get_allocator (C++ function) ams::internal::_raw_copy (C++ function) ams::internal::_release_allocator (C++ function) ams::iterator_range (C++ class) ams::LayoutTransform (C++ class) ams::LayoutTransform::name (C++ function) ams::LayoutTransform::pack (C++ function) ams::LayoutTransform::unpack (C++ function) ams::LayoutTransform::~LayoutTransform (C++ function) ams::LogConfig (C++ struct) ams::LogConfig::ShowHostname (C++ member) ams::LogConfig::ShowPid (C++ member) ams::LogConfig::ShowRank (C++ member) ams::LogConfig::UseColor (C++ member) ams::Logger (C++ class) ams::Logger::flush (C++ function) ams::Logger::fromString (C++ function) ams::Logger::get (C++ function) ams::Logger::getLevel (C++ function) ams::Logger::isEnabled (C++ function) ams::Logger::log (C++ function) ams::Logger::setConfig (C++ function) ams::Logger::setLevel (C++ function) ams::Logger::setOutputFile (C++ function) ams::Logger::setOutputStderr (C++ function) ams::Logger::setOutputStdout (C++ function) ams::Logger::toString (C++ function) ams::LogLevel (C++ enum) ams::LogLevel::Debug (C++ enumerator) ams::LogLevel::Error (C++ enumerator) ams::LogLevel::Info (C++ enumerator) ams::LogLevel::NumLevels (C++ enumerator) ams::LogLevel::Unknown (C++ enumerator) ams::LogLevel::Warning (C++ enumerator) ams::MakeError (C++ function) ams::ml::AbstractModel (C++ class) ams::ml::AbstractModel::AbstractModel (C++ function), [1] ams::ml::AbstractModel::getName (C++ function) ams::ml::AbstractModel::getPath (C++ function) ams::ml::AbstractModel::getVersion (C++ function) ams::ml::AbstractModel::info (C++ function) ams::ml::AbstractModel::Json (C++ type) ams::ml::AbstractModel::Path (C++ type) ams::ml::BaseModel (C++ class) ams::ml::BaseModel::BaseModel (C++ function), [1], [2] ams::ml::BaseModel::convertTo (C++ function) ams::ml::BaseModel::dependent_false (C++ struct) ams::ml::BaseModel::DeviceType (C++ type) ams::ml::BaseModel::DType (C++ type) ams::ml::BaseModel::getDevice (C++ function) ams::ml::BaseModel::getDType (C++ function) ams::ml::BaseModel::getJITModel (C++ function), [1] ams::ml::BaseModel::HashT (C++ type) ams::ml::BaseModel::isDevice (C++ function) ams::ml::BaseModel::isType (C++ function) ams::ml::BaseModel::load (C++ function) ams::ml::BaseModel::operator= (C++ function), [1]

ams::ml::BaseModel::setDevice (C++ function) ams::ml::BaseModel::setDType (C++ function) ams::ml::InferenceModel (C++ class) ams::ml::InferenceModel::BaseModel (C++ function), [1], [2] ams::ml::InferenceModel::InferenceModel (C++ function), [1] ams::ml::InferenceModel::isTraining (C++ function) ams::ml::InferenceModel::load (C++ function) ams::ml::InferenceModel::operator() (C++ function), [1], [2] ams::ml::InferenceModel::operator= (C++ function), [1] ams::ml::parseName (C++ function) ams::ml::parsePath (C++ function) ams::MutableArrayRef (C++ class) ams::MutableArrayRef::back (C++ function) ams::MutableArrayRef::begin (C++ function) ams::MutableArrayRef::const_iterator (C++ type) ams::MutableArrayRef::const_pointer (C++ type) ams::MutableArrayRef::const_reference (C++ type) ams::MutableArrayRef::const_reverse_iterator (C++ type) ams::MutableArrayRef::data (C++ function) ams::MutableArrayRef::difference_type (C++ type) ams::MutableArrayRef::drop_back (C++ function) ams::MutableArrayRef::drop_front (C++ function) ams::MutableArrayRef::drop_until (C++ function) ams::MutableArrayRef::drop_while (C++ function) ams::MutableArrayRef::end (C++ function) ams::MutableArrayRef::front (C++ function) ams::MutableArrayRef::iterator (C++ type) ams::MutableArrayRef::MutableArrayRef (C++ function), [1], [2], [3], [4], [5], [6], [7] ams::MutableArrayRef::operator[] (C++ function) ams::MutableArrayRef::pointer (C++ type) ams::MutableArrayRef::rbegin (C++ function) ams::MutableArrayRef::reference (C++ type) ams::MutableArrayRef::rend (C++ function) ams::MutableArrayRef::reverse_iterator (C++ type) ams::MutableArrayRef::size_type (C++ type) ams::MutableArrayRef::slice (C++ function), [1] ams::MutableArrayRef::take_back (C++ function) ams::MutableArrayRef::take_front (C++ function) ams::MutableArrayRef::take_until (C++ function) ams::MutableArrayRef::take_while (C++ function) ams::MutableArrayRef::value_type (C++ type) ams::operator!= (C++ function), [1] ams::operator<< (C++ function), [1] ams::operator== (C++ function), [1] ams::OwningArrayRef (C++ class) ams::OwningArrayRef::operator= (C++ function) ams::OwningArrayRef::OwningArrayRef (C++ function), [1], [2], [3] ams::OwningArrayRef::~OwningArrayRef (C++ function) ams::Pipeline (C++ class) ams::Pipeline::ActionPtr (C++ type) ams::Pipeline::add (C++ function) ams::Pipeline::clear (C++ function) ams::Pipeline::empty (C++ function) ams::Pipeline::Pipeline (C++ function) ams::Pipeline::run (C++ function) ams::Pipeline::size (C++ function) ams::PointwiseConcatTransform (C++ class) ams::PointwiseConcatTransform::name (C++ function) ams::PointwiseConcatTransform::pack (C++ function) ams::PointwiseConcatTransform::unpack (C++ function) ams::Policy (C++ class) ams::Policy::makePipeline (C++ function) ams::Policy::name (C++ function) ams::Policy::~Policy (C++ function) ams::ResourceManager (C++ class) ams::ResourceManager::dev (C++ member) ams::ResourceManager::getAllocatorName (C++ function) ams::ResourceManager::getInstance (C++ function) ams::ResourceManager::operator= (C++ function), [1] ams::ResourceManager::ResourceManager (C++ function), [1] ams::ResourceManager::~ResourceManager (C++ function) ams::roundUp (C++ function) ams::SmallVector (C++ class) ams::SmallVector::operator= (C++ function), [1], [2], [3] ams::SmallVector::SmallVector (C++ function), [1], [2], [3], [4], [5], [6], [7], [8], [9] ams::SmallVector::~SmallVector (C++ function) ams::SmallVectorAlignmentAndSize (C++ struct) ams::SmallVectorAlignmentAndSize::Base (C++ member) ams::SmallVectorAlignmentAndSize::FirstEl (C++ member) ams::SmallVectorBase (C++ class) ams::SmallVectorBase::BeginX (C++ member) ams::SmallVectorBase::capacity (C++ function) ams::SmallVectorBase::Capacity (C++ member) ams::SmallVectorBase::empty (C++ function) ams::SmallVectorBase::grow_pod (C++ function) ams::SmallVectorBase::mallocForGrow (C++ function) ams::SmallVectorBase::replaceAllocation (C++ function) ams::SmallVectorBase::set_allocation_range (C++ function) ams::SmallVectorBase::set_size (C++ function) ams::SmallVectorBase::size (C++ function) ams::SmallVectorBase::Size (C++ member) ams::SmallVectorBase::SizeTypeMax (C++ function) ams::SmallVectorBase::SmallVectorBase (C++ function), [1] ams::SmallVectorImpl (C++ class) ams::SmallVectorImpl::append (C++ function), [1], [2], [3] ams::SmallVectorImpl::assign (C++ function), [1], [2], [3] ams::SmallVectorImpl::assignRemote (C++ function) ams::SmallVectorImpl::clear (C++ function) ams::SmallVectorImpl::const_iterator (C++ type) ams::SmallVectorImpl::emplace_back (C++ function) ams::SmallVectorImpl::erase (C++ function), [1] ams::SmallVectorImpl::insert (C++ function), [1], [2], [3], [4] ams::SmallVectorImpl::iterator (C++ type) ams::SmallVectorImpl::operator!= (C++ function) ams::SmallVectorImpl::operator< (C++ function) ams::SmallVectorImpl::operator<= (C++ function) ams::SmallVectorImpl::operator= (C++ function), [1] ams::SmallVectorImpl::operator== (C++ function) ams::SmallVectorImpl::operator> (C++ function) ams::SmallVectorImpl::operator>= (C++ function) ams::SmallVectorImpl::pop_back_n (C++ function) ams::SmallVectorImpl::pop_back_val (C++ function) ams::SmallVectorImpl::reference (C++ type) ams::SmallVectorImpl::reserve (C++ function) ams::SmallVectorImpl::resize (C++ function), [1] ams::SmallVectorImpl::resize_for_overwrite (C++ function) ams::SmallVectorImpl::size_type (C++ type) ams::SmallVectorImpl::SmallVectorImpl (C++ function), [1] ams::SmallVectorImpl::swap (C++ function) ams::SmallVectorImpl::truncate (C++ function) ams::SmallVectorImpl::ValueParamT (C++ type) ams::SmallVectorImpl::~SmallVectorImpl (C++ function) ams::SmallVectorStorage (C++ struct) ams::SmallVectorStorage::InlineElts (C++ member) ams::SmallVectorStorage<T, 0> (C++ struct) ams::SmallVectorTemplateBase (C++ class) ams::SmallVectorTemplateBase::destroy_range (C++ function) ams::SmallVectorTemplateBase::forward_value_param (C++ function), [1] ams::SmallVectorTemplateBase::grow (C++ function) ams::SmallVectorTemplateBase::growAndAssign (C++ function) ams::SmallVectorTemplateBase::growAndEmplaceBack (C++ function) ams::SmallVectorTemplateBase::mallocForGrow (C++ function) ams::SmallVectorTemplateBase::moveElementsForGrow (C++ function) ams::SmallVectorTemplateBase::pop_back (C++ function) ams::SmallVectorTemplateBase::push_back (C++ function), [1] ams::SmallVectorTemplateBase::reserveForParamAndGetAddress (C++ function), [1] ams::SmallVectorTemplateBase::SmallVectorTemplateBase (C++ function) ams::SmallVectorTemplateBase::takeAllocationForGrow (C++ function) ams::SmallVectorTemplateBase::TakesParamByValue (C++ member) ams::SmallVectorTemplateBase::uninitialized_copy (C++ function) ams::SmallVectorTemplateBase::uninitialized_move (C++ function) ams::SmallVectorTemplateBase::ValueParamT (C++ type) ams::SmallVectorTemplateBase<T, true> (C++ class) ams::SmallVectorTemplateBase<T, true>::destroy_range (C++ function) ams::SmallVectorTemplateBase<T, true>::forward_value_param (C++ function) ams::SmallVectorTemplateBase<T, true>::grow (C++ function) ams::SmallVectorTemplateBase<T, true>::growAndAssign (C++ function) ams::SmallVectorTemplateBase<T, true>::growAndEmplaceBack (C++ function) ams::SmallVectorTemplateBase<T, true>::pop_back (C++ function) ams::SmallVectorTemplateBase<T, true>::push_back (C++ function) ams::SmallVectorTemplateBase<T, true>::reserveForParamAndGetAddress (C++ function), [1] ams::SmallVectorTemplateBase<T, true>::SmallVectorTemplateBase (C++ function) ams::SmallVectorTemplateBase<T, true>::TakesParamByValue (C++ member) ams::SmallVectorTemplateBase<T, true>::uninitialized_copy (C++ function), [1] ams::SmallVectorTemplateBase<T, true>::uninitialized_move (C++ function) ams::SmallVectorTemplateBase<T, true>::ValueParamT (C++ type) ams::SmallVectorTemplateCommon (C++ class) ams::SmallVectorTemplateCommon::assertSafeToAdd (C++ function) ams::SmallVectorTemplateCommon::assertSafeToAddRange (C++ function), [1] ams::SmallVectorTemplateCommon::assertSafeToReferenceAfterClear (C++ function), [1] ams::SmallVectorTemplateCommon::assertSafeToReferenceAfterResize (C++ function) ams::SmallVectorTemplateCommon::back (C++ function), [1] ams::SmallVectorTemplateCommon::begin (C++ function), [1] ams::SmallVectorTemplateCommon::capacity_in_bytes (C++ function) ams::SmallVectorTemplateCommon::const_iterator (C++ type) ams::SmallVectorTemplateCommon::const_pointer (C++ type) ams::SmallVectorTemplateCommon::const_reference (C++ type) ams::SmallVectorTemplateCommon::const_reverse_iterator (C++ type) ams::SmallVectorTemplateCommon::data (C++ function), [1] ams::SmallVectorTemplateCommon::difference_type (C++ type) ams::SmallVectorTemplateCommon::end (C++ function), [1] ams::SmallVectorTemplateCommon::front (C++ function), [1] ams::SmallVectorTemplateCommon::getFirstEl (C++ function) ams::SmallVectorTemplateCommon::grow_pod (C++ function) ams::SmallVectorTemplateCommon::isRangeInStorage (C++ function) ams::SmallVectorTemplateCommon::isReferenceToRange (C++ function) ams::SmallVectorTemplateCommon::isReferenceToStorage (C++ function) ams::SmallVectorTemplateCommon::isSafeToReferenceAfterResize (C++ function) ams::SmallVectorTemplateCommon::isSmall (C++ function) ams::SmallVectorTemplateCommon::iterator (C++ type) ams::SmallVectorTemplateCommon::max_size (C++ function) ams::SmallVectorTemplateCommon::operator[] (C++ function), [1] ams::SmallVectorTemplateCommon::pointer (C++ type) ams::SmallVectorTemplateCommon::rbegin (C++ function), [1] ams::SmallVectorTemplateCommon::reference (C++ type) ams::SmallVectorTemplateCommon::rend (C++ function), [1] ams::SmallVectorTemplateCommon::reserveForParamAndGetAddressImpl (C++ function) ams::SmallVectorTemplateCommon::resetToSmall (C++ function) ams::SmallVectorTemplateCommon::reverse_iterator (C++ type) ams::SmallVectorTemplateCommon::size_in_bytes (C++ function) ams::SmallVectorTemplateCommon::size_type (C++ type) ams::SmallVectorTemplateCommon::SmallVectorTemplateCommon (C++ function) ams::SmallVectorTemplateCommon::value_type (C++ type) ams::style_for (C++ function) ams::tensor::maskTensor (C++ function) ams::TensorBundle (C++ struct) ams::TensorBundle::add (C++ function) ams::TensorBundle::at (C++ function), [1] ams::TensorBundle::begin (C++ function), [1] ams::TensorBundle::clear (C++ function) ams::TensorBundle::contains (C++ function) ams::TensorBundle::empty (C++ function) ams::TensorBundle::end (C++ function), [1] ams::TensorBundle::find (C++ function), [1] ams::TensorBundle::Item (C++ struct), [1] ams::TensorBundle::Item::Item (C++ function), [1] ams::TensorBundle::Item::name (C++ member), [1] ams::TensorBundle::Item::tensor (C++ member), [1] ams::TensorBundle::items (C++ member) ams::TensorBundle::operator= (C++ function), [1] ams::TensorBundle::operator[] (C++ function), [1] ams::TensorBundle::size (C++ function) ams::TensorBundle::TensorBundle (C++ function), [1], [2] ams::ValueTypeFromRangeType (C++ type) AMS_CDEBUG (C macro) AMS_CFATAL (C macro) AMS_CINFO (C macro) AMS_CWARNING (C macro) AMS_DBG (C macro) AMS_FATAL (C macro) ams_flux._WorkItem (built-in class) ams_flux._WorkItem.__init__() built-in function ams_flux._WorkItem.run() built-in function ams_id() built-in function, [1] AMS_INFO (C macro) ams_jobs.AMSJob (built-in class) ams_jobs.AMSJob.__init__() built-in function ams_jobs.AMSJob.__str__() built-in function ams_jobs.AMSJob.environ() built-in function, [1] ams_jobs.AMSJob.executable() built-in function, [1] ams_jobs.AMSJob.from_dict() built-in function ams_jobs.AMSJob.generate_cli_command() built-in function ams_jobs.AMSJob.name() built-in function, [1] ams_jobs.AMSJob.precede_deploy() built-in function ams_jobs.AMSJob.resources() built-in function, [1] ams_jobs.AMSJob.stderr() built-in function, [1] ams_jobs.AMSJob.stdout() built-in function, [1] ams_jobs.AMSJob.to_dict() built-in function ams_jobs.AMSJob.to_flux_jobspec() built-in function ams_jobs.AMSJobResources (built-in class) ams_jobs.AMSJobResources.to_dict() built-in function ams_jobs.get_echo_job() built-in function ams_jobs.nested_instance_job_descr() built-in function AMS_MAKE_ERROR (C macro) AMS_MAKE_ERROR_OBJ (C macro) AMS_WARNING (C macro) AMSBroker.main() built-in function AMSDBStage.main() built-in function amsDebug (C++ function) AMSDeploy.get_partition_uri() built-in function AMSDeploy.main() built-in function AMSDeploy.verify_arg() built-in function AMSOrchestrator.main() built-in function AMSPRINT (C macro) AMSStore.main() built-in function AMSStore.StoreCommand (built-in class) AMSStore.StoreCommand.__init__() built-in function AMSStore.StoreCommand.add_cli_options() built-in function AMSStore.StoreCommand.from_cli() built-in function AMSTrain.main() built-in function append() built-in function application_name, [1], [2], [3] array_context (monitor.AMSMonitor attribute) array_names (monitor.AMSMonitor attribute)

B

Base (store attribute) BATCH_SIZE (stage attribute) blob (stage.QueueMessage attribute) body broadcast() built-in function built-in function __call__(), [1], [2], [3], [4], [5], [6], [7], [8], [9], [10], [11], [12] __contains__() __enter__(), [1], [2], [3], [4] __exit__(), [1], [2], [3], [4] __getitem__(), [1] __init__(), [1], [2], [3], [4], [5], [6], [7], [8], [9], [10], [11], [12], [13], [14], [15], [16], [17], [18], [19], [20], [21], [22], [23], [24], [25], [26], [27], [28], [29], [30], [31], [32], [33], [34], [35], [36], [37], [38], [39] __len__() __repr__(), [1], [2] __setitem__(), [1] __str__(), [1], [2], [3] __subclasshook__(), [1] _create_future(), [1] _data_cb() _decode() _execute_tasks() _generate_ams_object() _generate_ams_objects_store() _get_jobid() _get_uri() _invoke_flux_callback() _link_pipeline() _map_name_to_index() _model_update_cb() _pack_dsets_to_list() _parallel_execute() _parse_data() _parse_header() _parse_tensor() _seq_execute() _set_event() _set_jobid() _set_uri() _store_dataset() acknowledge_message() add_cli_args(), [1], [2], [3] add_done_callback() add_event_callback() add_jobid_callback() add_on_cancel_callback() add_on_channel_close_callback() add_uri_callback() add_user_action() ams_flux._WorkItem.__init__() ams_flux._WorkItem.run() ams_id(), [1] ams_jobs.AMSJob.__init__() ams_jobs.AMSJob.__str__() ams_jobs.AMSJob.environ(), [1] ams_jobs.AMSJob.executable(), [1] ams_jobs.AMSJob.from_dict() ams_jobs.AMSJob.generate_cli_command() ams_jobs.AMSJob.name(), [1] ams_jobs.AMSJob.precede_deploy() ams_jobs.AMSJob.resources(), [1] ams_jobs.AMSJob.stderr(), [1] ams_jobs.AMSJob.stdout(), [1] ams_jobs.AMSJob.to_dict() ams_jobs.AMSJob.to_flux_jobspec() ams_jobs.AMSJobResources.to_dict() ams_jobs.get_echo_job() ams_jobs.nested_instance_job_descr() AMSBroker.main() AMSDBStage.main() AMSDeploy.get_partition_uri() AMSDeploy.main() AMSDeploy.verify_arg() AMSOrchestrator.main() AMSStore.main() AMSStore.StoreCommand.__init__() AMSStore.StoreCommand.add_cli_options() AMSStore.StoreCommand.from_cli() AMSTrain.main() append() broadcast() callback_close() callback_message(), [1], [2], [3] cancel() close(), [1], [2], [3], [4], [5], [6] close_channel() close_connection() connect() connection_params() data_cb() db_dir(), [1] decode() describe_inputs() describe_outputs() domain(), [1] domain_names(), [1] domains() encode() endianness() exception() execute() faccessors.get_reader() faccessors.get_writer() faccessors.main() flux_executor() flux_job_id(), [1] from_cli(), [1], [2], [3] from_descr(), [1], [2] get(), [1] get_data() get_domain_descr() get_domains() get_file_format_suffix(), [1], [2], [3] get_files() get_input_data() get_load_task(), [1], [2] get_model_update_task(), [1], [2] get_o_queue(), [1] get_output_data() get_q_type() getMessageCount() header_format() init_signals() input_feature_dims() input_feature_names() input_feature_types() items() jobid() keys() load(), [1], [2] monitor.AMSMonitor.__call__() monitor.AMSMonitor.__enter__() monitor.AMSMonitor.__exit__() monitor.AMSMonitor.__init__() monitor.AMSMonitor.__repr__() monitor.AMSMonitor.__str__() monitor.AMSMonitor._acc() monitor.AMSMonitor._filter() monitor.AMSMonitor._filter_out_object() monitor.AMSMonitor._get_ts() monitor.AMSMonitor._remove_reserved_keys() monitor.AMSMonitor._update_db() monitor.AMSMonitor.convert_ts() monitor.AMSMonitor.format_ts() monitor.AMSMonitor.info() monitor.AMSMonitor.json() monitor.AMSMonitor.lock() monitor.AMSMonitor.reset() monitor.AMSMonitor.start_monitor() monitor.AMSMonitor.stats() monitor.AMSMonitor.stop_monitor() monitor.AMSMonitor.unlock() on_basic_qos_ok() on_cancelok() on_channel_closed() on_channel_open(), [1] on_close_cb() on_connection_closed() on_connection_open() on_connection_open_error() on_consumer_cancelled() on_exchange_declared() on_message() on_message_cb() on_queue_bound() on_queue_declared() on_queue_declareok() open(), [1], [2], [3], [4], [5], [6] open_channel() orchestrator.AMSFakeRMQUpdate.__call__() orchestrator.AMSFakeRMQUpdate.__init__() orchestrator.DomainSpec.__init__() orchestrator.DomainSpec.cancelled_sub_select() orchestrator.DomainSpec.cancelled_train() orchestrator.DomainSpec.candidate_data(), [1] orchestrator.DomainSpec.done_sub_select() orchestrator.DomainSpec.done_sub_select_cb() orchestrator.DomainSpec.done_train() orchestrator.DomainSpec.done_train_cb() orchestrator.DomainSpec.estimated_effort() orchestrator.DomainSpec.fully_described() orchestrator.DomainSpec.in_queue(), [1] orchestrator.DomainSpec.name(), [1] orchestrator.DomainSpec.running() orchestrator.DomainSpec.start_sub_select() orchestrator.DomainSpec.start_train() orchestrator.DomainSpec.state(), [1] orchestrator.DomainSpec.sub_select_job_spec(), [1] orchestrator.DomainSpec.TrackJobStats.__init__(), [1] orchestrator.DomainSpec.TrackJobStats.cancel(), [1] orchestrator.DomainSpec.TrackJobStats.done(), [1] orchestrator.DomainSpec.TrackJobStats.start(), [1] orchestrator.DomainSpec.train_job_spec(), [1] orchestrator.DomainSpec.trained_data(), [1] orchestrator.RequestProcessor.__call__() orchestrator.RequestProcessor.__init__() orchestrator.RequestProcessor.new_candidates() orchestrator.RequestProcessor.process_request() orchestrator.RequestProcessor.register_job_spec() orchestrator.RMQStatusUpdate.__call__() orchestrator.RMQStatusUpdate.__init__() orchestrator.run() orchestrator.StatusPrinter.__call__() orchestrator.StatusPrinter.__init__() orchestrator.thread_safe_call() orchestrator.TrainJobScheduler.__call__() orchestrator.TrainJobScheduler.__init__() orchestrator.TrainJobScheduler._flux_run() orchestrator.TrainJobScheduler._local_run() orchestrator.TrainJobScheduler._run() orchestrator.TrainJobScheduler._schedule() output_feature_dims() output_feature_names() output_feature_types() precede_deploy() process_request(), [1] reconnect() release_signals() requires_model_update(), [1], [2] resources_from_domain_job() result() rmq.AMSChannel.__enter__() rmq.AMSChannel.__exit__() rmq.AMSChannel.__init__() rmq.AMSChannel.close() rmq.AMSChannel.default_callback() rmq.AMSChannel.get_messages() rmq.AMSChannel.open() rmq.AMSChannel.purge() rmq.AMSChannel.receive() rmq.AMSChannel.send() rmq.AMSRMQConfiguration.__post_init__() rmq.AMSRMQConfiguration.from_json() rmq.AMSRMQConfiguration.to_dict() rmq.AMSSyncProducer.__enter__() rmq.AMSSyncProducer.__exit__() rmq.AMSSyncProducer.__init__() rmq.AMSSyncProducer.close() rmq.AMSSyncProducer.open() rmq.AMSSyncProducer.send_message() rmq.BlockingClient.__enter__() rmq.BlockingClient.__exit__() rmq.BlockingClient.__init__() rmq.BlockingClient.connect() rmq.default_ams_callback() run() set_exception() set_qos() setup_queue() shutdown(), [1], [2] shutdown_event() signal_wrapper(), [1] stage.DataBlob.__init__() stage.DataBlob.domain_name() stage.DataBlob.inputs() stage.DataBlob.outputs() stage.get_pipeline() stage.QueueMessage.__init__() stage.QueueMessage.data() stage.QueueMessage.is_delete() stage.QueueMessage.is_new_model() stage.QueueMessage.is_process() stage.QueueMessage.is_terminate() start_consuming() stop(), [1] stop_consuming() store(), [1], [2] store.AMSDataStore.__enter__() store.AMSDataStore.__exit__() store.AMSDataStore.__init__() store.AMSDataStore.__str__() store.AMSDataStore._add_entries() store.AMSDataStore._get_entry_versions() store.AMSDataStore._remove_entries() store.AMSDataStore._suggest_entry_file_name() store.AMSDataStore.add_candidates() store.AMSDataStore.add_data() store.AMSDataStore.add_model() store.AMSDataStore.close() store.AMSDataStore.find() store.AMSDataStore.get_candidate_files() store.AMSDataStore.get_candidate_versions() store.AMSDataStore.get_data_files() store.AMSDataStore.get_data_versions() store.AMSDataStore.get_files() store.AMSDataStore.get_model_files() store.AMSDataStore.get_model_versions() store.AMSDataStore.is_open() store.AMSDataStore.move() store.AMSDataStore.open() store.AMSDataStore.remove_candidates() store.AMSDataStore.remove_data() store.AMSDataStore.remove_models() store.AMSDataStore.search() store.AMSDataStore.suggest_candidate_file_name() store.AMSDataStore.suggest_data_file_name() store.AMSDataStore.suggest_model_file_name() store.create_store_directories() store_types.AMSModelDescr.__post_init__() store_types.AMSModelDescr.to_dict() submit(), [1] update_model_cb() uri() util.get_unique_fn() util.mkdir() versions(), [1] views.AMSHDF5VirtualDBReader.__del__() views.AMSHDF5VirtualDBReader.__init__() views.AMSHDF5VirtualDBReader.create_vds_layout() views.AMSHDF5VirtualDBReader.DataDescr.__init__(), [1] views.AMSHDF5VirtualDBReader.DataDescr.i_shape(), [1] views.AMSHDF5VirtualDBReader.DataDescr.i_type(), [1] views.AMSHDF5VirtualDBReader.DataDescr.o_shape(), [1] views.AMSHDF5VirtualDBReader.DataDescr.o_type(), [1] views.AMSHDF5VirtualDBReader.destroy() views.AMSHDF5VirtualDBReader.fn() views.AMSHDF5VirtualDBReader.verify_dsets() wf_manager.AMSWorkflowManager.__init__() wf_manager.AMSWorkflowManager.__str__() wf_manager.AMSWorkflowManager.broadcast_train_specs() wf_manager.AMSWorkflowManager.domain_done_cb() wf_manager.AMSWorkflowManager.domain_jobid_cb() wf_manager.AMSWorkflowManager.from_descr() wf_manager.AMSWorkflowManager.rmq_config() wf_manager.AMSWorkflowManager.stager_done_cb() wf_manager.AMSWorkflowManager.start() wf_manager.AMSWorkflowManager.start_domain() wf_manager.AMSWorkflowManager.start_stagers() wf_manager.Partition.from_uri()

C

CALIPER (C macro) callAMS (C++ function) callApplication (C++ function), [1] callback (rmq.AMSChannel attribute) (rmq.BlockingClient attribute) callback_close() built-in function callback_message() built-in function, [1], [2], [3] cancel() built-in function candidates cert, [1] (rmq.AMSSyncProducer attribute) (rmq.BlockingClient attribute) channel (rmq.AMSChannel attribute) (rmq.AMSSyncProducer attribute) close() built-in function, [1], [2], [3], [4], [5], [6]

close_channel() built-in function close_connection() built-in function connect() built-in function connection (rmq.AMSChannel attribute) (rmq.AMSSyncProducer attribute) (rmq.BlockingClient attribute) connection_parameters (rmq.AMSSyncProducer attribute) connection_params (rmq.BlockingClient attribute) connection_params() built-in function context (rmq.BlockingClient attribute) cores_per_node (wf_manager.Partition attribute) cores_per_task (ams_jobs.AMSJobResources attribute) credentials (rmq.BlockingClient attribute)

D

data data_cb() built-in function data_writer_cls datasets datasize_byte, [1], [2], [3] db_dir db_dir() built-in function, [1] db_type db_url, [1], [2] decode() built-in function Delete DeltaUQ

describe_inputs() built-in function describe_outputs() built-in function dest_dir, [1] domain() built-in function, [1] domain_name domain_name_size domain_names, [1] domain_names() built-in function, [1] domains() built-in function dtype_byte dtype_to_size (C++ function)

E

enable_if_t (C++ type) encode() built-in function endianness() built-in function entry_mime_types (store.AMSDataStore attribute) entry_suffix (store.AMSDataStore attribute) entry_type

environ (ams_jobs.AMSJob attribute) EVENTS exception() built-in function exclusive (ams_jobs.AMSJobResources attribute) executable (ams_jobs.AMSJob attribute) execute() built-in function

F

faccessors.get_reader() built-in function faccessors.get_writer() built-in function faccessors.main() built-in function Faiss fd, [1], [2] file_name, [1], [2] filename flux_executor() built-in function

flux_job_id() built-in function, [1] fmt::formatter<ams::AMSResourceType> (C++ struct) fmt::formatter<ams::AMSResourceType>::format (C++ function) fmt::formatter<std::filesystem::path> (C++ struct) fmt::formatter<std::filesystem::path>::format (C++ function) format_ts (monitor.AMSMonitor attribute) from_cli() built-in function, [1], [2], [3] from_descr() built-in function, [1], [2] future (ams_flux._WorkItem attribute)

G

get() built-in function, [1] get_data() built-in function get_domain_descr() built-in function get_domains() built-in function get_file_format_suffix() built-in function, [1], [2], [3] get_files() built-in function get_input_data() built-in function get_load_task() built-in function, [1], [2]

get_model_update_task() built-in function, [1], [2] get_o_queue() built-in function, [1] get_output_data() built-in function get_q_type() built-in function getMessageCount() built-in function GETNAME (C macro) GETNAME2 (C macro) gpus_per_node (wf_manager.Partition attribute) gpus_per_task (ams_jobs.AMSJobResources attribute)

H

header_format() built-in function

host (rmq.AMSSyncProducer attribute) (rmq.BlockingClient attribute) hsize

I

i_queue, [1], [2] (orchestrator.RequestProcessor attribute) (orchestrator.RMQStatusUpdate attribute) (orchestrator.StatusPrinter attribute) (orchestrator.TrainJobScheduler attribute) id IDLE init_signals() built-in function input_dim input_feature_dims input_feature_dims() built-in function input_feature_names

input_feature_names() built-in function input_feature_types input_feature_types() built-in function internal_ts (monitor.AMSMonitor attribute) is_real_equal (C++ function) isDouble (C++ class) isDouble::default_value (C++ function) isDouble<double> (C++ class) isDouble<double>::default_value (C++ function) isDouble<float> (C++ class) isDouble<float>::default_value (C++ function) items() built-in function

J

jobid() built-in function

jobs (wf_manager.AMSWorkflowManager attribute) json_file (orchestrator.AMSFakeRMQUpdate attribute)

K

keys() built-in function

kwargs (monitor.AMSMonitor attribute)

L

load() built-in function, [1], [2] loader

logger (monitor.AMSMonitor attribute) (rmq.AMSChannel attribute) (rmq.BlockingClient attribute)

M

max max_size_file mean memUsage (C++ function), [1] meta_dict models monitor.AMSMonitor (built-in class) monitor.AMSMonitor.__call__() built-in function monitor.AMSMonitor.__enter__() built-in function monitor.AMSMonitor.__exit__() built-in function monitor.AMSMonitor.__init__() built-in function monitor.AMSMonitor.__repr__() built-in function monitor.AMSMonitor.__str__() built-in function monitor.AMSMonitor._acc() built-in function monitor.AMSMonitor._filter() built-in function monitor.AMSMonitor._filter_out_object() built-in function monitor.AMSMonitor._get_ts() built-in function

monitor.AMSMonitor._remove_reserved_keys() built-in function monitor.AMSMonitor._update_db() built-in function monitor.AMSMonitor.convert_ts() built-in function monitor.AMSMonitor.format_ts() built-in function monitor.AMSMonitor.info() built-in function monitor.AMSMonitor.json() built-in function monitor.AMSMonitor.lock() built-in function monitor.AMSMonitor.reset() built-in function monitor.AMSMonitor.start_monitor() built-in function monitor.AMSMonitor.stats() built-in function monitor.AMSMonitor.stop_monitor() built-in function monitor.AMSMonitor.unlock() built-in function MPI_CALL (C macro) MPI_Comm (C++ type) mpi_rank msg_type (stage.QueueMessage attribute)

N

nb_requests NewModel nnodes (wf_manager.Partition attribute) nodes (ams_jobs.AMSJobResources attribute)

num_cancelled_jobs (orchestrator.DomainSpec.TrackJobStats attribute), [1] num_done_jobs (orchestrator.DomainSpec.TrackJobStats attribute), [1] num_jobs (orchestrator.DomainSpec.TrackJobStats attribute), [1] num_messages, [1]

O

o_queue, [1], [2], [3] (orchestrator.RequestProcessor attribute) (orchestrator.TrainJobScheduler attribute) object (monitor.AMSMonitor attribute) on_basic_qos_ok() built-in function on_cancelok() built-in function on_channel_closed on_channel_closed() built-in function on_channel_open() built-in function, [1] on_close_cb() built-in function on_connection_closed() built-in function on_connection_open() built-in function on_connection_open_error() built-in function on_consumer_cancelled on_consumer_cancelled() built-in function on_exchange_declared() built-in function on_message() built-in function on_message_cb() built-in function on_queue_bound() built-in function on_queue_declared() built-in function on_queue_declareok() built-in function open() built-in function, [1], [2], [3], [4], [5], [6] open_channel() built-in function orchestrator.AMSFakeRMQUpdate (built-in class) orchestrator.AMSFakeRMQUpdate.__call__() built-in function orchestrator.AMSFakeRMQUpdate.__init__() built-in function orchestrator.DomainSpec (built-in class) orchestrator.DomainSpec.__init__() built-in function orchestrator.DomainSpec.cancelled_sub_select() built-in function orchestrator.DomainSpec.cancelled_train() built-in function orchestrator.DomainSpec.candidate_data() built-in function, [1] orchestrator.DomainSpec.done_sub_select() built-in function orchestrator.DomainSpec.done_sub_select_cb() built-in function orchestrator.DomainSpec.done_train() built-in function orchestrator.DomainSpec.done_train_cb() built-in function orchestrator.DomainSpec.estimated_effort() built-in function orchestrator.DomainSpec.fully_described() built-in function orchestrator.DomainSpec.in_queue() built-in function, [1] orchestrator.DomainSpec.name() built-in function, [1] orchestrator.DomainSpec.running() built-in function

orchestrator.DomainSpec.start_sub_select() built-in function orchestrator.DomainSpec.start_train() built-in function orchestrator.DomainSpec.state() built-in function, [1] orchestrator.DomainSpec.sub_select_job_spec() built-in function, [1] orchestrator.DomainSpec.TrackJobStats (built-in class), [1] orchestrator.DomainSpec.TrackJobStats.__init__() built-in function, [1] orchestrator.DomainSpec.TrackJobStats.cancel() built-in function, [1] orchestrator.DomainSpec.TrackJobStats.done() built-in function, [1] orchestrator.DomainSpec.TrackJobStats.start() built-in function, [1] orchestrator.DomainSpec.train_job_spec() built-in function, [1] orchestrator.DomainSpec.trained_data() built-in function, [1] orchestrator.RequestProcessor (built-in class) orchestrator.RequestProcessor.__call__() built-in function orchestrator.RequestProcessor.__init__() built-in function orchestrator.RequestProcessor.new_candidates() built-in function orchestrator.RequestProcessor.process_request() built-in function orchestrator.RequestProcessor.register_job_spec() built-in function orchestrator.RMQStatusUpdate (built-in class) orchestrator.RMQStatusUpdate.__call__() built-in function orchestrator.RMQStatusUpdate.__init__() built-in function orchestrator.run() built-in function orchestrator.StatusPrinter (built-in class) orchestrator.StatusPrinter.__call__() built-in function orchestrator.StatusPrinter.__init__() built-in function orchestrator.thread_safe_call() built-in function orchestrator.TrainJobScheduler (built-in class) orchestrator.TrainJobScheduler.__call__() built-in function orchestrator.TrainJobScheduler.__init__() built-in function orchestrator.TrainJobScheduler._flux_run() built-in function orchestrator.TrainJobScheduler._local_run() built-in function orchestrator.TrainJobScheduler._run() built-in function orchestrator.TrainJobScheduler._schedule() built-in function orig_sig_handlers original_handlers out_dir output_dim output_feature_dims output_feature_dims() built-in function output_feature_names output_feature_names() built-in function output_feature_types output_feature_types() built-in function

P

password (rmq.AMSSyncProducer attribute) (rmq.BlockingClient attribute) path (store_types.AMSModelDescr attribute), [1] pattern PERFFASPECT (C macro) policy port (rmq.AMSSyncProducer attribute) (rmq.BlockingClient attribute) precede_deploy() built-in function

prefetch_count print_message Process process_request() built-in function, [1] producer (orchestrator.AMSFakeRMQUpdate attribute) (orchestrator.RMQStatusUpdate attribute) publish_queue (orchestrator.AMSFakeRMQUpdate attribute) (orchestrator.RMQStatusUpdate attribute)

Q

q_name (rmq.AMSChannel attribute)

QUEUE

R

rabbitmq_cert (rmq.AMSRMQConfiguration attribute), [1] rabbitmq_exchange_training (rmq.AMSRMQConfiguration attribute), [1] rabbitmq_key_training (rmq.AMSRMQConfiguration attribute), [1] rabbitmq_ml_status_queue (rmq.AMSRMQConfiguration attribute), [1] rabbitmq_ml_submit_queue (rmq.AMSRMQConfiguration attribute), [1] rabbitmq_password (rmq.AMSRMQConfiguration attribute), [1] rabbitmq_queue_physics (rmq.AMSRMQConfiguration attribute), [1] rabbitmq_user (rmq.AMSRMQConfiguration attribute), [1] rabbitmq_vhost (rmq.AMSRMQConfiguration attribute), [1] Random reconnect() built-in function reconnect_reason record (monitor.AMSMonitor attribute) release_signals() built-in function released requires_model_update() built-in function, [1], [2] resources_from_domain_job() built-in function result() built-in function rmq.AMSChannel (built-in class) rmq.AMSChannel.__enter__() built-in function rmq.AMSChannel.__exit__() built-in function rmq.AMSChannel.__init__() built-in function rmq.AMSChannel.close() built-in function rmq.AMSChannel.default_callback() built-in function rmq.AMSChannel.get_messages() built-in function rmq.AMSChannel.open() built-in function rmq.AMSChannel.purge() built-in function

rmq.AMSChannel.receive() built-in function rmq.AMSChannel.send() built-in function rmq.AMSRMQConfiguration (built-in class) rmq.AMSRMQConfiguration.__post_init__() built-in function rmq.AMSRMQConfiguration.from_json() built-in function rmq.AMSRMQConfiguration.to_dict() built-in function rmq.AMSSyncProducer (built-in class) rmq.AMSSyncProducer.__enter__() built-in function rmq.AMSSyncProducer.__exit__() built-in function rmq.AMSSyncProducer.__init__() built-in function rmq.AMSSyncProducer.close() built-in function rmq.AMSSyncProducer.open() built-in function rmq.AMSSyncProducer.send_message() built-in function rmq.BlockingClient (built-in class) rmq.BlockingClient.__enter__() built-in function rmq.BlockingClient.__exit__() built-in function rmq.BlockingClient.__init__() built-in function rmq.BlockingClient.connect() built-in function rmq.default_ams_callback() built-in function rmq_consumer rmq_queue run() built-in function running (orchestrator.DomainSpec.TrackJobStats attribute), [1]

S

service_host (rmq.AMSRMQConfiguration attribute), [1] service_port (rmq.AMSRMQConfiguration attribute), [1] set_exception() built-in function set_qos() built-in function setup_queue() built-in function shapeToString (C++ function) should_reconnect shutdown() built-in function, [1], [2] shutdown_event() built-in function signal_wrapper() built-in function, [1] signals, [1] spec (ams_flux._WorkItem attribute) stage.DataBlob (built-in class) stage.DataBlob.__init__() built-in function stage.DataBlob.domain_name() built-in function stage.DataBlob.inputs() built-in function stage.DataBlob.outputs() built-in function stage.get_pipeline() built-in function stage.QueueMessage (built-in class) stage.QueueMessage.__init__() built-in function stage.QueueMessage.data() built-in function stage.QueueMessage.is_delete() built-in function stage.QueueMessage.is_new_model() built-in function stage.QueueMessage.is_process() built-in function stage.QueueMessage.is_terminate() built-in function stage_dir start_consuming() built-in function start_time (monitor.AMSMonitor attribute) std::swap (C++ function), [1] stop() built-in function, [1] stop_consuming() built-in function store() built-in function, [1], [2] store.AMSDataStore (built-in class) store.AMSDataStore.__enter__() built-in function store.AMSDataStore.__exit__() built-in function store.AMSDataStore.__init__() built-in function store.AMSDataStore.__str__() built-in function store.AMSDataStore._add_entries() built-in function store.AMSDataStore._get_entry_versions() built-in function store.AMSDataStore._remove_entries() built-in function store.AMSDataStore._suggest_entry_file_name() built-in function store.AMSDataStore.add_candidates() built-in function store.AMSDataStore.add_data() built-in function

store.AMSDataStore.add_model() built-in function store.AMSDataStore.close() built-in function store.AMSDataStore.find() built-in function store.AMSDataStore.get_candidate_files() built-in function store.AMSDataStore.get_candidate_versions() built-in function store.AMSDataStore.get_data_files() built-in function store.AMSDataStore.get_data_versions() built-in function store.AMSDataStore.get_files() built-in function store.AMSDataStore.get_model_files() built-in function store.AMSDataStore.get_model_versions() built-in function store.AMSDataStore.is_open() built-in function store.AMSDataStore.move() built-in function store.AMSDataStore.open() built-in function store.AMSDataStore.remove_candidates() built-in function store.AMSDataStore.remove_data() built-in function store.AMSDataStore.remove_models() built-in function store.AMSDataStore.search() built-in function store.AMSDataStore.suggest_candidate_file_name() built-in function store.AMSDataStore.suggest_data_file_name() built-in function store.AMSDataStore.suggest_model_file_name() built-in function store.create_store_directories() built-in function store_types.AMSModelDescr (built-in class) store_types.AMSModelDescr.__post_init__() built-in function store_types.AMSModelDescr.to_dict() built-in function sub_select (orchestrator.DomainSpec attribute) submit() built-in function, [1] SUBSELECT suffix, [1], [2], [3], [4] supported_policies supported_readers supported_writers SurrogateModel (C++ class) SurrogateModel::_evaluate (C++ function) SurrogateModel::convertModelDataType (C++ function) SurrogateModel::convertModelResourceType (C++ function) SurrogateModel::evaluate (C++ function) SurrogateModel::getInstance (C++ function) SurrogateModel::getModelDataType (C++ function) SurrogateModel::getModelResourceType (C++ function) SurrogateModel::instances (C++ member) SurrogateModel::is_cpu (C++ function) SurrogateModel::is_double (C++ function) SurrogateModel::is_float (C++ function) SurrogateModel::is_gpu (C++ function) SurrogateModel::is_resource (C++ function) SurrogateModel::is_type (C++ function) SurrogateModel::SurrogateModel (C++ function) SurrogateModel::~SurrogateModel (C++ function)

T

tag (monitor.AMSMonitor attribute) tasks_per_node (ams_jobs.AMSJobResources attribute) Terminate threshold (store_types.AMSModelDescr attribute) THROW (C macro)

total_bytes_written total_filesize total_messages total_time_ns, [1] TRAINING training (orchestrator.DomainSpec attribute)

U

UNDEFINED_FUNC (C macro) untrained_sizes (orchestrator.DomainSpec.TrackJobStats attribute), [1] update_model_cb() built-in function uq_aggregate (store_types.AMSModelDescr attribute) uq_type (store_types.AMSModelDescr attribute), [1] uri (wf_manager.Partition attribute) uri() built-in function

use_arrays (monitor.AMSMonitor attribute) user (rmq.AMSSyncProducer attribute) (rmq.BlockingClient attribute) user_action user_obj util.get_unique_fn() built-in function util.mkdir() built-in function

V

valid_dbs (store.AMSDataStore attribute) valid_entries (store.AMSDataStore attribute) variables_list (monitor.AMSMonitor attribute) version versions() built-in function, [1] vhost (rmq.AMSSyncProducer attribute) (rmq.BlockingClient attribute) views.AMSHDF5VirtualDBReader (built-in class) views.AMSHDF5VirtualDBReader.__del__() built-in function views.AMSHDF5VirtualDBReader.__init__() built-in function views.AMSHDF5VirtualDBReader.create_vds_layout() built-in function views.AMSHDF5VirtualDBReader.DataDescr (built-in class), [1]

views.AMSHDF5VirtualDBReader.DataDescr.__init__() built-in function, [1] views.AMSHDF5VirtualDBReader.DataDescr.i_shape() built-in function, [1] views.AMSHDF5VirtualDBReader.DataDescr.i_type() built-in function, [1] views.AMSHDF5VirtualDBReader.DataDescr.o_shape() built-in function, [1] views.AMSHDF5VirtualDBReader.DataDescr.o_type() built-in function, [1] views.AMSHDF5VirtualDBReader.destroy() built-in function views.AMSHDF5VirtualDBReader.fn() built-in function views.AMSHDF5VirtualDBReader.verify_dsets() built-in function

W

was_consuming wf_manager.AMSWorkflowManager (built-in class) wf_manager.AMSWorkflowManager.__init__() built-in function wf_manager.AMSWorkflowManager.__str__() built-in function wf_manager.AMSWorkflowManager.broadcast_train_specs() built-in function wf_manager.AMSWorkflowManager.domain_done_cb() built-in function wf_manager.AMSWorkflowManager.domain_jobid_cb() built-in function wf_manager.AMSWorkflowManager.from_descr() built-in function

wf_manager.AMSWorkflowManager.rmq_config() built-in function wf_manager.AMSWorkflowManager.stager_done_cb() built-in function wf_manager.AMSWorkflowManager.start() built-in function wf_manager.AMSWorkflowManager.start_domain() built-in function wf_manager.AMSWorkflowManager.start_stagers() built-in function wf_manager.Partition (built-in class) wf_manager.Partition.from_uri() built-in function