mirror of
https://github.com/hwchase17/langchain.git
synced 2025-06-19 13:23:35 +00:00
Add lock for using global config enum weak map (#11920)
<!-- Thank you for contributing to LangChain! Replace this entire comment with: - **Description:** a description of the change, - **Issue:** the issue # it fixes (if applicable), - **Dependencies:** any dependencies required for this change, - **Tag maintainer:** for a quicker response, tag the relevant maintainer (see below), - **Twitter handle:** we announce bigger features on Twitter. If your PR gets announced, and you'd like a mention, we'll gladly shout you out! Please make sure your PR is passing linting and testing before submitting. Run `make format`, `make lint` and `make test` to check this locally. See contribution guidelines for more information on how to write/run tests, lint, etc: https://github.com/langchain-ai/langchain/blob/master/.github/CONTRIBUTING.md If you're adding a new integration, please include: 1. a test for the integration, preferably unit tests that do not rely on network access, 2. an example notebook showing its use. It lives in `docs/extras` directory. If no one reviews your PR within a few days, please @-mention one of @baskaryan, @eyurtsev, @hwchase17. -->
This commit is contained in:
parent
2a8ded6c8c
commit
8b79cf9566
@ -1,6 +1,7 @@
|
||||
from __future__ import annotations
|
||||
|
||||
import enum
|
||||
import threading
|
||||
from abc import abstractmethod
|
||||
from typing import (
|
||||
Any,
|
||||
@ -270,6 +271,8 @@ _enums_for_spec: WeakValueDictionary[
|
||||
Type[StrEnum],
|
||||
] = WeakValueDictionary()
|
||||
|
||||
_enums_for_spec_lock = threading.Lock()
|
||||
|
||||
|
||||
class RunnableConfigurableAlternatives(DynamicRunnable[Input, Output]):
|
||||
which: ConfigurableField
|
||||
@ -280,12 +283,16 @@ class RunnableConfigurableAlternatives(DynamicRunnable[Input, Output]):
|
||||
|
||||
@property
|
||||
def config_specs(self) -> Sequence[ConfigurableFieldSpec]:
|
||||
with _enums_for_spec_lock:
|
||||
if which_enum := _enums_for_spec.get(self.which):
|
||||
pass
|
||||
else:
|
||||
which_enum = StrEnum( # type: ignore[call-overload]
|
||||
self.which.name or self.which.id,
|
||||
((v, v) for v in list(self.alternatives.keys()) + [self.default_key]),
|
||||
(
|
||||
(v, v)
|
||||
for v in list(self.alternatives.keys()) + [self.default_key]
|
||||
),
|
||||
)
|
||||
_enums_for_spec[self.which] = cast(Type[StrEnum], which_enum)
|
||||
return [
|
||||
@ -325,6 +332,7 @@ def make_options_spec(
|
||||
spec: Union[ConfigurableFieldSingleOption, ConfigurableFieldMultiOption],
|
||||
description: Optional[str],
|
||||
) -> ConfigurableFieldSpec:
|
||||
with _enums_for_spec_lock:
|
||||
if enum := _enums_for_spec.get(spec):
|
||||
pass
|
||||
else:
|
||||
|
Loading…
Reference in New Issue
Block a user