Allow compressing visible chunks before selection
Browse files
env/__pycache__/environment.cpython-314.pyc
CHANGED
|
Binary files a/env/__pycache__/environment.cpython-314.pyc and b/env/__pycache__/environment.cpython-314.pyc differ
|
|
|
env/environment.py
CHANGED
|
@@ -293,9 +293,10 @@ class RagContextOptimizerEnv:
|
|
| 293 |
return reward, {"event": "chunk_deselected", "chunk_id": chunk_id, "hybrid_score": score}
|
| 294 |
|
| 295 |
def _handle_compress(self, chunk_id: str, compression_ratio: float) -> tuple[float, dict[str, Any]]:
|
| 296 |
-
|
| 297 |
-
|
| 298 |
-
|
|
|
|
| 299 |
|
| 300 |
self._compression_ratios[chunk_id] = compression_ratio
|
| 301 |
is_relevant, score = self._is_relevant(chunk_id)
|
|
|
|
| 293 |
return reward, {"event": "chunk_deselected", "chunk_id": chunk_id, "hybrid_score": score}
|
| 294 |
|
| 295 |
def _handle_compress(self, chunk_id: str, compression_ratio: float) -> tuple[float, dict[str, Any]]:
|
| 296 |
+
chunk = self._chunk_map().get(chunk_id)
|
| 297 |
+
if chunk is None:
|
| 298 |
+
self._last_action_feedback = "chunk_not_found"
|
| 299 |
+
return -0.1, {"event": "chunk_not_found", "chunk_id": chunk_id}
|
| 300 |
|
| 301 |
self._compression_ratios[chunk_id] = compression_ratio
|
| 302 |
is_relevant, score = self._is_relevant(chunk_id)
|