async def METHOD_NAME(self, op_id):
    async with self._futures_lock:
        future = self._futures.get(op_id, None)
        if not future:
            return
        future.set_result(_EMPTY_MESSAGE)