outposts: improve logs for outpost connection
This commit is contained in:
parent
00235e039b
commit
d99451b45c
|
@ -55,13 +55,21 @@ class OutpostConsumer(AuthJsonConsumer):
|
||||||
OutpostState(
|
OutpostState(
|
||||||
uid=self.channel_name, last_seen=datetime.now(), _outpost=self.outpost
|
uid=self.channel_name, last_seen=datetime.now(), _outpost=self.outpost
|
||||||
).save(timeout=OUTPOST_HELLO_INTERVAL * 1.5)
|
).save(timeout=OUTPOST_HELLO_INTERVAL * 1.5)
|
||||||
LOGGER.debug("added channel to cache", channel_name=self.channel_name)
|
LOGGER.debug(
|
||||||
|
"added outpost instace to cache",
|
||||||
|
outpost=self.outpost,
|
||||||
|
channel_name=self.channel_name,
|
||||||
|
)
|
||||||
|
|
||||||
# pylint: disable=unused-argument
|
# pylint: disable=unused-argument
|
||||||
def disconnect(self, close_code):
|
def disconnect(self, close_code):
|
||||||
if self.outpost:
|
if self.outpost:
|
||||||
OutpostState.for_channel(self.outpost, self.channel_name).delete()
|
OutpostState.for_channel(self.outpost, self.channel_name).delete()
|
||||||
LOGGER.debug("removed channel from cache", channel_name=self.channel_name)
|
LOGGER.debug(
|
||||||
|
"removed outpost instance from cache",
|
||||||
|
outpost=self.outpost,
|
||||||
|
channel_name=self.channel_name,
|
||||||
|
)
|
||||||
|
|
||||||
def receive_json(self, content: Data):
|
def receive_json(self, content: Data):
|
||||||
msg = from_dict(WebsocketMessage, content)
|
msg = from_dict(WebsocketMessage, content)
|
||||||
|
|
Reference in New Issue