DMS/DynamoDB: Fix table name quoting within CDC processor handler

Author: amotl

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

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()