Global variables implementation

.github/workflows/lint.yml

@@ -14,15 +14,14 @@ on:
  - "src/backend/**"
 
 env:
- POETRY_VERSION: "1.7.0"
+ POETRY_VERSION: "1.8.2"
 
 jobs:
  lint:
  runs-on: ubuntu-latest
  strategy:
  matrix:
  python-version:
- - "3.9"
  - "3.10"
  - "3.11"
  steps:

.github/workflows/test.yml

@@ -15,7 +15,7 @@ on:
  - "src/backend/**"
 
 env:
- POETRY_VERSION: "1.5.0"
+ POETRY_VERSION: "1.8.2"
 
 jobs:
  build:

Makefile

@@ -32,7 +32,7 @@ format:
 
 lint:
  make install_backend
- poetry run mypy src/backend
+ poetry run mypy --namespace-packages -p "langflow"
  poetry run ruff . --fix
 
 install_frontend:

base.Dockerfile

@@ -23,7 +23,7 @@ ENV PYTHONUNBUFFERED=1 \
  \
  # poetry
  # https://python-poetry.org/docs/configuration/#using-environment-variables
- POETRY_VERSION=1.7.1 \
+ POETRY_VERSION=1.8.2 \
  # make poetry install to this location
  POETRY_HOME="/opt/poetry" \
  # make poetry create the virtual environment in the project's root

build_and_push.Dockerfile

@@ -23,7 +23,7 @@ ENV PYTHONUNBUFFERED=1 \
  \
  # poetry
  # https://python-poetry.org/docs/configuration/#using-environment-variables
- POETRY_VERSION=1.7.1 \
+ POETRY_VERSION=1.8.2 \
  # make poetry install to this location
  POETRY_HOME="/opt/poetry" \
  # make poetry create the virtual environment in the project's root

deploy/base.Dockerfile

@@ -23,7 +23,7 @@ ENV PYTHONUNBUFFERED=1 \
  \
  # poetry
  # https://python-poetry.org/docs/configuration/#using-environment-variables
- POETRY_VERSION=1.5.1 \
+ POETRY_VERSION=1.8.2 \
  # make poetry install to this location
  POETRY_HOME="/opt/poetry" \
  # make poetry create the virtual environment in the project's root

src/backend/base/langflow/__main__.py

@@ -285,7 +285,12 @@ def run_langflow(host, port, log_level, options, app):
  # MacOS requires an env variable to be set to use gunicorn
  import uvicorn
 
- uvicorn.run(app, host=host, port=port, log_level=log_level)
+ uvicorn.run(
+ app,
+ host=host,
+ port=port,
+ log_level=log_level.lower(),
+ )
  else:
  from langflow.server import LangflowApplication
 

src/backend/base/langflow/alembic/versions/1a110b568907_replace_credential_table_with_variable.py

@@ -0,0 +1,65 @@
+"""Replace Credential table with Variable
+
+Revision ID: 1a110b568907
+Revises: 63b9c451fd30
+Create Date: 2024-03-25 09:40:02.743453
+
+"""
+from typing import Sequence, Union
+
+import sqlalchemy as sa
+import sqlmodel
+from alembic import op
+from sqlalchemy.engine.reflection import Inspector
+
+# revision identifiers, used by Alembic.
+revision: str = "1a110b568907"
+down_revision: Union[str, None] = "63b9c451fd30"
+branch_labels: Union[str, Sequence[str], None] = None
+depends_on: Union[str, Sequence[str], None] = None
+
+
+def upgrade() -> None:
+ conn = op.get_bind()
+ inspector = Inspector.from_engine(conn) # type: ignore
+ table_names = inspector.get_table_names()
+ # ### commands auto generated by Alembic - please adjust! ###
+ if "variable" not in table_names:
+ op.create_table(
+ "variable",
+ sa.Column("name", sqlmodel.sql.sqltypes.AutoString(), nullable=True),
+ sa.Column("value", sqlmodel.sql.sqltypes.AutoString(), nullable=True),
+ sa.Column("type", sqlmodel.sql.sqltypes.AutoString(), nullable=True),
+ sa.Column("id", sqlmodel.sql.sqltypes.GUID(), nullable=False),
+ sa.Column("created_at", sa.DateTime(), nullable=False),
+ sa.Column("updated_at", sa.DateTime(), nullable=True),
+ sa.Column("user_id", sqlmodel.sql.sqltypes.GUID(), nullable=False),
+ sa.ForeignKeyConstraint(["user_id"], ["user.id"], name="fk_variable_user_id"),
+ sa.PrimaryKeyConstraint("id"),
+ )
+ if "credential" in table_names:
+ op.drop_table("credential")
+ # ### end Alembic commands ###
+
+
+def downgrade() -> None:
+ conn = op.get_bind()
+ inspector = Inspector.from_engine(conn) # type: ignore
+ table_names = inspector.get_table_names()
+ # ### commands auto generated by Alembic - please adjust! ###
+ if "credential" not in table_names:
+ op.create_table(
+ "credential",
+ sa.Column("name", sa.VARCHAR(), nullable=True),
+ sa.Column("value", sa.VARCHAR(), nullable=True),
+ sa.Column("provider", sa.VARCHAR(), nullable=True),
+ sa.Column("user_id", sa.CHAR(length=32), nullable=False),
+ sa.Column("id", sa.CHAR(length=32), nullable=False),
+ sa.Column("created_at", sa.DATETIME(), nullable=False),
+ sa.Column("updated_at", sa.DATETIME(), nullable=True),
+ sa.ForeignKeyConstraint(["user_id"], ["user.id"], name="fk_credential_user_id"),
+ sa.PrimaryKeyConstraint("id"),
+ )
+ if "variable" in table_names:
+ op.drop_table("variable")
+ # ### end Alembic commands ###