async def query_capacity_to_miners(self, available_uids):
        capacity_query_tasks = []

        bt.logging.info(f"querying capacity to uid = {available_uids.keys()}")
        # Query all images concurrently
        for uid in available_uids:
            syn = Bandwidth()
            task = self.dendrite.call(self.metagraph.axons[uid], syn,
                                      timeout=self.timeout)
            capacity_query_tasks.append(task)

        # Query responses is (uid. syn)
        query_responses: List[Bandwidth] = await asyncio.gather(*capacity_query_tasks, return_exceptions=True)
        uid_to_capacity = {}
        for uid, resp in zip(available_uids, query_responses):
            if isinstance(resp, Exception):
                bt.logging.error(f"exception happens while querying capacity to miner {uid}, {resp}")
            else:
                uid_to_capacity[uid] = resp.bandwidth_rpm
        self.uid_to_capacity = deepcopy(uid_to_capacity) # assigned here, but is useless
        return uid_to_capacity

    async def initialize_uids_and_capacities(self):
        self.available_uid_to_axons = await self.get_available_uids()
        self.uids_to_query = list(self.available_uid_to_axons.keys())
        bt.logging.info(f"Available UIDs: {list(self.available_uid_to_axons.keys())}")
        self.uid_to_capacity = await self.get_capacities_for_uids(self.available_uid_to_axons) # here is final value