datacontract_specification_lint_and_test_quickstart.py

1import asyncio
2from datacontract.data_contract import DataContract
3
4async def main():
5    # Initialize the DataContract with the path to your datacontract.yaml
6    data_contract = DataContract(data_contract_str="datacontract.yaml")
7
8    # Lint the data contract for specification compliance
9    print("Linting data contract...")
10    lint_result = data_contract.lint()
11    if lint_result.is_ok():
12        print("Linting successful!")
13    else:
14        print(f"Linting failed: {lint_result.err()}")
15
16    # Run tests against the data source defined in the contract
17    print("Testing data contract...")
18    test_result = await data_contract.test()
19    if test_result.is_ok():
20        print("Tests passed!")
21    else:
22        print(f"Tests failed: {test_result.err()}")
23
24if __name__ == "__main__":
25    asyncio.run(main())