async def METHOD_NAME(self, payload: dict, in_edge=None) -> Result:
    try:
        result = await self.db.fetch(self.query, timeout=self.timeout)
        result = [self.to_dict(record) for record in result]
        return Result(port="result", value={"result": result})
    except Exception as e:
        self.console.error(str(e))
        return Result(port="error", value={"payload": payload, "error": str(e)})