src/translation/dags/validation_dag.py [223:241]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    source_conn, source_conn_string = connection_string(
        config["validation_config"]["source_config"].items()
    )
    target_conn, target_conn_string = connection_string(
        config["validation_config"]["target_config"].items()
    )

    add_conn = create_connection.format(
        source_conn_string=source_conn_string, target_conn_string=target_conn_string
    )

    validation_type = config["validation_config"]["validation_type"]

    if validation_type == "schema":
        validation_command = schema_validation.format(
            source_conn=source_conn,
            target_conn=target_conn,
            table=table,
            bq_table=table.split("=")[-1],
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



src/translation/dvt/main.py [153:171]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    source_conn, source_conn_string = connection_string(
        config["validation_config"]["source_config"].items()
    )
    target_conn, target_conn_string = connection_string(
        config["validation_config"]["target_config"].items()
    )

    add_conn = create_connection.format(
        source_conn_string=source_conn_string, target_conn_string=target_conn_string
    )

    validation_type = config["validation_config"]["validation_type"]

    if validation_type == "schema":
        validation_command = schema_validation.format(
            source_conn=source_conn,
            target_conn=target_conn,
            table=table,
            bq_table=table.split("=")[-1],
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -