NickNYU commited on
Commit
e98e74e
·
1 Parent(s): 25be1c6

Update xpipe_wiki/robot_manager.py

Browse files
Files changed (1) hide show
  1. xpipe_wiki/robot_manager.py +19 -5
xpipe_wiki/robot_manager.py CHANGED
@@ -16,29 +16,43 @@ class XPipeWikiRobot(ABC):
16
  pass
17
 
18
 
19
- @dataclasses
20
  class AzureOpenAIXPipeWikiRobot(XPipeWikiRobot):
21
  query_engine: BaseQueryEngine
22
 
 
 
 
 
23
  def ask(self, question: str) -> Any:
24
  return self.query_engine.query(question)
25
 
26
 
27
  class XPipeWikiRobotManager(Lifecycle):
28
-
29
  @abstractmethod
30
  def get_robot(self) -> XPipeWikiRobot:
31
  pass
32
 
33
 
34
- @dataclasses
35
  class AzureXPipeWikiRobotManager(XPipeWikiRobotManager):
36
  service_context_manager: ServiceContextManager
37
  storage_context_manager: StorageContextManager
38
 
 
 
 
 
 
 
 
 
 
39
  def get_robot(self) -> XPipeWikiRobot:
40
- index = load_index_from_storage(storage_context=self.storage_context_manager.get_storage_context())
41
- query_engine = index.as_query_engine(service_context=self.service_context_manager.get_service_context())
 
 
 
 
42
  return AzureOpenAIXPipeWikiRobot(query_engine)
43
 
44
  def do_init(self) -> None:
 
16
  pass
17
 
18
 
 
19
  class AzureOpenAIXPipeWikiRobot(XPipeWikiRobot):
20
  query_engine: BaseQueryEngine
21
 
22
+ def __init__(self, query_engine: BaseQueryEngine) -> None:
23
+ super().__init__()
24
+ self.query_engine = query_engine
25
+
26
  def ask(self, question: str) -> Any:
27
  return self.query_engine.query(question)
28
 
29
 
30
  class XPipeWikiRobotManager(Lifecycle):
 
31
  @abstractmethod
32
  def get_robot(self) -> XPipeWikiRobot:
33
  pass
34
 
35
 
 
36
  class AzureXPipeWikiRobotManager(XPipeWikiRobotManager):
37
  service_context_manager: ServiceContextManager
38
  storage_context_manager: StorageContextManager
39
 
40
+ def __init__(
41
+ self,
42
+ service_context_manager: ServiceContextManager,
43
+ storage_context_manager: StorageContextManager,
44
+ ) -> None:
45
+ super().__init__()
46
+ self.service_context_manager = service_context_manager
47
+ self.storage_context_manager = storage_context_manager
48
+
49
  def get_robot(self) -> XPipeWikiRobot:
50
+ index = load_index_from_storage(
51
+ storage_context=self.storage_context_manager.get_storage_context()
52
+ )
53
+ query_engine = index.as_query_engine(
54
+ service_context=self.service_context_manager.get_service_context()
55
+ )
56
  return AzureOpenAIXPipeWikiRobot(query_engine)
57
 
58
  def do_init(self) -> None: