Reassign an accel_group to guake main window and guake
        context menu and calls the load_accelerators method.
506836
def reload_accelerators(self, *args):
        
        if self.accel_group:
            self.guake.window.remove_accel_group(self.accel_group)
        self.accel_group = Gtk.AccelGroup()
        self.guake.window.add_accel_group(self.accel_group)
        self.load_accelerators()
1284383
private static void loadNativeSigarBindings(File nativeLibDir) throws Exception {
		extractFromJarToTemp(SIGAR_RESOURCE_DIR + new SigarLoader(Sigar.class).getLibraryName(), nativeLibDir);

		System.setProperty(SIGAR_PATH, nativeLibDir.getAbsolutePath());
		nativeLibDir.getAbsolutePath();
	}
656212
def run_step_group(pipeline_definition, step_group_name, context):
    """"""
    logger.debug(f"starting {step_group_name}")
    assert step_group_name

    steps = get_pipeline_steps(pipeline=pipeline_definition,
                               steps_group=step_group_name)

    run_pipeline_steps(steps=steps, context=context)

    logger.debug(f"done {step_group_name}")
1036977
function _migrateHostAppInitializers(project) {
  const hostAppPath = path.join(project.root);

  _checkBrowserInitializers(hostAppPath);
  _moveFastBootInitializers(project, hostAppPath);
}
275614
def load(cls, context_id, persistence_engine=None):
        """"""
        if not persistence_engine:
            from furious.config import get_default_persistence_engine
            persistence_engine = get_default_persistence_engine()

        if not persistence_engine:
            raise RuntimeError(
                'Specify a valid persistence_engine to load the context.')

        return persistence_engine.load_context(context_id)
1034598
public function main()
    {
        if (!$this->getName()) {
            throw new \BuildException('No autoscaling group provided!');
        }
        
        $config = [
            'AutoScalingGroupName' => $this->getName()
        ];

        if (!is_null($this->getDesired())) {
            $config['DesiredCapacity'] = $this->getDesired();
        }
        
        if (!is_null($this->getMin())) {
            $config['MinSize'] = $this->getMin();
        }
        
        if (!is_null($this->getMax())) {
            $config['MaxSize'] = $this->getMax();
        }

        $autoscaling = $this->getService();
        
        $autoscaling->updateAutoScalingGroup($config);
        
        if (!is_null($this->getDesired())) {
            while (!$this->groupIsReady()) {
                sleep(3);
                $this->log("Waiting to meet desired capacity (" . $this->getCurrent() . " on " . $this->getDesired() . " available)...");
            }
        }
    }
1232346
void loadAdditionalServices(ServiceRegistry registry) {
        for (ResourceLoader loader : getResourceLoaders()) {
            for (Metadata<Service> metadata : ServiceLoader.load(Service.class, loader)) {
                Service service = metadata.getValue();
                for (Class<? extends Service> serviceInterface : Services.identifyServiceInterfaces(service.getClass(), new HashSet<>())) {
                    Services.put(registry, serviceInterface, service);
                }
            }
        }
    }
683513
def execute(thrift_call_group,host_s=nil,port_n=nil,incr=false)
      @@host = host_s if !host_s.nil?
      @@port = port_n if !port_n.nil?
      socket = Thrift::Socket.new(@@host, @@port)

      transport = Thrift::BufferedTransport.new(socket)
      transport.open

      protocol = Thrift::BinaryProtocol.new(transport)
      client = HBase::Client.new(protocol)
      
      results = []
      
      if incr
        not_incr = true
        c_row = 0
      end
      
      thrift_call_group.each do |thrift_call|
        if incr
          if not_incr
            c_row = increment_table_row_index(thrift_call[:arguments][0],thrift_call_group.length,client) 
            not_incr = false
          end
          c_row += 1
          thrift_call[:arguments][1] = c_row.to_s 
        end
        results << client.send(thrift_call[:method],*thrift_call[:arguments])
      end
      
      results.flatten
    end
