Update storage_options when using DeltaTable in write_deltalake

delta-io · Sep 26, 2024 · 47b9286 · 47b9286
1 parent 2498837
commit 47b9286
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/python/deltalake/writer.py b/python/deltalake/writer.py
@@ -297,8 +297,8 @@ def write_deltalake(
 
     table, table_uri = try_get_table_and_table_uri(table_or_uri, storage_options)
     if table is not None:
-        storage_options = table._storage_options or {}
-        storage_options.update(storage_options or {})
+        if table._storage_options and storage_options:
+            table._storage_options.update(storage_options)
         table.update_incremental()
 
     _enforce_append_only(table=table, configuration=configuration, mode=mode)