Release Beta 5 (#1009)

pyproject.toml

@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "langflow"
-version = "0.5.0b3"
+version = "0.5.0b4"
 description = "A Python package with a built-in web application"
 authors = ["Logspace <contact@logspace.ai>"]
 maintainers = [

src/backend/langflow/__main__.py

@@ -52,6 +52,18 @@ def display_results(results):
         console.print()  # Print a new line
 
 
+def set_var_for_macos_issue():
+    # OBJC_DISABLE_INITIALIZE_FORK_SAFETY=YES
+    # we need to set this var is we are running on MacOS
+    # otherwise we get an error when running gunicorn
+
+    if platform.system() in ["Darwin"]:
+        import os
+
+        os.environ["OBJC_DISABLE_INITIALIZE_FORK_SAFETY"] = "YES"
+        logger.debug("Set OBJC_DISABLE_INITIALIZE_FORK_SAFETY to YES to avoid error")
+
+
 def update_settings(
     config: str,
     cache: Optional[str] = None,
@@ -143,7 +155,10 @@ def run(
     """
     Run the Langflow.
     """
+
+    set_var_for_macos_issue()
     # override env variables with .env file
+
     if env_file:
         load_dotenv(env_file, override=True)
 
@@ -165,7 +180,6 @@ def run(
     options = {
         "bind": f"{host}:{port}",
         "workers": get_number_of_workers(workers),
-        "worker_class": "uvicorn.workers.UvicornWorker",
         "timeout": timeout,
     }
 

src/backend/langflow/server.py

@@ -4,6 +4,8 @@ from gunicorn.app.base import BaseApplication  # type: ignore
 class LangflowApplication(BaseApplication):
     def __init__(self, app, options=None):
         self.options = options or {}
+
+        self.options["worker_class"] = "uvicorn.workers.UvicornWorker"
         self.application = app
         super().__init__()
 

src/backend/langflow/services/manager.py

@@ -90,7 +90,10 @@ class ServiceManager:
             if service is None:
                 continue
             logger.debug(f"Teardown service {service.name}")
-            service.teardown()
+            try:
+                service.teardown()
+            except Exception as exc:
+                logger.exception(exc)
         self.services = {}
         self.factories = {}
         self.dependencies = {}
@@ -150,9 +153,3 @@ def initialize_session_service():
         dependencies=[ServiceType.CACHE_SERVICE],
     )
 
-
-def teardown_services():
-    """
-    Teardown all the services.
-    """
-    service_manager.teardown()

src/backend/langflow/services/utils.py

@@ -153,6 +153,9 @@ def teardown_services():
     """
     try:
         teardown_superuser(get_settings_service(), next(get_session()))
+    except Exception as exc:
+        logger.exception(exc)
+    try:
         service_manager.teardown()
     except Exception as exc:
         logger.exception(exc)