def join(self):
        # waiting for all tasks to complete
        log.debug('Waiting all tasks to be completed...')
        print "Waiting for all tasks to be completed..."
        while 0 > self.task_count:
            pass
        self.worker_pool.close()
        self.worker_pool.join()
        log.debug('All tasks completed!')
        print "All tasks completed!"
dataset/ETHPy150Open kencoken/imsearch-tools/imsearchtools/process/callback_handler_multiprocessing.py/CallbackHandler.join/swapped operands of `>`