in provider/consumer.py [0:0]
def setDesiredState(self, newState):
logging.info('[{}] Request to set desiredState to {}'.format(self.trigger, newState))
if self.sharedDictionary['desiredState'] == Consumer.State.Dead and newState != Consumer.State.Dead:
logging.info('[{}] Asking to kill a consumer that is already marked for death. Doing nothing.'.format(self.trigger))
return
else:
logging.info('[{}] Setting desiredState to: {}'.format(self.trigger, newState))
self.sharedDictionary['desiredState'] = newState