🔧 chore(__main__.py): update Typer configuration to treat no arguments as help to improve usability

🔧 chore(__main__.py): update docstring for run() function to improve clarity
🔧 chore(__main__.py): update docstring for superuser() function to improve clarity
🔧 chore(__main__.py): update migration() function to default to test mode
🔧 chore(manager.py): remove unnecessary logging of database URL in run_migrations() function
🔧 chore(manager.py): add missing import statement for logger in check_celery_availability() function
🔧 chore(manager.py): update configure() function to be called in check_celery_availability() function
🔧 chore(logger.py): update configure() function to use environment variable for log level if available
🔧 chore(logger.py): update configure() function to use default log file location if not provided

src/backend/langflow/__main__.py

@@ -23,7 +23,7 @@ from rich.table import Table
 
 console = Console()
 
-app = typer.Typer()
+app = typer.Typer(no_args_is_help=True)
 
 
 def get_number_of_workers(workers=None):
@@ -141,7 +141,7 @@ def run(
     ),
 ):
     """
-    Run the Langflow server.
+    Run the Langflow.
     """
     # override env variables with .env file
     if env_file:
@@ -299,7 +299,14 @@ def superuser(
     password: str = typer.Option(
         ..., prompt=True, hide_input=True, help="Password for the superuser."
     ),
+    log_level: str = typer.Option(
+        "critical", help="Logging level.", envvar="LANGFLOW_LOG_LEVEL"
+    ),
 ):
+    """
+    Create a superuser.
+    """
+    configure(log_level=log_level)
     initialize_services()
     db_service = get_db_service()
     with session_getter(db_service) as session:
@@ -321,7 +328,10 @@ def superuser(
 
 
 @app.command()
-def migration(test: bool = typer.Option(False, help="Run migrations in test mode.")):
+def migration(test: bool = typer.Option(True, help="Run migrations in test mode.")):
+    """
+    Run or test migrations.
+    """
     initialize_services()
     db_service = get_db_service()
     if not test:

src/backend/langflow/services/database/manager.py

@@ -94,9 +94,7 @@ class DatabaseService(Service):
         return True
 
     def run_migrations(self):
-        logger.info(
+        logger.info(f"Running DB migrations in {self.script_location}")
-            f"Running DB migrations in {self.script_location} on {self.database_url}"
-        )
         alembic_cfg = Config()
         alembic_cfg.set_main_option("script_location", str(self.script_location))
         alembic_cfg.set_main_option("sqlalchemy.url", self.database_url)

src/backend/langflow/services/task/manager.py

@@ -1,4 +1,5 @@
 from typing import Any, Callable, Coroutine, Union
+from langflow.utils.logger import configure
 from loguru import logger
 from langflow.services.base import Service
 from langflow.services.task.backends.anyio import AnyIOBackend
@@ -7,18 +8,19 @@ from langflow.services.task.utils import get_celery_worker_status
 
 
 def check_celery_availability():
-    from langflow.worker import celery_app
-
     try:
+        from langflow.worker import celery_app
+
         status = get_celery_worker_status(celery_app)
         logger.debug(f"Celery status: {status}")
-    except Exception as e:
+    except Exception as exc:
-        logger.error(f"An error occurred: {e}")
+        logger.debug(f"Celery not available: {exc}")
         status = {"availability": None}
     return status
 
 
 try:
+    configure()
     status = check_celery_availability()
 
     USE_CELERY = status.get("availability") is not None

src/backend/langflow/utils/logger.py

@@ -2,12 +2,34 @@ from typing import Optional
 from loguru import logger
 from pathlib import Path
 from rich.logging import RichHandler
+import os
+import orjson
+import appdirs
 
 
-def configure(log_level: str = "DEBUG", log_file: Optional[Path] = None):
+def serialize(record):
-    log_format = "<green>{time:HH:mm:ss}</green> - <level>{level: <8}</level> - <level>{message}</level>"
+    subset = {
+        "timestamp": record["time"].timestamp(),
+        "message": record["message"],
+        "level": record["level"].name,
+        "module": record["module"],
+    }
+    return orjson.dumps(subset)
+
+
+def patching(record):
+    record["extra"]["serialized"] = serialize(record)
+
+
+def configure(log_level: str = "INFO", log_file: Optional[Path] = None):
+    if os.getenv("LANGFLOW_LOG_LEVEL"):
+        log_level = os.getenv("LANGFLOW_LOG_LEVEL")
+    # Human-readable
+    log_format = "<green>{time:YYYY-MM-DD HH:mm:ss}</green> - <level>{level: <8}</level> - {module} - <level>{message}</level>"
+
+    # log_format = log_format_dev if log_level.upper() == "DEBUG" else log_format_prod
     logger.remove()  # Remove default handlers
-
+    logger.patch(patching)
     # Configure loguru to use RichHandler
     logger.configure(
         handlers=[
@@ -19,17 +41,21 @@ def configure(log_level: str = "DEBUG", log_file: Optional[Path] = None):
         ]
     )
 
-    if log_file:
+    if not log_file:
-        log_file = Path(log_file)
+        cache_dir = Path(appdirs.user_cache_dir("langflow"))
-        log_file.parent.mkdir(parents=True, exist_ok=True)
+        log_file = cache_dir / "langflow.log"
 
-        logger.add(
+    log_file = Path(log_file)
-            sink=str(log_file),
+    log_file.parent.mkdir(parents=True, exist_ok=True)
-            level=log_level.upper(),
-            format=log_format,
-            rotation="10 MB",  # Log rotation based on file size
-        )
 
-    logger.info(f"Logger set up with log level: {log_level}")
+    logger.add(
+        sink=str(log_file),
+        level=log_level.upper(),
+        format=log_format,
+        rotation="10 MB",  # Log rotation based on file size
+        serialize=True,
+    )
+
+    logger.debug(f"Logger set up with log level: {log_level}")
     if log_file:
         logger.info(f"Log file: {log_file}")