ENH: Update emulators with parent question UUID

Author: cortadocodes

octue/cloud/emulators/_pub_sub.py

@@ -20,10 +20,10 @@
 
 
 class MockTopic(Topic):
-    """A mock topic that registers in a global messages dictionary rather than Google Pub/Sub."""
+    """A mock topic that registers in a global topics dictionary rather than Google Pub/Sub."""
 
     def create(self, allow_existing=False):
-        """Register the topic in the global messages dictionary.
+        """Register the topic in the global topics dictionary.
 
         :param bool allow_existing: if True, don't raise an error if the topic already exists
         :raise google.api_core.exceptions.AlreadyExists: if the topic already exists
@@ -38,7 +38,7 @@ def create(self, allow_existing=False):
             self._created = True
 
     def delete(self):
-        """Delete the topic from the global messages dictionary.
+        """Delete the topic from the global topics dictionary.
 
         :return None:
         """
@@ -48,7 +48,7 @@ def delete(self):
             pass
 
     def exists(self, timeout=10):
-        """Check if the topic exists in the global messages dictionary.
+        """Check if the topic exists in the global topics dictionary.
 
         :param float timeout:
         :return bool:
@@ -326,6 +326,7 @@ def ask(
         allow_local_files=False,
         save_diagnostics="SAVE_DIAGNOSTICS_ON_CRASH",
         question_uuid=None,
+        parent_question_uuid=None,
         push_endpoint=None,
         asynchronous=False,
         timeout=86400,
@@ -342,6 +343,7 @@ def ask(
         :param bool allow_local_files:
         :param str save_diagnostics:
         :param str|None question_uuid:
+        :param str|None parent_question_uuid:
         :param str|None push_endpoint:
         :param bool asynchronous:
         :param float|None timeout:
@@ -356,6 +358,7 @@ def ask(
             allow_local_files=allow_local_files,
             save_diagnostics=save_diagnostics,
             question_uuid=question_uuid,
+            parent_question_uuid=parent_question_uuid,
             push_endpoint=push_endpoint,
             asynchronous=asynchronous,
             timeout=timeout,
@@ -380,6 +383,7 @@ def ask(
                         "datetime": "2024-04-11T10:46:48.236064",
                         "uuid": "a9de11b1-e88f-43fa-b3a4-40a590c3443f",
                         "question_uuid": question_uuid,
+                        "parent_question_uuid": parent_question_uuid,
                         "forward_logs": subscribe_to_logs,
                         "save_diagnostics": save_diagnostics,
                         "order": 0,