async def METHOD_NAME(self):
    """
    function for asynchronous polling of input queues
    loops through each of the queues in watchin and checks
    if an object is present and then saves the object if found
    """
    if self.setUp is False:
        for q in self.polling:
            self.tasks.append(asyncio.create_task(q.get_async()))
        self.setUp = True
    done, pending = await asyncio.wait(
        self.tasks, return_when=concurrent.futures.FIRST_COMPLETED
    )
    for i, t in enumerate(self.tasks):
        if t in done or self.polling[i].status == "done":
            r = self.polling[i].result  # r is array with id and name of object
            actorID = self.polling[
                i
            ].getStart()  # name of actor asking watcher to save the object
            try:
                obj = self.client.getID(r[0])
                np.save("output/saved/" + actorID + r[1], obj)
            except ObjectNotFoundError as e:
                logger.info(e.message)
                pass
            self.tasks[i] = asyncio.create_task(self.polling[i].get_async())