We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 11b3bf9 commit 8e2938bCopy full SHA for 8e2938b
awswrangler/athena/_write_iceberg.py
@@ -548,7 +548,7 @@ def to_iceberg( # noqa: PLR0913
548
549
# Ensure that the ordering of the DF is the same as in the catalog.
550
# This is required for the INSERT command to work.
551
- df = df[catalog_cols]
+ df = df[catalog_cols + [col_name for col_name, _ in schema_differences["new_columns"].items()]]
552
553
if schema_evolution is False and any([schema_differences[x] for x in schema_differences]): # type: ignore[literal-required]
554
raise exceptions.InvalidArgumentValue(f"Schema change detected: {schema_differences}")
0 commit comments