Did I find the right examples for you? yes no      Crawl my project      Python Jobs

All Samples(40)  |  Call(0)  |  Derive(0)  |  Import(40)

src/p/y/pyon-HEAD/pyon/public.py   pyon(Download)
__all__ += ['log']
 
from pyon.core.bootstrap import get_obj_registry, IonObject, get_sys_name, CFG
__all__ += ['get_obj_registry', 'IonObject', 'get_sys_name', 'CFG']
 

src/p/y/pyon-HEAD/pyon/container/procs.py   pyon(Download)
from pyon.agent.simple_agent import SimpleResourceAgent
from pyon.core import exception
from pyon.core.bootstrap import CFG, IonObject, get_sys_name
from pyon.core.exception import ContainerConfigError, BadRequest, NotFound
from pyon.ion.endpoint import ProcessRPCServer
        log.debug("ProcManager.spawn_process(name=%s, module.cls=%s.%s, config=%s) as pid=%s", name, module, cls, config, process_id)
 
        process_cfg = deepcopy(CFG)
        if config:
            # Use provided config. Must be dict or DotDict

src/p/y/pyon-HEAD/pyon/core/governance/governance_controller.py   pyon(Download)
import types
 
from pyon.core.bootstrap import CFG, get_service_registry, is_testing
from pyon.core.governance.governance_dispatcher import GovernanceDispatcher
from pyon.util.log import log

src/p/y/pyon-HEAD/pyon/datastore/datastore_admin.py   pyon(Download)
    def __init__(self, config=None, sysname=None):
        if not config:
            from pyon.core.bootstrap import CFG
            config = CFG
        self.config = config

src/p/y/pyon-HEAD/pyon/core/interfaces/service_object_generator.py   pyon(Download)
from pyon.core.interfaces.interface_util import get_object_definition_from_datastore, get_service_definition_from_datastore
from pyon.ion.service import BaseService
from pyon.core.bootstrap import CFG, set_config
from pyon.util import yaml_ordered_dict; yaml_ordered_dict.apply_yaml_patch()
from pyon.ion.directory_standalone import DirectoryStandalone

src/p/y/pyon-HEAD/pyon/net/endpoint.py   pyon(Download)
 
from pyon.core import bootstrap, exception
from pyon.core.bootstrap import CFG, IonObject
from pyon.core.exception import ExceptionFactory, IonException, BadRequest
from pyon.net.channel import ChannelClosedError, PublisherChannel, ListenChannel, SubscriberChannel, ServerChannel, BidirClientChannel

src/p/y/pyon-HEAD/pyon/container/cc.py   pyon(Download)
from pyon.container import ContainerCapability
from pyon.core import bootstrap
from pyon.core.bootstrap import CFG
from pyon.core.exception import ContainerError, BadRequest
from pyon.datastore.datastore import DataStore
        self.container = self  # Make self appear as process to service clients
        self.CCAP = CCAP
        self.CFG = CFG
 
        log.debug("Container (sysname=%s) initializing ..." % bootstrap.get_sys_name())
    def __init__(self, container):
        ContainerCapability.__init__(self, container)
        self.container.file_system = FileSystem(CFG)
 

src/p/y/pyon-HEAD/pyon/util/queueblame_plugin.py   pyon(Download)
        from pyon.ion.exchange import ExchangeManager
        from pyon.util.containers import DotDict
        from pyon.core.bootstrap import CFG
        from mock import Mock
 

src/p/y/pyon-HEAD/pyon/ion/exchange.py   pyon(Download)
 
from pyon.core import bootstrap
from pyon.core.bootstrap import CFG, get_service_registry
from pyon.net import messaging
from pyon.net.transport import NameTrio, TransportError, ComposableTransport

src/p/y/pyon-HEAD/pyon/datastore/datastore.py   pyon(Download)
__license__ = 'Apache 2.0'
 
from pyon.core.bootstrap import get_sys_name, CFG
from pyon.datastore.datastore_common import DatastoreFactory, DataStore
from pyon.util.log import log
    def get_datastore_instance(cls, ds_name, profile=None):
        profile = profile or DataStore.DS_PROFILE_MAPPING.get(ds_name, DataStore.DS_PROFILE.BASIC)
        new_ds = DatastoreFactory.get_datastore(datastore_name=ds_name, profile=profile, scope=get_sys_name(),
                                                config=CFG, variant=DatastoreFactory.DS_FULL)
 

  1 | 2 | 3 | 4  Next