1255962
def _loadlib(lib='standard'):
    """"""
    global _LIB
    if _LIB is not None:
        warnings.warn('rabit.int call was ignored because it has'\
                          ' already been initialized', level=2)
        return
    if lib == 'standard':
        _LIB = ctypes.cdll.LoadLibrary(WRAPPER_PATH % '')
    elif lib == 'mock':
        _LIB = ctypes.cdll.LoadLibrary(WRAPPER_PATH % '_mock')
    elif lib == 'mpi':
        _LIB = ctypes.cdll.LoadLibrary(WRAPPER_PATH % '_mpi')
    else:
        raise Exception('unknown rabit lib %s, can be standard, mock, mpi' % lib)
    _LIB.RabitGetRank.restype = ctypes.c_int
    _LIB.RabitGetWorldSize.restype = ctypes.c_int
    _LIB.RabitVersionNumber.restype = ctypes.c_int
289904
def converter_loader(app, entry_points=None, modules=None):
    
    if entry_points:
        for entry_point in entry_points:
            for ep in pkg_resources.iter_entry_points(entry_point):
                try:
                    app.url_map.converters[ep.name] = ep.load()
                except Exception:
                    app.logger.error(
                        'Failed to initialize entry point: {0}'.format(ep))
                    raise

    if modules:
        app.url_map.converters.update(**modules)
329028
function reload() {
        $this->client->registry->reregisterCommand($this->groupID.':'.$this->name, $this);
    }
1241773
def _ensure_initialized(cls, instance=None, gateway=None, conf=None):
        
        with SparkContext._lock:
            if not SparkContext._gateway:
                SparkContext._gateway = gateway or launch_gateway(conf)
                SparkContext._jvm = SparkContext._gateway.jvm

            if instance:
                if (SparkContext._active_spark_context and
                        SparkContext._active_spark_context != instance):
                    currentMaster = SparkContext._active_spark_context.master
                    currentAppName = SparkContext._active_spark_context.appName
                    callsite = SparkContext._active_spark_context._callsite

                    # Raise error if there is already a running Spark context
                    raise ValueError(
                        "Cannot run multiple SparkContexts at once; "
                        "existing SparkContext(app=%s, master=%s)"
                        " created by %s at %s:%s "
                        % (currentAppName, currentMaster,
                            callsite.function, callsite.file, callsite.linenum))
                else:
                    SparkContext._active_spark_context = instance
1351538
def reload(self, env=None, silent=None):  # pragma: no cover
        """"""
        self.clean()
        self.execute_loaders(env, silent)
157151
def unified_load(namespace, subclasses=None, recurse=False):
    

    if subclasses is not None:
        return ClassLoader(recurse=recurse).load(namespace, subclasses=subclasses)
    else:
        return ModuleLoader(recurse=recurse).load(namespace)
236083
def addtoreadergroup(self, groupname):
        """"""

        hresult, hcontext = SCardEstablishContext(SCARD_SCOPE_USER)
        if 0 != hresult:
            raise EstablishContextException(hresult)
        try:
            hresult = SCardIntroduceReader(hcontext, self.name, self.name)
            if 0 != hresult and SCARD_E_DUPLICATE_READER != hresult:
                raise IntroduceReaderException(hresult, self.name)
            hresult = SCardAddReaderToGroup(hcontext, self.name, groupname)
            if 0 != hresult:
                raise AddReaderToGroupException(hresult, self.name, groupname)
        finally:
            hresult = SCardReleaseContext(hcontext)
            if 0 != hresult:
                raise ReleaseContextException(hresult)
682873
def reload(self):
        """"""

        app_profile_pb = self.instance_admin_client.get_app_profile(self.name)

        # NOTE: _update_from_pb does not check that the project and
        #       app_profile ID on the response match the request.
        self._update_from_pb(app_profile_pb)
150492
protected void addAccountsGroupRules(Digester digester, String xpath) {

        String xp_group = xpath + N_GROUPS + "/" + N_GROUP;
        digester.addCallMethod(xp_group, "importGroup");
        xp_group += "/";
        digester.addCallMethod(xp_group + N_NAME, "setGroupName", 0);
        digester.addCallMethod(xp_group + N_DESCRIPTION, "setGroupDescription", 0);
        digester.addCallMethod(xp_group + N_FLAGS, "setGroupFlags", 0);
        digester.addCallMethod(xp_group + N_PARENTGROUP, "setGroupParent", 0);
    }