May 2018
Beginner to intermediate
452 pages
11h 26m
English
To make sure that the Message objects are the only thing that get put in our queue, let's create a wrapper method in CorporateRestUploaderWithQueue that will create the object and place it in the queue. We'll use this for all communications to the queue.
Call it _putmessage():
def _putmessage(self, status, subject, body):
self.queue.put(Message(status, subject, body))
Now, in the run() method, let's add some status messages:
def run(self, *args, **kwargs): session = requests.session() self._putmessage( 'info', 'Authenticating', 'Authenticating to {} as {}'.format( self.auth_url, self.username)) ... # Before upload request self._putmessage( 'info', 'Starting Upload', 'Starting upload of {} to {}'.format( ...