scheduler.py: Notification for Message() propagation

Add a notification for MESSAGE. Instead of scheduler's Queues and
Jobs directly calling the message handler that App has assigned to
Context, the Message() is now sent over the notification handler
where it is then given to Messenger's handler.

1 files changed, 3 insertions, 3 deletions

diff --git a/src/buildstream/_scheduler/jobs/job.py b/src/buildstream/_scheduler/jobs/job.py
index 9af08df92..913e27ea2 100644
--- a/src/buildstream/_scheduler/jobs/job.py
+++ b/src/buildstream/_scheduler/jobs/job.py
@@ -393,8 +393,8 @@ class Job():
             element_name = self._message_element_name
         if element_key is None:
             element_key = self._message_element_key
-        self._scheduler.context.messenger.message(
-            Message(message_type, message, element_name=element_name, element_key=element_key, **kwargs))
+        message = Message(message_type, message, element_name=element_name, element_key=element_key, **kwargs)
+        self._scheduler.notify_messenger(message)
 
     # get_element()
     #
@@ -536,7 +536,7 @@ class Job():
         if envelope.message_type is _MessageType.LOG_MESSAGE:
             # Propagate received messages from children
             # back through the context.
-            self._scheduler.context.messenger.message(envelope.message)
+            self._scheduler.notify_messenger(envelope.message)
         elif envelope.message_type is _MessageType.ERROR:
             # For regression tests only, save the last error domain / reason
             # reported from a child task in the main process, this global state