|
10 | 10 | from flag_engine.identities.models import IdentityModel |
11 | 11 | from flag_engine.identities.traits.models import TraitModel |
12 | 12 | from flag_engine.identities.traits.types import TraitValue |
13 | | -from flag_engine.segments.evaluator import get_identity_segments |
| 13 | +from flag_engine.segments.evaluator import get_context_segments |
| 14 | +from flag_engine.context.mappers import map_environment_identity_to_context |
14 | 15 | from requests.adapters import HTTPAdapter |
15 | 16 | from requests.utils import default_user_agent |
16 | 17 | from urllib3 import Retry |
@@ -280,10 +281,16 @@ def get_identity_segments( |
280 | 281 |
|
281 | 282 | traits = traits or {} |
282 | 283 | identity_model = self._get_identity_model(identifier, **traits) |
283 | | - segment_models = get_identity_segments( |
284 | | - environment=self._environment, identity=identity_model |
| 284 | + context = map_environment_identity_to_context( |
| 285 | + environment=self._environment, |
| 286 | + identity=identity_model, |
| 287 | + override_traits=None, |
285 | 288 | ) |
286 | | - return [Segment(id=sm.id, name=sm.name) for sm in segment_models] |
| 289 | + segments = get_context_segments( |
| 290 | + context=context, |
| 291 | + segments=self._environment.project.segments, |
| 292 | + ) |
| 293 | + return [Segment(id=sm.id, name=sm.name) for sm in segments] |
287 | 294 |
|
288 | 295 | def update_environment(self) -> None: |
289 | 296 | try: |
|
0 commit comments