|
14 | 14 | from rdagent.components.coder.data_science.pipeline.exp import PipelineTask |
15 | 15 | from rdagent.components.coder.data_science.raw_data_loader import DataLoaderCoSTEER |
16 | 16 | from rdagent.components.coder.data_science.raw_data_loader.exp import DataLoaderTask |
| 17 | +from rdagent.components.coder.data_science.share.doc import DocDev |
17 | 18 | from rdagent.components.coder.data_science.workflow import WorkflowCoSTEER |
18 | 19 | from rdagent.components.coder.data_science.workflow.exp import WorkflowTask |
19 | 20 | from rdagent.components.workflow.conf import BasePropSetting |
@@ -64,6 +65,8 @@ def __init__(self, PROP_SETTING: BasePropSetting): |
64 | 65 | self.pipeline_coder = PipelineCoSTEER(scen) |
65 | 66 |
|
66 | 67 | self.runner = DSCoSTEERRunner(scen) |
| 68 | + if DS_RD_SETTING.enable_doc_dev: |
| 69 | + self.docdev = DocDev(scen) |
67 | 70 | # self.summarizer: Experiment2Feedback = import_class(PROP_SETTING.summarizer)(scen) |
68 | 71 | # logger.log_object(self.summarizer, tag="summarizer") |
69 | 72 |
|
@@ -109,7 +112,9 @@ def running(self, prev_out: dict[str, Any]): |
109 | 112 | if exp.is_ready_to_run(): |
110 | 113 | new_exp = self.runner.develop(exp) |
111 | 114 | logger.log_object(new_exp) |
112 | | - return new_exp |
| 115 | + exp = new_exp |
| 116 | + if DS_RD_SETTING.enable_doc_dev: |
| 117 | + self.docdev.develop(exp) |
113 | 118 | return exp |
114 | 119 |
|
115 | 120 | def feedback(self, prev_out: dict[str, Any]) -> ExperimentFeedback: |
|
0 commit comments