Rajan Sharma commited on
Commit
6c48427
·
verified ·
1 Parent(s): ac62f48

Update data_registry.py

Browse files
Files changed (1) hide show
  1. data_registry.py +19 -9
data_registry.py CHANGED
@@ -1,17 +1,27 @@
1
  # data_registry.py
 
2
  import pandas as pd
 
3
 
4
  class DataRegistry:
5
  def __init__(self):
6
- self._data={}
7
 
8
- def add_path(self, path: str):
9
- if path.endswith(".csv"):
10
- self._data[path]=pd.read_csv(path)
11
- # future: add PDF/TXT/MD parsing
12
-
13
- def get(self, name: str):
14
- return self._data.get(name)
 
15
 
16
  def names(self):
17
- return list(self._data.keys())
 
 
 
 
 
 
 
 
1
  # data_registry.py
2
+ import os
3
  import pandas as pd
4
+ from typing import Dict, Optional
5
 
6
  class DataRegistry:
7
  def __init__(self):
8
+ self._frames: Dict[str, pd.DataFrame] = {}
9
 
10
+ def add_path(self, path: str) -> bool:
11
+ name = os.path.basename(path)
12
+ ext = os.path.splitext(name)[1].lower()
13
+ if ext == ".csv":
14
+ df = pd.read_csv(path)
15
+ self._frames[name] = df
16
+ return True
17
+ return False
18
 
19
  def names(self):
20
+ return list(self._frames.keys())
21
+
22
+ def get(self, name_or_path: str) -> Optional[pd.DataFrame]:
23
+ key = os.path.basename(name_or_path)
24
+ return self._frames.get(key)
25
+
26
+ def put_df(self, key: str, df):
27
+ self._frames[key] = df