def METHOD_NAME(
    self,
    configuration: ExpectationConfiguration,
    metrics: dict,
    runtime_configuration: dict = None,
    execution_engine: ExecutionEngine = None,
) -> Union[ExpectationValidationResult, dict]:
    diff: Union[float, int] = configuration["kwargs"].get("diff")
    mostly: str = configuration["kwargs"].get("mostly")
    query_result = metrics.get("query.column_pair")
    query_result = [tuple(element.values()) for element in query_result]
    success = (
        sum([(abs(x[0]) == diff) for x in query_result]) / len(query_result)
    ) >= mostly
    return {
        "success": success,
        "result": {"observed_value": [x[0] for x in query_result]},
    }