diff options
author | Angelos Evripiotis <jevripiotis@bloomberg.net> | 2019-05-30 09:30:12 +0100 |
---|---|---|
committer | bst-marge-bot <marge-bot@buildstream.build> | 2019-06-05 14:13:10 +0000 |
commit | efc8a4dbb54b63cd5412218e17c9fa9801356aff (patch) | |
tree | d351d2ca7974a988f649f1a91801547fb9932155 | |
parent | dad39f94ad147101efd166ddd6eadf6cadd8e806 (diff) | |
download | buildstream-efc8a4dbb54b63cd5412218e17c9fa9801356aff.tar.gz |
_scheduler/jobs/job: document send_message
-rw-r--r-- | src/buildstream/_scheduler/jobs/job.py | 16 |
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 # |