Method run

tests/explorer/workflow_test.py:88–107

(self)

        self.run_id_base = run_id_base

    def run(self):
        exps = []
        if self.output_format == "json":
            import json

            for i in range(self.repeat_times):
                exp = Experience(tokens=Tensor([0, 1, 2, 3]), prompt_length=1)
                exp.response_text = json.dumps(self.obj)
                exps.append(exp)
            return exps
        elif self.output_format == "yaml":
            import yaml

            for i in range(self.repeat_times):
                exp = Experience(tokens=Tensor([0, 1, 2, 3]), prompt_length=1)
                exp.response_text = yaml.safe_dump(self.obj)
                exps.append(exp)
            return exps
        else:
            raise ValueError("Invalid output format")


class DummyAsyncWorkflow(Workflow):