validate_staging_area.py

"""
Runs a pre-check of a staging area to identify issues that might cause the
snapshot or indexing processes to fail.
"""
import argparse
import sys

from hca.staging_area_validator import StagingAreaValidator


def _parse_args(argv):
    parser = argparse.ArgumentParser(description=__doc__)
    parser.add_argument(
        "--staging-area",
        "-s",
        required=True,
        help="The Google Cloud Storage URL of the staging area. "
        "Syntax is gs://<bucket>[/<path>].",
    )
    parser.add_argument(
        "--ignore-dangling-inputs",
        "-I",
        action="store_true",
        default=False,
        help="Ignore errors caused by metadata files not found "
        "in the staging area for input-only entities.",
    )
    parser.add_argument(
        "--no-json-validation",
        "-J",
        action="store_false",
        default=True,
        dest="validate_json",
        help="Do not validate JSON documents against their schema.",
    )
    parser.add_argument(
        "--total-retries",
        "-t",
        type=int,
        default=10,
        dest="total_retries",
        help="The number of times to retry the validation process.",
    )
    return parser.parse_args(argv)


if __name__ == "__main__":
    args = _parse_args(sys.argv[1:])
    adapter = StagingAreaValidator(
        staging_area=args.staging_area,
        ignore_dangling_inputs=args.ignore_dangling_inputs,
        validate_json=args.validate_json,
        total_retries=args.total_retries,
    )
    sys.exit(adapter.main())