Threa

load.py

        for args in tables_for_load:
            thread = FileLoaderWorker(*args)
            thread.start()

        completed = 0
        while completed < len(tables_for_load):
            try:
                response, exception = response_queue.get(block=False, timeout=0.1)

                if exception:
                    raise exception

                if response:
                    completed += 1

            except Queue.Empty:
                pass  # Don't do anything if the queue is empty