diff --git a/src/backend/base/langflow/base/tools/component_tool.py b/src/backend/base/langflow/base/tools/component_tool.py index d80fd33bb..2580682f8 100644 --- a/src/backend/base/langflow/base/tools/component_tool.py +++ b/src/backend/base/langflow/base/tools/component_tool.py @@ -17,12 +17,12 @@ if TYPE_CHECKING: from langflow.io import Output -def _get_input_type(input: InputTypes): - if input.input_types: - if len(input.input_types) == 1: - return input.input_types[0] - return " | ".join(input.input_types) - return input.field_type +def _get_input_type(_input: InputTypes): + if _input.input_types: + if len(_input.input_types) == 1: + return _input.input_types[0] + return " | ".join(_input.input_types) + return _input.field_type def build_description(component: Component, output: Output): diff --git a/src/backend/base/langflow/components/prototypes/RunnableExecutor.py b/src/backend/base/langflow/components/prototypes/RunnableExecutor.py index 4f50b0ffb..2c251e446 100644 --- a/src/backend/base/langflow/components/prototypes/RunnableExecutor.py +++ b/src/backend/base/langflow/components/prototypes/RunnableExecutor.py @@ -130,8 +130,8 @@ class RunnableExecComponent(Component): self.status = status return result_value - async def astream_events(self, input): - async for event in self.runnable.astream_events(input, version="v1"): + async def astream_events(self, runnable_input): + async for event in self.runnable.astream_events(runnable_input, version="v1"): if event.get("event") != "on_chat_model_stream": continue diff --git a/src/backend/base/langflow/services/database/models/user/crud.py b/src/backend/base/langflow/services/database/models/user/crud.py index f329d4667..bb9b1cfde 100644 --- a/src/backend/base/langflow/services/database/models/user/crud.py +++ b/src/backend/base/langflow/services/database/models/user/crud.py @@ -14,8 +14,8 @@ def get_user_by_username(db: Session, username: str) -> User | None: return db.exec(select(User).where(User.username == username)).first() -def get_user_by_id(db: Session, id: UUID) -> User | None: - return db.exec(select(User).where(User.id == id)).first() +def get_user_by_id(db: Session, user_id: UUID) -> User | None: + return db.exec(select(User).where(User.id == user_id)).first() def update_user(user_db: User | None, user: UserUpdate, db: Session = Depends(get_session)) -> User: diff --git a/src/backend/base/langflow/services/telemetry/opentelemetry.py b/src/backend/base/langflow/services/telemetry/opentelemetry.py index 614a8901b..ea15f7e13 100644 --- a/src/backend/base/langflow/services/telemetry/opentelemetry.py +++ b/src/backend/base/langflow/services/telemetry/opentelemetry.py @@ -12,7 +12,7 @@ from opentelemetry.metrics._internal.instrument import Counter, Histogram, UpDow from opentelemetry.sdk.metrics import MeterProvider from opentelemetry.sdk.resources import Resource -# a default OpenTelelmetry meter name +# a default OpenTelemetry meter name langflow_meter_name = "langflow" """ @@ -64,13 +64,13 @@ class Metric: self, name: str, description: str, - type: MetricType, + metric_type: MetricType, labels: dict[str, bool], unit: str = "", ): self.name = name self.description = description - self.type = type + self.type = metric_type self.unit = unit self.labels = labels self.mandatory_labels = [label for label, required in labels.items() if required] @@ -114,7 +114,7 @@ class OpenTelemetry(metaclass=ThreadSafeSingletonMetaUsingWeakref): _metrics_registry: dict[str, Metric] = {} def _add_metric(self, name: str, description: str, unit: str, metric_type: MetricType, labels: dict[str, bool]): - metric = Metric(name=name, description=description, type=metric_type, unit=unit, labels=labels) + metric = Metric(name=name, description=description, metric_type=metric_type, unit=unit, labels=labels) self._metrics_registry[name] = metric if labels is None or len(labels) == 0: msg = "Labels must be provided for the metric upon registration" diff --git a/src/backend/base/langflow/services/variable/kubernetes_secrets.py b/src/backend/base/langflow/services/variable/kubernetes_secrets.py index b270bd826..c541b341e 100644 --- a/src/backend/base/langflow/services/variable/kubernetes_secrets.py +++ b/src/backend/base/langflow/services/variable/kubernetes_secrets.py @@ -164,31 +164,31 @@ def encode_user_id(user_id: UUID | str) -> str: return f"uuid-{str(user_id).lower()}"[:253] # Convert string to lowercase - id = str(user_id).lower() + _user_id = str(user_id).lower() # If the user_id looks like an email, replace @ and . with allowed characters - if "@" in id or "." in id: - id = id.replace("@", "-at-").replace(".", "-dot-") + if "@" in _user_id or "." in _user_id: + _user_id = _user_id.replace("@", "-at-").replace(".", "-dot-") # Encode the user_id to base64 # encoded = base64.b64encode(user_id.encode("utf-8")).decode("utf-8") # Replace characters not allowed in Kubernetes names - id = id.replace("+", "-").replace("/", "_").rstrip("=") + _user_id = _user_id.replace("+", "-").replace("/", "_").rstrip("=") # Ensure the name starts with an alphanumeric character - if not id[0].isalnum(): - id = "a-" + id + if not _user_id[0].isalnum(): + _user_id = "a-" + _user_id # Truncate to 253 characters (Kubernetes name length limit) - id = id[:253] + _user_id = _user_id[:253] - if not all(c.isalnum() or c in "-_" for c in id): - msg = f"Invalid user_id: {id}" + if not all(c.isalnum() or c in "-_" for c in _user_id): + msg = f"Invalid user_id: {_user_id}" raise ValueError(msg) # Ensure the name ends with an alphanumeric character - while not id[-1].isalnum(): - id = id[:-1] + while not _user_id[-1].isalnum(): + _user_id = _user_id[:-1] - return id + return _user_id diff --git a/src/backend/base/langflow/utils/util.py b/src/backend/base/langflow/utils/util.py index 48d760966..3839aaaad 100644 --- a/src/backend/base/langflow/utils/util.py +++ b/src/backend/base/langflow/utils/util.py @@ -142,7 +142,7 @@ def get_base_classes(cls): bases = cls.__bases__ result = [] for base in bases: - if any(type in base.__module__ for type in ["pydantic", "abc"]): + if any(_type in base.__module__ for _type in ["pydantic", "abc"]): continue result.append(base.__name__) base_classes = get_base_classes(base) diff --git a/src/backend/base/pyproject.toml b/src/backend/base/pyproject.toml index b91d978ad..277b93ad5 100644 --- a/src/backend/base/pyproject.toml +++ b/src/backend/base/pyproject.toml @@ -157,6 +157,7 @@ flake8-bugbear.extend-immutable-calls = [ "typer.Option", ] select = [ + "A", "ASYNC", "B", "C4",