apersilva

Results 3 comments of apersilva

def update_table(database_target, table_target,database_name, table_name, partition_by,size, process_date, custom_partion): catalog =load_catalog('glue', **{ 'type': 'glue', 'verify' : False }) tabela = catalog.load_table(f"{database_target}.{table_target}") metadata = {} for doc in tabela.metadata.schemas[0].columns: metadata.update({doc.name: f"({doc.doc})"}) df =...

└────┴───────────────────────────────────────────────────────────────────────────┴──────────────────────────────────────────┘Traceback (most recent call last): File "c:\great_teste\update_table.py", line 45, in update_table tabela.append(df) File "C:\Users\9001329\AppData\Roaming\Python\Python310\site-packages\pyiceberg\table\__init__.py", line 1057, in append _check_schema_compatible(self.schema(), other_schema=df.schema) File "C:\Users\9001329\AppData\Roaming\Python\Python310\site-packages\pyiceberg\table\__init__.py", line 175, in _check_schema_compatible raise ValueError(f"Mismatch in fields:\n{console.export_text()}")...

It´s work, thanks a lot.