diff --git a/octue/cloud/pub_sub/validation.py b/octue/cloud/pub_sub/validation.py index 482845319..7eeea51f9 100644 --- a/octue/cloud/pub_sub/validation.py +++ b/octue/cloud/pub_sub/validation.py @@ -7,7 +7,7 @@ logger = logging.getLogger(__name__) -SERVICE_COMMUNICATION_SCHEMA = "https://jsonschema.registry.octue.com/octue/service-communication/0.1.2.json" +SERVICE_COMMUNICATION_SCHEMA = "https://jsonschema.registry.octue.com/octue/service-communication/0.1.3.json" SERVICE_COMMUNICATION_SCHEMA_INFO_URL = "https://strands.octue.com/octue/service-communication" diff --git a/octue/resources/child.py b/octue/resources/child.py index f88bada6c..fc4d990ce 100644 --- a/octue/resources/child.py +++ b/octue/resources/child.py @@ -79,7 +79,6 @@ def ask( :param bool allow_save_diagnostics_data_on_crash: if `True`, allow the input values and manifest (and its datasets) to be saved by the child if it fails while processing them :param str|None question_uuid: the UUID to use for the question if a specific one is needed; a UUID is generated if not :param float timeout: time in seconds to wait for an answer before raising a timeout error - :param float|int delivery_acknowledgement_timeout: how long in seconds to wait for a delivery acknowledgement before aborting :param float|int maximum_heartbeat_interval: the maximum amount of time (in seconds) allowed between child heartbeats before an error is raised :raise TimeoutError: if the timeout is exceeded while waiting for an answer :return dict: a dictionary containing the keys "output_values" and "output_manifest"