Minor bug fix

globus-labs · Dec 11, 2024 · 32ee2aa · 32ee2aa
1 parent eeac24e
commit 32ee2aa
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/mofa/proxyqueue.py b/mofa/proxyqueue.py
@@ -132,11 +132,11 @@ def connect_request_producer(self):
     def connect_request_consumer(self):
         if not isinstance(self.request_consumer, StreamConsumer):
 
+            request_topic = f"{self.prefix}_requests"
             if ENGINE == "octopus":
                 consumer = Consumer(
                     confluent_consumer_conf(self.group_id, self.auto_offset_reset)
                 )
-                request_topic = f"{self.prefix}_requests"
                 # consumer.subscribe([request_topic])
                 topic_partition = TopicPartition(request_topic, partition=0)
                 consumer.assign([topic_partition])