Skip to content

Commit c876f5e

Browse files
committed
refactored to tuning_agent
1 parent 5358233 commit c876f5e

File tree

4 files changed

+18
-8
lines changed

4 files changed

+18
-8
lines changed

env/integtest_pg_conn.py

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,10 @@
55

66
import yaml
77

8-
from env.integtest_util import ENV_INTEGTESTS_DBGYM_CONFIG_FPATH, get_integtest_workspace_path
8+
from env.integtest_util import (
9+
ENV_INTEGTESTS_DBGYM_CONFIG_FPATH,
10+
get_integtest_workspace_path,
11+
)
912
from env.pg_conn import PostgresConn
1013
from util.pg import (
1114
DEFAULT_POSTGRES_PORT,

env/integtest_agent.py renamed to env/integtest_tuning_agent.py

Lines changed: 6 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,8 +1,11 @@
11
import subprocess
22
import unittest
33

4-
from env.agent import TuningAgent
5-
from env.integtest_util import ENV_INTEGTESTS_DBGYM_CONFIG_FPATH, get_integtest_workspace_path
4+
from env.integtest_util import (
5+
ENV_INTEGTESTS_DBGYM_CONFIG_FPATH,
6+
get_integtest_workspace_path,
7+
)
8+
from env.tuning_agent import TuningAgent
69
from util.workspace import DBGymConfig
710

811

@@ -25,4 +28,4 @@ def test_test(self) -> None:
2528

2629

2730
if __name__ == "__main__":
28-
unittest.main()
31+
unittest.main()

env/integtest_util.py

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -2,11 +2,10 @@
22

33
import yaml
44

5-
65
ENV_INTEGTESTS_DBGYM_CONFIG_FPATH = Path("env/env_integtests_dbgym_config.yaml")
76

87

98
def get_integtest_workspace_path() -> Path:
109
with open(ENV_INTEGTESTS_DBGYM_CONFIG_FPATH) as f:
1110
return Path(yaml.safe_load(f)["dbgym_workspace_path"])
12-
assert False
11+
assert False

env/agent.py renamed to env/tuning_agent.py

Lines changed: 7 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,12 @@
22

33

44
class DBMSConfig:
5-
def __init__(self, indexes: list[str], sysknobs: dict[str, str], query_knobs: dict[str, list[str]]) -> None:
5+
def __init__(
6+
self,
7+
indexes: list[str],
8+
sysknobs: dict[str, str],
9+
query_knobs: dict[str, list[str]],
10+
) -> None:
611
self.indexes = indexes
712
self.sysknobs = sysknobs
813
self.query_knobs = query_knobs
@@ -20,4 +25,4 @@ def step(self) -> None:
2025

2126
# Subclasses should override this function.
2227
def _step(self) -> DBMSConfig:
23-
raise NotImplementedError
28+
raise NotImplementedError

0 commit comments

Comments
 (0)