@@ -737,9 +737,9 @@ def push_to_input_queue(
737737 data , source_worker = source_worker , destination_worker = worker .name
738738 )
739739 elif workers :
740- random .choice (workers ). push_to_input_queue (
741- data , source_worker = source_worker
742- )
740+ random .choice ( # nosec: B311 # We aren't doing encryption here.
741+ workers
742+ ). push_to_input_queue ( data , source_worker = source_worker )
743743
744744 logger .debug ("%s-manager | Pushed to input queue: %r" , self .STD_NAME , data )
745745
@@ -790,9 +790,9 @@ def push_to_output_queues(
790790 destination_worker = worker .name ,
791791 )
792792 elif workers :
793- random .choice (workers ). push_to_output_queues (
794- data , source_worker = source_worker
795- )
793+ random .choice ( # nosec: B311 # We aren't doing encryption here.
794+ workers
795+ ). push_to_output_queues ( data , source_worker = source_worker )
796796 else :
797797 for manager in self .dependent_managers :
798798 # Their input queue is our output queue.
@@ -839,9 +839,9 @@ def push_to_configuration_queue(
839839 data , source_worker = source_worker , destination_worker = worker .name
840840 )
841841 elif workers :
842- random .choice (workers ). push_to_configuration_queue (
843- data , source_worker = source_worker
844- )
842+ random .choice ( # nosec: B311 # We aren't doing encryption here.
843+ workers
844+ ). push_to_configuration_queue ( data , source_worker = source_worker )
845845
846846 logger .debug (
847847 "%s-manager | Pushed to configuration queue: %r" , self .STD_NAME , data
0 commit comments