From 9261c8f4a79971e5d5361dd2d0df902bdc44e394 Mon Sep 17 00:00:00 2001

From: Tobias Henkel <tobias.henkel@bmw.de>

Date: Tue, 24 Mar 2020 17:43:46 +0100

Subject: [PATCH 2/9] Move handleDisconnect into BaseClientServer

It's called from there using self.handleDisconnect so define it there

as well.

Change-Id: I90fef55a79168e082e69f81a717c08badd4163a9

Signed-off-by: Matthieu Huin <mhuin@redhat.com>

---

 gear/__init__.py | 22 +++++++++++-----------

 1 file changed, 11 insertions(+), 11 deletions(-)

diff --git a/gear/__init__.py b/gear/__init__.py

index f7fc767..891804b 100644

--- a/gear/__init__.py

+++ b/gear/__init__.py

@@ -996,6 +996,17 @@ class BaseClientServer(object):

         end = time.time()

         self.reportTimingStats(packet.ptype, end - start)

+    def handleDisconnect(self, job):

+        """Handle a Gearman server disconnection.

+

+        If the Gearman server is disconnected, this will be called for any

+        jobs currently associated with the server.

+

+        :arg Job packet: The :py:class:`Job` that was running when the server

+            disconnected.

+        """

+        return job

+

     def reportTimingStats(self, ptype, duration):

         """Report processing times by packet type

@@ -1696,17 +1707,6 @@ class Client(BaseClient):

         packet.connection.handleOptionRes(packet.getArgument(0))

         task.setComplete()

-    def handleDisconnect(self, job):

-        """Handle a Gearman server disconnection.

-

-        If the Gearman server is disconnected, this will be called for any

-        jobs currently associated with the server.

-

-        :arg Job packet: The :py:class:`Job` that was running when the server

-            disconnected.

-        """

-        return job

-

 class FunctionRecord(object):

     """Represents a function that should be registered with Gearman.

-- 

2.31.1