Skip to content

Commit

Permalink
move imports to the top
Browse files Browse the repository at this point in the history
  • Loading branch information
ion-elgreco committed Nov 11, 2023
1 parent 3765721 commit 8e076eb
Showing 1 changed file with 6 additions and 6 deletions.
12 changes: 6 additions & 6 deletions python/deltalake/writer.py
Original file line number Diff line number Diff line change
Expand Up @@ -38,6 +38,12 @@
from ._internal import batch_distinct
from ._internal import write_new_deltalake as _write_new_deltalake
from .exceptions import DeltaProtocolError, TableNotFoundError
from .schema import (
convert_pyarrow_dataset,
convert_pyarrow_recordbatch,
convert_pyarrow_recordbatchreader,
convert_pyarrow_table,
)
from .table import MAX_SUPPORTED_WRITER_VERSION, DeltaTable

try:
Expand Down Expand Up @@ -158,12 +164,6 @@ def write_deltalake(
partition_filters: the partition filters that will be used for partition overwrite.
large_dtypes: If True, the data schema is kept in large_dtypes, has no effect on pandas dataframe input
"""
from .schema import (
convert_pyarrow_dataset,
convert_pyarrow_recordbatch,
convert_pyarrow_recordbatchreader,
convert_pyarrow_table,
)

table, table_uri = try_get_table_and_table_uri(table_or_uri, storage_options)

Expand Down

0 comments on commit 8e076eb

Please sign in to comment.