Skip to content
This repository was archived by the owner on May 17, 2024. It is now read-only.

Commit 6b0eef1

Browse files
author
Sergey Vasilyev
committed
Normalise all imports to fully qualified names
1 parent 32d8bf0 commit 6b0eef1

70 files changed

Lines changed: 283 additions & 243 deletions

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

‎data_diff/__init__.py‎

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -2,13 +2,13 @@
22

33
from data_diff.sqeleton.abcs import DbTime, DbPath
44

5-
from .tracking import disable_tracking
6-
from .databases import connect
7-
from .diff_tables import Algorithm
8-
from .hashdiff_tables import HashDiffer, DEFAULT_BISECTION_THRESHOLD, DEFAULT_BISECTION_FACTOR
9-
from .joindiff_tables import JoinDiffer, TABLE_WRITE_LIMIT
10-
from .table_segment import TableSegment
11-
from .utils import eval_name_template, Vector
5+
from data_diff.tracking import disable_tracking
6+
from data_diff.databases import connect
7+
from data_diff.diff_tables import Algorithm
8+
from data_diff.hashdiff_tables import HashDiffer, DEFAULT_BISECTION_THRESHOLD, DEFAULT_BISECTION_FACTOR
9+
from data_diff.joindiff_tables import JoinDiffer, TABLE_WRITE_LIMIT
10+
from data_diff.table_segment import TableSegment
11+
from data_diff.utils import eval_name_template, Vector
1212

1313

