diff --git a/CHANGES.md b/CHANGES.md index 31d0fd4d..f667db48 100644 --- a/CHANGES.md +++ b/CHANGES.md @@ -2,6 +2,7 @@ ## Unreleased +- DMS/DynamoDB: Fix table name quoting within CDC processor handler ## 2024/08/26 v0.0.19 - MongoDB: Fix and verify Zyp transformations diff --git a/cratedb_toolkit/io/processor/kinesis_lambda.py b/cratedb_toolkit/io/processor/kinesis_lambda.py index 4d661d34..005b49cf 100644 --- a/cratedb_toolkit/io/processor/kinesis_lambda.py +++ b/cratedb_toolkit/io/processor/kinesis_lambda.py @@ -127,8 +127,7 @@ def handler(event, context): connection.execute(sa.text(operation.statement), parameters=operation.parameters) # Processing alternating CDC events requires write synchronization. - # FIXME: Needs proper table name quoting. - connection.execute(sa.text(f"REFRESH TABLE {CRATEDB_TABLE}")) + connection.execute(sa.text(f"REFRESH TABLE {cdc.quote_table_name(CRATEDB_TABLE)}")) connection.commit()