summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorAngelos Evripiotis <jevripiotis@bloomberg.net>2019-05-30 09:30:12 +0100
committerAngelos Evripiotis <jevripiotis@bloomberg.net>2019-06-04 10:04:17 +0100
commit007441e33ee635f1aff3daec12a70dcdcf2f62ed (patch)
treed7845997781ce14d655b6f2e86139bc915514c12
parent8f5cdbd437cf7d016bb6bba6560e8d3d9961e625 (diff)
downloadbuildstream-007441e33ee635f1aff3daec12a70dcdcf2f62ed.tar.gz
_scheduler/jobs/job: document send_message
-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 #