diff --git a/dbxio/__init__.py b/dbxio/__init__.py index 5fe821c..99f54ab 100644 --- a/dbxio/__init__.py +++ b/dbxio/__init__.py @@ -4,4 +4,4 @@ from dbxio.utils import * # noqa: F403 from dbxio.volume import * # noqa: F403 -__version__ = '0.5.0' # single source of truth +__version__ = '0.5.1' # single source of truth diff --git a/dbxio/delta/table_commands.py b/dbxio/delta/table_commands.py index 5db91b3..e2182a2 100644 --- a/dbxio/delta/table_commands.py +++ b/dbxio/delta/table_commands.py @@ -310,6 +310,7 @@ def bulk_write_table( replace=True, ) else: + create_table(dbxio_table, client=client).wait() copy_into_table( client=client, table=dbxio_table, @@ -375,6 +376,7 @@ def bulk_write_local_files( replace=True, ) else: + create_table(table, client=client).wait() copy_into_table( client=client, table=table,