src/translation/dags/validation_dag.py [130:146]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
def get_additional_validation_flags(
    validation_entity_type,
    validation_entity_name,
    validation_flags_list,
    validation_params_from_gcs,
):
    additonal_validation_flags = ""
    if validation_entity_type == ValidationEntity.Table:
        validation_entity_name = validation_entity_name.split("=")[0]
    validation_params = validation_params_from_gcs[validation_entity_name]
    for flag, flag_value in validation_params.items():
        if flag in validation_flags_list:
            if flag not in boolean_validation_flags and flag_value != "":
                additonal_validation_flags += f" --{flag} {flag_value}"
            elif flag in boolean_validation_flags and flag_value == "Y":
                additonal_validation_flags += f" --{flag}"
    return additonal_validation_flags
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



src/translation/dvt/main.py [130:146]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
def get_additional_validation_flags(
    validation_entity_type,
    validation_entity_name,
    validation_flags_list,
    validation_params_from_gcs,
):
    additonal_validation_flags = ""
    if validation_entity_type == ValidationEntity.Table:
        validation_entity_name = validation_entity_name.split("=")[0]
    validation_params = validation_params_from_gcs[validation_entity_name]
    for flag, flag_value in validation_params.items():
        if flag in validation_flags_list:
            if flag not in boolean_validation_flags and flag_value != "":
                additonal_validation_flags += f" --{flag} {flag_value}"
            elif flag in boolean_validation_flags and flag_value == "Y":
                additonal_validation_flags += f" --{flag}"
    return additonal_validation_flags
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -