a-chumagin

FROM python:3.7-slim-bullseye
RUN pip install great-expectations==0.15.26
COPY ./*.py /
ENTRYPOINT ["/usr/local/bin/python", "check.py"]

a-chumagin

import great_expectations as gx
from great_expectations.data_context.types.base import DataContextConfig, FilesystemStoreBackendDefaults
import os
import logging

logging.basicConfig()
logging.getLogger('sqlalchemy.engine').setLevel(logging.INFO)


context_dir = os.path.abspath("./mysql-context")

a-chumagin

import great_expectations as gx
from great_expectations.data_context.types.base import DataContextConfig, FilesystemStoreBackendDefaults
import os
from great_expectations.core.batch import RuntimeBatchRequest
import pytest


@pytest.fixture
def create_context():
    context_dir = os.path.abspath("./tripdata")

a-chumagin

{
  "data_asset_type": null,
  "expectation_suite_name": "my_suite",
  "expectations": [
    {
      "expectation_type": "expect_column_values_to_be_between",
      "kwargs": {
        "column": {
          "$PARAMETER": "column_name"
        },

a-chumagin

from soda.scan import Scan
import os
import yaml
import argparse

def parse_arguments():
    parser = argparse.ArgumentParser()
    parser.add_argument('--path', help='Specify the tests to run')
    return parser.parse_args()

a-chumagin

CREATE OR REPLACE VIEW trino.completed_queries AS
SELECT
    SUBSTRING_INDEX(`user`, '@', 1) AS usr,
    `query`,
    JSON_UNQUOTE(JSON_EXTRACT(inputs_json, '$[0].catalogName')) AS catalog,
    JSON_UNQUOTE(JSON_EXTRACT(inputs_json, '$[0].schema')) AS `schema`,
    `query_type`,
    JSON_ARRAY(
      JSON_OBJECT(
        'catalogName', JSON_UNQUOTE(JSON_EXTRACT(inputs_json, '$[0].catalogName')),