def pass_end_signal()

in ees_microsoft_outlook/base_indexing_command.py [0:0]

• 6 lines of code
• 2 McCabe index (conditional complexity)

    def pass_end_signal(self, queue):
        """This method pass end signal into queue
        :param queue: Shared queue to pass end signal
        """
        enterprise_thread_count = self.config.get_value(
            "enterprise_search_sync_thread_count"
        )
        for _ in range(enterprise_thread_count):
            queue.end_signal()