1414
def connect_to_table(

‎data_diff/__main__.py‎

Lines changed: 11 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -15,17 +15,17 @@
1515
from data_diff.sqeleton.schema import create_schema
1616
from data_diff.sqeleton.queries.api import current_timestamp
1717

18-
from .dbt import dbt_diff
19-
from .utils import eval_name_template, remove_password_from_url, safezip, match_like, LogStatusHandler
20-
from .diff_tables import Algorithm
21-
from .hashdiff_tables import HashDiffer, DEFAULT_BISECTION_THRESHOLD, DEFAULT_BISECTION_FACTOR
22-
from .joindiff_tables import TABLE_WRITE_LIMIT, JoinDiffer
23-
from .table_segment import TableSegment
24-
from .databases import connect
25-
from .parse_time import parse_time_before, UNITS_STR, ParseError
26-
from .config import apply_config_from_file
27-
from .tracking import disable_tracking, set_entrypoint_name
28-
from .version import __version__
18+
from data_diff.dbt import dbt_diff
19+
from data_diff.utils import eval_name_template, remove_password_from_url, safezip, match_like, LogStatusHandler
20+
from data_diff.diff_tables import Algorithm
21+
from data_diff.hashdiff_tables import HashDiffer, DEFAULT_BISECTION_THRESHOLD, DEFAULT_BISECTION_FACTOR
22+
from data_diff.joindiff_tables import TABLE_WRITE_LIMIT, JoinDiffer
23+
from data_diff.table_segment import TableSegment
24+
from data_diff.databases import connect
25+
from data_diff.parse_time import parse_time_before, UNITS_STR, ParseError
26+
from data_diff.config import apply_config_from_file
27+
from data_diff.tracking import disable_tracking, set_entrypoint_name
28+
from data_diff.version import __version__
2929

3030

3131
COLOR_SCHEME = {

‎data_diff/cloud/__init__.py‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,2 +1,2 @@
1-
from .datafold_api import DatafoldAPI, TCloudApiDataDiff, TCloudApiOrgMeta
2-
from .data_source import get_or_create_data_source
1+
from data_diff.cloud.datafold_api import DatafoldAPI, TCloudApiDataDiff, TCloudApiOrgMeta
2+
from data_diff.cloud.data_source import get_or_create_data_source

‎data_diff/cloud/data_source.py‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -8,14 +8,14 @@
88
from rich.prompt import Confirm, Prompt, FloatPrompt, IntPrompt, InvalidResponse
99
from typing_extensions import Literal
1010

11-
from .datafold_api import (
11+
from data_diff.cloud.datafold_api import (
1212
DatafoldAPI,
1313
TCloudApiDataSourceConfigSchema,
1414
TCloudApiDataSource,
1515
TDsConfig,
1616
TestDataSourceStatus,
1717
)
18-
from ..dbt_parser import DbtParser
18+
from data_diff.dbt_parser import DbtParser
1919

2020

2121
UNKNOWN_VALUE = "unknown_value"

‎data_diff/cloud/datafold_api.py‎

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -9,8 +9,7 @@
99
from typing_extensions import Self
1010

1111
from data_diff.errors import DataDiffCloudDiffFailed, DataDiffCloudDiffTimedOut, DataDiffDatasourceIdNotFoundError
12-
13-
from ..utils import getLogger
12+
from data_diff.utils import getLogger
1413

1514
logger = getLogger(__name__)
1615

‎data_diff/databases/__init__.py‎

Lines changed: 14 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -1,17 +1,17 @@
11
from data_diff.sqeleton.databases import MD5_HEXDIGITS, CHECKSUM_HEXDIGITS, QueryError, ConnectError
22

3-
from .postgresql import PostgreSQL
4-
from .mysql import MySQL
5-
from .oracle import Oracle
6-
from .snowflake import Snowflake
7-
from .bigquery import BigQuery
8-
from .redshift import Redshift
9-
from .presto import Presto
10-
from .databricks import Databricks
11-
from .trino import Trino
12-
from .clickhouse import Clickhouse
13-
from .vertica import Vertica
14-
from .duckdb import DuckDB
15-
from .mssql import MsSql
3+
from data_diff.databases.postgresql import PostgreSQL
4+
from data_diff.databases.mysql import MySQL
5+
from data_diff.databases.oracle import Oracle
6+
from data_diff.databases.snowflake import Snowflake
7+
from data_diff.databases.bigquery import BigQuery
8+
from data_diff.databases.redshift import Redshift
9+
from data_diff.databases.presto import Presto
10+
from data_diff.databases.databricks import Databricks
11+
from data_diff.databases.trino import Trino
12+
from data_diff.databases.clickhouse import Clickhouse
13+
from data_diff.databases.vertica import Vertica
14+
from data_diff.databases.duckdb import DuckDB
15+
from data_diff.databases.mssql import MsSql
1616

17-
from ._connect import connect
17+
from data_diff.databases._connect import connect

‎data_diff/databases/_connect.py‎

Lines changed: 13 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -2,19 +2,19 @@
22

33
from data_diff.sqeleton.databases import Connect
44

5-
from .postgresql import PostgreSQL
6-
from .mysql import MySQL
7-
from .oracle import Oracle
8-
from .snowflake import Snowflake
9-
from .bigquery import BigQuery
10-
from .redshift import Redshift
11-
from .presto import Presto
12-
from .databricks import Databricks
13-
from .trino import Trino
14-
from .clickhouse import Clickhouse
15-
from .vertica import Vertica
16-
from .duckdb import DuckDB
17-
from .mssql import MsSql
5+
from data_diff.databases.postgresql import PostgreSQL
6+
from data_diff.databases.mysql import MySQL
7+
from data_diff.databases.oracle import Oracle
8+
from data_diff.databases.snowflake import Snowflake
9+
from data_diff.databases.bigquery import BigQuery
10+
from data_diff.databases.redshift import Redshift
11+
from data_diff.databases.presto import Presto
12+
from data_diff.databases.databricks import Databricks
13+
from data_diff.databases.trino import Trino
14+
from data_diff.databases.clickhouse import Clickhouse
15+
from data_diff.databases.vertica import Vertica
16+
from data_diff.databases.duckdb import DuckDB
17+
from data_diff.databases.mssql import MsSql
1818

1919

2020
DATABASE_BY_SCHEME = {

‎data_diff/databases/bigquery.py‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
from data_diff.sqeleton.databases import bigquery
2-
from .base import DatadiffDialect
2+
from data_diff.databases.base import DatadiffDialect
33

44

55
class Dialect(bigquery.Dialect, bigquery.Mixin_MD5, bigquery.Mixin_NormalizeValue, DatadiffDialect):

‎data_diff/databases/clickhouse.py‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
from data_diff.sqeleton.databases import clickhouse
2-
from .base import DatadiffDialect
2+
from data_diff.databases.base import DatadiffDialect
33

44

55
class Dialect(clickhouse.Dialect, clickhouse.Mixin_MD5, clickhouse.Mixin_NormalizeValue, DatadiffDialect):

‎data_diff/databases/databricks.py‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
from data_diff.sqeleton.databases import databricks
2-
from .base import DatadiffDialect
2+
from data_diff.databases.base import DatadiffDialect
33

44

55
class Dialect(databricks.Dialect, databricks.Mixin_MD5, databricks.Mixin_NormalizeValue, DatadiffDialect):

0 commit comments

Comments
 (0)