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

crate · Aug 27, 2024 · 7d630de · 7d630de
1 parent e2defa8
commit 7d630de
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git 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
@@ -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()