Look at the inventory for a given source
        
        Parameters
        ----------
        source_id: int
            The id of the source to inspect
324355
def inventory(self, source_id):
        
        if self.n_sources==0:
            print('Please run group_sources() to create the catalog first.')
        
        else:
            
            if source_id>self.n_sources or source_id<1 or not isinstance(source_id, int):
                print('Please enter an integer between 1 and',self.n_sources)
            
            else:
            
                print('Source:')
                print(at.Table.from_pandas(self.catalog[self.catalog['id']==source_id]).pprint())
                for cat_name in self.catalogs:
                    cat = getattr(self, cat_name)
                    rows = cat[cat['source_id']==source_id]
                    if not rows.empty:
                        print('\n{}:'.format(cat_name))
                        at.Table.from_pandas(rows).pprint()
15718
async def inspect(self, service_id: str) -> Mapping[str, Any]:
        

        response = await self.docker._query_json(
            "services/{service_id}".format(service_id=service_id), method="GET"
        )
        return response
480737
def inventory(self, modules_inventory=False):
        

        self.c_info = self.get_attributes()
        for m_index, m_portcounts in enumerate(self.c_info['c_portcounts'].split()):
            if int(m_portcounts):
                module = XenaModule(parent=self, index=m_index)
                if modules_inventory:
                    module.inventory()
794655
def inspect(self):
        
        policy = self.policy
        image_name = format_image_tag((self.config_id.config_name, self.config_id.instance_name))
        image_id = policy.images[self.client_name].get(image_name)
        if image_id:
            self.detail = {'Id': image_id}   # Currently there is no need for actually inspecting the image.
        else:
            self.detail = NOT_FOUND
194342
def prepare_inventory(self):
        
        if self.inventory is None:
            self.inventory  = os.path.join(self.private_data_dir, "inventory")
1156467
def getRequest(self, id_):
        
        for request in self.requests:
            if request.id == id_:
                return request

        raise LookupError("Request %r not found" % (id_,))
1375058
def get_id(self):
        
        if self._id is None:
            self._id = graceful_get(self.inspect(refresh=True), "ID")
        return self._id
797303
async def inspect(self, task_id: str) -> Mapping[str, Any]:
        

        response = await self.docker._query_json(
            "tasks/{task_id}".format(task_id=task_id), method="GET"
        )
        return response
644370
def inspect_image(self, image_id):
        
        logger.info("inspecting image '%s'", image_id)
        logger.debug("image_id = '%s'", image_id)
        if isinstance(image_id, ImageName):
            image_id = image_id.to_str()
        image_metadata = self.d.inspect_image(image_id)
        return image_metadata
770069
def get_observation(self, observation_id):
        
        search = mp.ObservationSearch(observation_id=observation_id)
        b = search_observations_sql_builder(search)
        sql = b.get_select_sql(columns='l.publicId AS obstory_id, l.name AS obstory_name, '
                                       'o.obsTime, s.name AS obsType, o.publicId, o.uid',
                               skip=0, limit=1, order='o.obsTime DESC')
        obs = list(self.generators.observation_generator(sql=sql, sql_args=b.sql_args))
        if not obs:
            return None
        return obs[0]
629462
def show(source):
    
    if is_verbose():
        logger.info('Retrieving Metadata for: %s', source)
    processed_source = get_source(source)
    metadata = _get_metadata(processed_source)
    shutil.rmtree(processed_source)
    return metadata
280949
def get_bucket_inventory(client, bucket, inventory_id):
    """"""
    inventories = client.list_bucket_inventory_configurations(
        Bucket=bucket).get('InventoryConfigurationList', [])
    inventories = {i['Id']: i for i in inventories}
    found = fnmatch.filter(inventories, inventory_id)
    if not found:
        return None

    i = inventories[found.pop()]
    s3_info = i['Destination']['S3BucketDestination']
    return {'bucket': s3_info['Bucket'].rsplit(':')[-1],
            'prefix': "%s/%s/%s" % (s3_info['Prefix'], bucket, i['Id'])}
1079308
def get_point_source_position(self, id):
        

        pts = self._point_sources.values()[id]

        return pts.position.get_ra(), pts.position.get_dec()
86844
def find(self,
             id,
             params=None,
             ):
        

        if params is None:
            params = {}

        if isinstance(id, tuple):
            path = self._resource.format(*id)
        else:
            path = self._resource.format(id)
        url = self._get_url(path)
        self._load(url, params=params)
423669
def enumerate_sources(self):
        
        sources = []
        for source_id in range(1, 17):
            try:
                name = yield from self.get_source_variable(source_id, 'name')
                if name:
                    sources.append((source_id, name))
            except CommandException:
                break
        return sources
727051
def set_source_variable(self, source_id, variable, value):
        
        source_id = int(source_id)
        return self._send_cmd("SET S[%d].%s=\"%s\"" % (
            source_id, variable, value))
431090
def wf_source_id?(source)
      if source.is_a?(String) && source.match(/^[\w\.\-]+$/) &&
         source.size < 1024
        return true
      end

      raise Wavefront::Exception::InvalidSourceId
    end