From 60fc24f0703e3f227932cbcf422796a3a4d1e90e Mon Sep 17 00:00:00 2001 From: Andreas Motl Date: Tue, 27 Aug 2024 11:26:37 +0200 Subject: [PATCH] DMS/DynamoDB: Fix table name quoting within CDC processor handler --- CHANGES.md | 1 + cratedb_toolkit/io/processor/kinesis_lambda.py | 3 +-- 2 files changed, 2 insertions(+), 2 deletions(-) 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()