From 7e9bb510c67268011ea0c833547625aec9d50050 Mon Sep 17 00:00:00 2001 From: Sayan Chowdhury Date: Jun 04 2019 22:29:35 +0000 Subject: Fix #7: Lessen the search area for a topic. Signed-off-by: Sayan Chowdhury --- diff --git a/joystick/consumers/fedora_messaging_consumer.py b/joystick/consumers/fedora_messaging_consumer.py index 18d9312..8ec501e 100644 --- a/joystick/consumers/fedora_messaging_consumer.py +++ b/joystick/consumers/fedora_messaging_consumer.py @@ -24,6 +24,9 @@ class JoyStickController(object): self.aws_secret_access_key = self.config['aws_secret_access_key'] self.valid_status = ('FINISHED_INCOMPLETE', 'FINISHED') self.regions = self.config['regions'] + self.environment = self.config['environment'] + self.topic = "org.fedoraproject.%s.pungi.compose.status.change" % ( + self.environment) def run_command(self, command): _log.info("Starting the command: %r" % command) @@ -54,8 +57,7 @@ class JoyStickController(object): else: msg_info = body['msg'] - - if topic.endswith("pungi.compose.status.change"): + if topic == self.topic: _log.debug("Processing %r" % (msg.id)) if msg_info['status'] not in self.valid_status: _log.debug("%s is not a valid status" % msg_info["status"])