We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 0485fa2 commit 1621a39Copy full SHA for 1621a39
1 file changed
unit_tests/test_entrypoint.py
@@ -911,9 +911,7 @@ def _raise_on_second_call() -> None:
911
# 1. Both records were yielded before the exception — the memory check
912
# runs after yield so every message pulled from the source is emitted.
913
record_messages = [m for m in messages if "RECORD" in m]
914
- assert len(record_messages) == 2, (
915
- "Both records should be yielded before MemoryLimitExceeded"
916
- )
+ assert len(record_messages) == 2, "Both records should be yielded before MemoryLimitExceeded"
917
918
# 2. The queued state message was flushed by the finally block
919
state_messages = [m for m in messages if "STATE" in m]
0 commit comments