use copy of list

Observation-Management-Service · Dec 1, 2023 · db30936 · db30936
1 parent b25345e
commit db30936
Showing 1 changed file with 3 additions and 4 deletions.
diff --git a/mqclient/broker_clients/rabbitmq.py b/mqclient/broker_clients/rabbitmq.py
@@ -8,7 +8,6 @@
     AsyncGenerator,
     AsyncIterator,
     Dict,
-    Iterator,
     List,
     Optional,
     Tuple,
@@ -385,7 +384,7 @@ def _get_msg():
         # inf_channels_gen = infinite_loop_over_channels()
         # channel = next(inf_channels_gen)  # always called manually
         # n_nonempty_channels_remaining = len(self.channels)  # assume all are non-empty
-        remaining_channels = self.active_channels  # start with all
+        remaining_channels = [c for c in self.active_channels]  # start with all
         channel = remaining_channels[0]  # TODO - use by priority?
 
         while True:
@@ -420,7 +419,7 @@ def _get_msg():
                     # if this was the reserve channel, move it to active channels
                     self.active_channels.append(self.reserve_channel)
                     self.reserve_channel = None  # no need to open a new one now
-                remaining_channels = self.active_channels  # reset!
+                remaining_channels = [c for c in self.active_channels]  # reset!
                 yield msg
             # DEAL WITH EMPTY CHANNEL (didn't get a message)
             else:
@@ -430,7 +429,7 @@ def _get_msg():
                     # this means our reserve channel came up empty,
                     # so there's REALLY nothing in the queue
                     LOGGER.debug(log_msgs.GETMSG_NO_MESSAGE)
-                    remaining_channels = self.active_channels  # reset!
+                    remaining_channels = [c for c in self.active_channels]  # reset!
                     yield None
                 else:
                     remaining_channels.remove(channel)