Skip to content

Commit

Permalink
add note about append+ovewrite logic
Browse files Browse the repository at this point in the history
  • Loading branch information
marcosmarxm authored Dec 26, 2024
1 parent 6c2ea27 commit 0cb640e
Showing 1 changed file with 3 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -262,6 +262,9 @@ def _write_temp_table_to_target_table(
) -> None:
"""Write the temp table into the final table using the provided write strategy."""
if sync_mode == DestinationSyncMode.append or sync_mode == DestinationSyncMode.overwrite:
# Because overwrite drops the table and reinsert all the data
# we can use the same logic as append.
# The table is dropped during (_ensure_table_exists)
self._ensure_compatible_table_schema(
stream_name=stream_name,
table_name=final_table_name,
Expand Down

0 comments on commit 0cb640e

Please sign in to comment.