From a4e7e0e35a4ee4cc26a60b4185885901db00b7f0 Mon Sep 17 00:00:00 2001 From: cortadocodes Date: Wed, 5 Feb 2025 19:28:29 +0000 Subject: [PATCH] REF: Rename function --- octue/cloud/pub_sub/service.py | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/octue/cloud/pub_sub/service.py b/octue/cloud/pub_sub/service.py index cc7363bc1..30408c5ef 100644 --- a/octue/cloud/pub_sub/service.py +++ b/octue/cloud/pub_sub/service.py @@ -234,7 +234,7 @@ def answer(self, question, heartbeat_interval=120, timeout=30): heartbeater = RepeatingTimer( interval=heartbeat_interval, - function=self._send_heartbeat_and_check_runtime, + function=self._send_heartbeat, kwargs=routing_metadata, ) @@ -669,7 +669,7 @@ def _send_delivery_acknowledgment( logger.info("%r acknowledged receipt of question %r.", self, question_uuid) - def _send_heartbeat_and_check_runtime( + def _send_heartbeat( self, question_uuid, parent_question_uuid, @@ -688,7 +688,6 @@ def _send_heartbeat_and_check_runtime( :param str originator: the SRUID of the service revision that triggered all ancestor questions of this question :param int retry_count: the retry count of the question (this is zero if it's the first attempt at the question) :param int|float start_time: the `time.perf_counter` time that the analysis was started [s] - :param int|float runtime_timeout_warning_time: the amount of time after which to warn that the runtime timeout is approaching [s] :param float timeout: time in seconds after which to give up sending :return None: """