Skip to content
Merged
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
8 changes: 5 additions & 3 deletions tests/unit/test_response_future.py
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,7 @@

from collections import deque
from threading import RLock
from unittest.mock import Mock, MagicMock, ANY
from unittest.mock import Mock, MagicMock, ANY, patch

from cassandra import ConsistencyLevel, Unavailable, SchemaTargetType, SchemaChangeType, OperationTimedOut
from cassandra.cluster import Session, ResponseFuture, NoHostAvailable, ProtocolVersion, ControlConnectionQueryFallback
Expand Down Expand Up @@ -1316,8 +1316,9 @@ def test_set_result_no_metadata_statement_adopts_metadata_changed(self):
)

# Ordinary METADATA_CHANGED handling, so no anomaly warning either.
with self.assertNoLogs('cassandra.cluster', level='WARNING'):
with patch('cassandra.cluster.log.warning') as warning:
rf._set_result(None, None, None, response)
warning.assert_not_called()

assert ps.result_metadata_and_id == (new_meta, b'new_id')

Expand Down Expand Up @@ -1351,8 +1352,9 @@ def test_set_result_anomalous_metadata_id_warns_once_and_rearms(self):
assert sum('result_metadata_id' in msg for msg in first.output) == 1

# Second identical anomalous response: no new warning (deduped).
with self.assertNoLogs('cassandra.cluster', level='WARNING'):
with patch('cassandra.cluster.log.warning') as warning:
rf._set_result(None, None, None, anomalous)
warning.assert_not_called()
assert ps.result_metadata_and_id == (old_meta, b'old_id')

# A genuine METADATA_CHANGED recovers the metadata and re-arms the warning.
Expand Down
Loading