Skip to content

Commit 2f12ead

Browse files
committed
Avoid warnings
1 parent 1007849 commit 2f12ead

File tree

2 files changed

+7
-3
lines changed

2 files changed

+7
-3
lines changed

python/cog/server/scope.py

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -23,6 +23,10 @@ def current_scope() -> Scope:
2323
category=ExperimentalFeatureWarning,
2424
stacklevel=1,
2525
)
26+
return _get_current_scope()
27+
28+
29+
def _get_current_scope() -> Scope:
2630
s = _current_scope.get()
2731
if s is None:
2832
raise RuntimeError("No scope available")
@@ -40,7 +44,7 @@ def scope(sc: Scope) -> Generator[None, None, None]:
4044

4145
@contextmanager
4246
def evolve_scope(**kwargs: Any) -> Generator[None, None, None]:
43-
new_scope = evolve(current_scope(), **kwargs)
47+
new_scope = evolve(_get_current_scope(), **kwargs)
4448
s = _current_scope.set(new_scope)
4549
try:
4650
yield

python/cog/server/worker.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -57,7 +57,7 @@
5757
InvalidStateException,
5858
)
5959
from .helpers import SimpleStreamRedirector, StreamRedirector
60-
from .scope import Scope, current_scope, evolve_scope, scope
60+
from .scope import Scope, _get_current_scope, evolve_scope, scope
6161

6262
if PYDANTIC_V2:
6363
from .helpers import unwrap_pydantic_serialization_iterators
@@ -480,7 +480,7 @@ def record_metric(self, name: str, value: Union[float, int]) -> None:
480480
@property
481481
def _current_tag(self) -> Optional[str]:
482482
if self._has_async_predictor:
483-
return current_scope()._tag
483+
return _get_current_scope()._tag
484484
return self._sync_tag
485485

486486
def _load_predictor(self) -> Optional[BasePredictor]:

0 commit comments

Comments
 (0)