Skip to content

Commit aba8ca1

Browse files
committed
fix test
1 parent efcb3a3 commit aba8ca1

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

tests/test_system_eraser.py

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -74,9 +74,10 @@ def test_delete_system_exception(mock_app_context, mock_db_session, mock_consume
7474
def test_run_processes_delete_message(mock_app_context, mock_db_session, mock_consumer):
7575
eraser = SystemEraser()
7676

77-
payload = {"type": "delete", "host": {"id": "host-999"}}
77+
payload = {"type": "delete", "id": "host-999"}
7878
message = MagicMock()
7979
message.value.return_value = json.dumps(payload).encode("utf-8")
80+
message.error.return_value = None # No error
8081

8182
# Consumer should return the message once then None
8283
mock_consumer.poll.side_effect = [message, None]
@@ -90,9 +91,10 @@ def test_run_processes_delete_message(mock_app_context, mock_db_session, mock_co
9091
def test_run_ignores_non_delete_message(mock_app_context, mock_db_session, mock_consumer):
9192
eraser = SystemEraser()
9293

93-
payload = {"type": "update", "host": {"id": "host-777"}}
94+
payload = {"type": "update", "id": "host-777"}
9495
message = MagicMock()
9596
message.value.return_value = json.dumps(payload).encode("utf-8")
97+
message.error.return_value = None # No error
9698

9799
mock_consumer.poll.side_effect = [message, None]
98100

0 commit comments

Comments
 (0)