ExternalVendorCode/tahoe-lafs
1
0
Fork 0
mirror of https://github.com/tahoe-lafs/tahoe-lafs.git synced 2025-02-27 11:46:44 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

removed deferred logger from basic function in test_logs

Browse Source 
Signed-off-by: fenn-cs <fenn25.fn@gmail.com>
This commit is contained in:
fenn-cs 2021-11-02 10:36:32 +01:00
parent 69d335c1e1
commit 5ba636c7b1
1 changed files with 3 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/allmydata/test/web/test_logs.py
View File

@ -54,9 +54,7 @@ from ...web.logs import (
TokenAuthenticatedWebSocketServerProtocol, TokenAuthenticatedWebSocketServerProtocol,
) )
from ...util.eliotutil import ( from eliot import log_call
log_call_deferred
)
class StreamingEliotLogsTests(SyncTestCase): class StreamingEliotLogsTests(SyncTestCase):
""" """
@ -110,7 +108,7 @@ class TestStreamingLogs(AsyncTestCase):
messages.append(json.loads(msg)) messages.append(json.loads(msg))
proto.on("message", got_message) proto.on("message", got_message)
@log_call_deferred(action_type=u"test:cli:some-exciting-action") @log_call(action_type=u"test:cli:some-exciting-action")
def do_a_thing(arguments): def do_a_thing(arguments):
pass pass
@ -121,7 +119,7 @@ class TestStreamingLogs(AsyncTestCase):
self.assertThat(len(messages), Equals(3)) self.assertThat(len(messages), Equals(3))
self.assertThat(messages[0]["action_type"], Equals("test:cli:some-exciting-action")) self.assertThat(messages[0]["action_type"], Equals("test:cli:some-exciting-action"))
self.assertThat(messages[0]["kwargs"]["arguments"], self.assertThat(messages[0]["arguments"],
Equals(["hello", "good-\\xff-day", 123, {"a": 35}, [None]])) Equals(["hello", "good-\\xff-day", 123, {"a": 35}, [None]]))
self.assertThat(messages[1]["action_type"], Equals("test:cli:some-exciting-action")) self.assertThat(messages[1]["action_type"], Equals("test:cli:some-exciting-action"))
self.assertThat("started", Equals(messages[0]["action_status"])) self.assertThat("started", Equals(messages[0]["action_status"]))