REF: Factor out default maximum heartbeat interval

Author: cortadocodes

octue/cloud/pub_sub/events.py

@@ -10,6 +10,7 @@
 from octue.cloud.events.attributes import ResponseAttributes
 from octue.cloud.events.handler import AbstractEventHandler
 from octue.cloud.events.validation import SERVICE_COMMUNICATION_SCHEMA
+from octue.definitions import DEFAULT_MAXIMUM_HEARTBEAT_INTERVAL
 from octue.utils.decoders import OctueJSONDecoder
 from octue.utils.objects import get_nested_attribute
 from octue.utils.threads import RepeatingTimer
@@ -110,7 +111,7 @@ def _time_since_last_heartbeat(self):
 
         return datetime.now() - self._last_heartbeat
 
-    def handle_events(self, timeout=60, maximum_heartbeat_interval=360):
+    def handle_events(self, timeout=60, maximum_heartbeat_interval=DEFAULT_MAXIMUM_HEARTBEAT_INTERVAL):
         """Pull events from the subscription and handle them in the order they were sent until a "result" event is
         handled, then return the handled result.
 

octue/cloud/pub_sub/service.py

@@ -24,7 +24,7 @@
     validate_sruid,
 )
 from octue.compatibility import warn_if_incompatible
-from octue.definitions import LOCAL_SDK_VERSION
+from octue.definitions import DEFAULT_MAXIMUM_HEARTBEAT_INTERVAL, LOCAL_SDK_VERSION
 import octue.exceptions
 from octue.utils.dictionaries import make_minimal_dictionary
 from octue.utils.encoders import OctueJSONEncoder
@@ -383,7 +383,7 @@ def wait_for_answer(
         handle_monitor_message=None,
         record_events=True,
         timeout=60,
-        maximum_heartbeat_interval=360,
+        maximum_heartbeat_interval=DEFAULT_MAXIMUM_HEARTBEAT_INTERVAL,
     ):
         """Wait for an answer to a question on the given subscription, deleting the subscription and its topic once
         the answer is received.

octue/definitions.py

@@ -20,3 +20,4 @@
 
 GOOGLE_COMPUTE_PROVIDERS = {"GOOGLE_CLOUD_FUNCTION"}
 LOCAL_SDK_VERSION = importlib.metadata.version("octue")
+DEFAULT_MAXIMUM_HEARTBEAT_INTERVAL = 360

octue/resources/child.py

@@ -4,6 +4,7 @@
 import os
 
 from octue.cloud.pub_sub.service import Service
+from octue.definitions import DEFAULT_MAXIMUM_HEARTBEAT_INTERVAL
 from octue.resources import service_backends
 
 logger = logging.getLogger(__name__)
@@ -76,7 +77,7 @@ def ask(
         prevent_retries_when=None,
         log_errors=True,
         timeout=86400,
-        maximum_heartbeat_interval=360,
+        maximum_heartbeat_interval=DEFAULT_MAXIMUM_HEARTBEAT_INTERVAL,
     ):
         """Ask the child either:
         - A synchronous (ask-and-wait) question and wait for it to return an output. Questions are synchronous if