summaryrefslogtreecommitdiff
path: root/src/buildstream/_scheduler/jobs/job.py
diff options
context:
space:
mode:
authorAngelos Evripiotis <jevripiotis@bloomberg.net>2019-05-30 09:30:12 +0100
committerbst-marge-bot <marge-bot@buildstream.build>2019-06-05 14:13:10 +0000
commitefc8a4dbb54b63cd5412218e17c9fa9801356aff (patch)
treed351d2ca7974a988f649f1a91801547fb9932155 /src/buildstream/_scheduler/jobs/job.py
parentdad39f94ad147101efd166ddd6eadf6cadd8e806 (diff)
downloadbuildstream-efc8a4dbb54b63cd5412218e17c9fa9801356aff.tar.gz
_scheduler/jobs/job: document send_message
Diffstat (limited to 'src/buildstream/_scheduler/jobs/job.py')
-rw-r--r--src/buildstream/_scheduler/jobs/job.py16
1 files changed, 13 insertions, 3 deletions
diff --git a/src/buildstream/_scheduler/jobs/job.py b/src/buildstream/_scheduler/jobs/job.py
index df9d3a8bc..178c84703 100644
--- a/src/buildstream/_scheduler/jobs/job.py
+++ b/src/buildstream/_scheduler/jobs/job.py
@@ -584,11 +584,21 @@ class ChildJob():
# send_message()
#
+ # Send data in a message to the parent Job, running in the main process.
+ #
+ # This allows for custom inter-process communication between subclasses of
+ # Job and ChildJob.
+ #
# These messages will be processed by the Job.handle_message()
- # implementation.
+ # implementation, which may be overridden to support one or more custom
+ # 'message_type's.
+ #
+ # Args:
+ # message_type (str): The type of message to send.
+ # message_data (any): A (simple!) object to be sent to the parent Job.
#
- def send_message(self, message_type, message):
- self._queue.put(_Envelope(message_type, message))
+ def send_message(self, message_type, message_data):
+ self._queue.put(_Envelope(message_type, message_data))
#######################################################
# Abstract Methods #