From f3eae985de26416d20acc20be44d2b456aaa5030 Mon Sep 17 00:00:00 2001 From: cisphyx Date: Fri, 22 Mar 2024 16:16:11 -0400 Subject: [PATCH 1/3] Add a message to t2:genr LinkShutDown exception (SYN-7033) --- synapse/telepath.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/synapse/telepath.py b/synapse/telepath.py index 67c29f735c..6135f0c780 100644 --- a/synapse/telepath.py +++ b/synapse/telepath.py @@ -832,7 +832,7 @@ async def genrloop(): mesg = await link.rx() if mesg is None: - raise s_exc.LinkShutDown(mesg=mesg) + raise s_exc.LinkShutDown(mesg='Remote peer disconnected') if mesg[0] != 't2:yield': # pragma: no cover info = 'Telepath protocol violation: unexpected message received' From f9197327764286327e8daf8c2be21ef8cea06ed6 Mon Sep 17 00:00:00 2001 From: cisphyx Date: Fri, 22 Mar 2024 16:20:44 -0400 Subject: [PATCH 2/3] deprecate task v1 --- synapse/telepath.py | 2 ++ 1 file changed, 2 insertions(+) diff --git a/synapse/telepath.py b/synapse/telepath.py index 6135f0c780..57d67adba5 100644 --- a/synapse/telepath.py +++ b/synapse/telepath.py @@ -869,6 +869,8 @@ async def task(self, todo, name=None): if self.sess is not None: return await self.taskv2(todo, name=name) + s_common.deprecated('Telepath task with no session', curv=2.166.0) + task = Task() mesg = ('task:init', { From 306caa567fef9dccc4cb8f780bae458af77eac8d Mon Sep 17 00:00:00 2001 From: cisphyx Date: Fri, 22 Mar 2024 16:24:11 -0400 Subject: [PATCH 3/3] fix typo --- synapse/telepath.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/synapse/telepath.py b/synapse/telepath.py index 57d67adba5..ff454117ea 100644 --- a/synapse/telepath.py +++ b/synapse/telepath.py @@ -869,7 +869,7 @@ async def task(self, todo, name=None): if self.sess is not None: return await self.taskv2(todo, name=name) - s_common.deprecated('Telepath task with no session', curv=2.166.0) + s_common.deprecated('Telepath task with no session', curv='2.166.0') task = Task()