Method run_task

tool/FlashRAG/webui/runner.py:492–523

(queue)

        DONE_MARKER = "__DONE__"

        def run_task(queue):
            original_stdout = sys.stdout
            original_stderr = sys.stderr
            sys.stdout = TeeStream(queue, original_stdout)
            sys.stderr = TeeStream(queue, original_stderr)

            # Load config
            args = self._parse_pipeline_args(data)
            args.update(self._parse_evaluate_args(data))
            args["split"] = [args["dataset_split"]]
            args["disable_save"] = True
            config = Config(config_dict=args)
            print("Finish loading config...")

            print("# Args")
            print(json.dumps(args, indent=4, ensure_ascii=False))

            # Load data
            dataset = get_dataset(config)[args["dataset_split"]]
            print("Dataset info:")
            print(dataset)

            # Load pipeline
            self._prepare_pipeline(config, progress)
            self.pipeline.evaluator = Evaluator(config)

            # Run evaluation process
            result = self.pipeline.run(dataset)

            sys.stdout = original_stdout
            sys.stderr = original_stderr
            queue.put(DONE_MARKER)

        message_queue = Queue()
        output_history = "```bash"