Bug: idempotent functions return None on replay when the stored response is falsy (0, False, "", [], {})

Offen
#8,700 3 Kommentare 0 Reaktionen 1 zugewiesene Person Auf GitHub ansehen

Maintainer antworten meist innerhalb von 1 Tag

@thebadalov arbeitet bereits daran.

Seit 29.10.2026.

  • #8701 von @thebadalov — offen

Bewertung

Dieses Issue wurde noch nicht bewertet.

Beschreibung

bug idempotency
Expected Behaviour

When an idempotent function returns a falsy value (0, False, "", [], {}), a retry with the same payload should return that same value from the persistence store.

Current Behaviour

The first call returns the value and it is stored correctly, but every replay returns None.

IdempotencyHandler._handle_for_status reads the stored response with:

serialized_response = self.output_serializer.from_dict(response_dict) if response_dict else None

so any falsy response_dict becomes None. #8090 pointed out this line together with the write path in _get_function_response. The write path was changed to is not None, but the read path still uses a truthiness check, so the value is saved and then dropped on replay.

Code snippet
from aws_lambda_powertools.utilities.idempotency import idempotent_function
from aws_lambda_powertools.utilities.idempotency.exceptions import (
    IdempotencyItemAlreadyExistsError,
    IdempotencyItemNotFoundError,
)
from aws_lambda_powertools.utilities.idempotency.persistence.base import BasePersistenceLayer, DataRecord


class InMemoryPersistenceLayer(BasePersistenceLayer):
    def __init__(self):
        super().__init__()
        self.records = {}

    def _get_record(self, idempotency_key) -> DataRecord:
        if idempotency_key not in self.records:
            raise IdempotencyItemNotFoundError
        return self.records[idempotency_key]

    def _put_record(self, data_record: DataRecord) -> None:
        if data_record.idempotency_key in self.records:
            raise IdempotencyItemAlreadyExistsError
        self.records[data_record.idempotency_key] = data_record

    def _update_record(self, data_record: DataRecord) -> None:
        self.records[data_record.idempotency_key] = data_record

    def _delete_record(self, data_record: DataRecord) -> None:
        self.records.pop(data_record.idempotency_key, None)


persistence_layer = InMemoryPersistenceLayer()


@idempotent_function(data_keyword_argument="order", persistence_store=persistence_layer)
def count_items(order):
    return len(order["items"])


order = {"order_id": "o-1", "items": []}
print(count_items(order=order))  # 0
print(count_items(order=order))  # None, expected 0

I see the same with CachePersistenceLayer on a real Redis server: 0, False, "", [] and {} all come back as None on replay, while None and truthy values are returned correctly.

Possible Solution

Use is not None, matching the write path:

serialized_response = self.output_serializer.from_dict(response_dict) if response_dict is not None else None

DataRecord.response_json_as_dict() already returns None when there is no stored data, and a function that returns None is stored as null, so that case keeps returning None.

Steps to Reproduce

Run the snippet above. Any persistence layer is affected, since the check is in the shared handler.

Powertools for AWS Lambda (Python) version

latest (3.37.0, also on develop)

AWS Lambda function runtime

3.13

Packaging format used

PyPi

Debugging logs
N/A, the replay returns None without an error
Vorherrschende Sprache
Python
Sterne
3.3k
Forks
511
Ø Merge
3 T. 8 Std.
Gemergte PRs (30 T.)
92

Entwicklungsumgebung

Erste Schritte

  1. Lesen Sie das ganze Issue und danach den Beitragsleitfaden des Projekts.
  2. Schreiben Sie ins Issue, dass Sie es übernehmen — das erspart doppelte Arbeit.
  3. Forken Sie das Repository und arbeiten Sie in einem Branch.
  4. Öffnen Sie einen Pull Request, der die Issue-Nummer nennt.

Mehr aus aws-powertools/powertools-lambda-python

Alle Issues in aws-powertools/powertools-lambda-python

Ähnliche Issues

Weitere Issues zu Python

Neue Issues direkt in Ihr Postfach

Eine kurze Übersicht über anfängerfreundliche GitHub-Issues.