Skip to content

Commit

Permalink
DMS/DynamoDB: Fix table name quoting within CDC processor handler
Browse files Browse the repository at this point in the history
  • Loading branch information
amotl committed Aug 27, 2024
1 parent e2defa8 commit 60fc24f
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 2 deletions.
1 change: 1 addition & 0 deletions CHANGES.md
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down
3 changes: 1 addition & 2 deletions cratedb_toolkit/io/processor/kinesis_lambda.py
Original file line number Diff line number Diff line change
Expand Up @@ -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()

Expand Down

0 comments on commit 60fc24f

Please sign in to comment.