From 9261c8f4a79971e5d5361dd2d0df902bdc44e394 Mon Sep 17 00:00:00 2001 From: Tobias Henkel Date: Tue, 24 Mar 2020 17:43:46 +0100 Subject: Move handleDisconnect into BaseClientServer It's called from there using self.handleDisconnect so define it there as well. Change-Id: I90fef55a79168e082e69f81a717c08badd4163a9 --- 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. -- cgit v1.2.1