PR comments

giograno · giograno · commit 4cc822a6af4b · 2026-02-12T13:06:52.000+01:00
diff --git a/localstack-core/localstack/services/dynamodb/provider.py b/localstack-core/localstack/services/dynamodb/provider.py
@@ -274,7 +274,11 @@ def forward_to_kinesis_stream(
             table_arn = arns.dynamodb_table_arn(table_name, account_id, region_name)
             records = table_records["records"]
             table_def = store.table_definitions.get(table_name) or {}
-            destinations = store.streaming_destinations.get(table_name) or []
+            destinations = store.streaming_destinations.get(table_name)
+            if not destinations:
+                LOG.debug("Table %s has no Kinesis streaming destinations enabled", table_name)
+                continue
+
             stream_arn = destinations[-1]["StreamArn"]
             for record in records:
                 kinesis_record = dict(
diff --git a/localstack-core/localstack/services/dynamodbstreams/dynamodbstreams_api.py b/localstack-core/localstack/services/dynamodbstreams/dynamodbstreams_api.py
@@ -16,7 +16,7 @@
 from localstack.services.dynamodb.v2.provider import DynamoDBProvider
 from localstack.services.dynamodbstreams.models import (
     DynamoDbStreamsStore,
-    Stream,
+    StreamWrapper,
     dynamodbstreams_stores,
 )
 from localstack.utils.aws import arns, resources
@@ -89,7 +89,7 @@ def add_dynamodb_stream(
         Shards=[],
         StreamViewType=view_type,
     )
-    store.ddb_streams[table_name] = Stream(StreamDescription=stream)
+    store.ddb_streams[table_name] = StreamWrapper(StreamDescription=stream)
 
 
 def get_stream_for_table(
@@ -219,7 +219,7 @@ def kinesis_shard_id(dynamodbstream_shard_id: str) -> str:
     return f"{shard_params[0]}-{shard_params[-1]}"
 
 
-def get_shard_id(stream: Stream, kinesis_shard_id: str) -> str:
+def get_shard_id(stream: StreamWrapper, kinesis_shard_id: str) -> str:
     ddb_stream_shard_id = stream.shards_id_map.get(kinesis_shard_id)
     if not ddb_stream_shard_id:
         ddb_stream_shard_id = shard_id(kinesis_shard_id)
diff --git a/localstack-core/localstack/services/dynamodbstreams/models.py b/localstack-core/localstack/services/dynamodbstreams/models.py
@@ -5,15 +5,15 @@
 
 
 @dataclasses.dataclass
-class Stream:
+class StreamWrapper:
     """Wrapper for the API stub and additional information about a store"""
 
     StreamDescription: StreamDescription
     shards_id_map: dict[str, str] = dataclasses.field(default_factory=dict)
 
 
 class DynamoDbStreamsStore(BaseStore):
-    ddb_streams: dict[str, Stream] = LocalAttribute(default=dict)
+    ddb_streams: dict[str, StreamWrapper] = LocalAttribute(default=dict)
 
 
 dynamodbstreams_stores = AccountRegionBundle("dynamodbstreams", DynamoDbStreamsStore)
