Merge remote-tracking branch 'origin/dev' into better_server

.github/workflows/release.yml

@@ -54,4 +54,4 @@ jobs:
           token: ${{ secrets.SERVE_GITHUB_TOKEN }}
           repository: jina-ai/langchain-serve
           event-type: langflow-push
-          client-payload: '{"push_token": "${{ secrets.LCSERVE_PUSH_TOKEN }}", "branch": "dev"}'
+          client-payload: '{"push_token": "${{ secrets.LCSERVE_PUSH_TOKEN }}", "branch": "main"}'

pyproject.toml

@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "langflow"
-version = "0.0.80"
+version = "0.0.86"
 description = "A Python package with a built-in web application"
 authors = ["Logspace <contact@logspace.ai>"]
 maintainers = [
@@ -29,7 +29,7 @@ google-search-results = "^2.4.1"
 google-api-python-client = "^2.79.0"
 typer = "^0.7.0"
 gunicorn = "^20.1.0"
-langchain = "^0.0.186"
+langchain = "^0.0.194"
 openai = "^0.27.7"
 types-pyyaml = "^6.0.12.8"
 dill = "^0.3.6"

src/backend/langflow/config.yaml

@@ -58,6 +58,7 @@ llms:
   - Cohere
   - Anthropic
   - ChatAnthropic
+  - HuggingFaceHub
 memories:
   - ConversationBufferMemory
   - ConversationSummaryMemory

src/backend/langflow/interface/utils.py

@@ -45,8 +45,12 @@ def try_setting_streaming_options(langchain_object, websocket):
         langchain_object.llm_chain, "llm"
     ):
         llm = langchain_object.llm_chain.llm
-    if isinstance(llm, BaseLanguageModel) and hasattr(llm, "streaming"):
-        llm.streaming = True
+
+    if isinstance(llm, BaseLanguageModel):
+        if hasattr(llm, "streaming") and isinstance(llm.streaming, bool):
+            llm.streaming = True
+        elif hasattr(llm, "stream") and isinstance(llm.stream, bool):
+            llm.stream = True
 
     return langchain_object
 

src/backend/langflow/template/frontend_node/llms.py

@@ -46,7 +46,8 @@ class LLMFrontendNode(FrontendNode):
             field.required = True
             field.show = True
             field.is_list = True
-            field.options = ["text-generation", "text2text-generation"]
+            field.options = ["text-generation", "text2text-generation", "summarization"]
+            field.value = field.options[0]
             field.advanced = True
 
         if display_name := display_names_dict.get(field.name):

src/frontend/src/App.tsx

@@ -170,7 +170,7 @@ export default function App() {
         className="absolute left-7 bottom-2 flex h-6 cursor-pointer flex-col items-center justify-start overflow-hidden rounded-lg bg-gray-800 px-2 text-center font-sans text-xs tracking-wide text-gray-300 transition-all duration-500 ease-in-out hover:h-12 dark:bg-gray-100 dark:text-gray-800"
       >
         {version && <div className="mt-1">⛓️ LangFlow v{version}</div>}
-        <div className="mt-2">Created by Logspace</div>
+        <div className={version ? "mt-2" : "mt-1"}>Created by Logspace</div>
       </a>
     </div>
   );

src/frontend/src/modals/chatModal/index.tsx

@@ -215,19 +215,11 @@ export default function ChatModal({
         }
       };
       ws.current = newWs;
-    } catch {
+    } catch (error) {
       if (flow.id === "") {
         connectWS();
-      } else {
-        setErrorData({
-          title: "There was an error on web connection, please: ",
-          list: [
-            "Refresh the page",
-            "Use a new flow tab",
-            "Check if the backend is up",
-          ],
-        });
       }
+      console.log(error);
     }
   }
 
@@ -236,7 +228,7 @@ export default function ChatModal({
     return () => {
       console.log("unmount");
       console.log(ws);
-      if (ws) {
+      if (ws.current) {
         ws.current.close();
       }
     };
@@ -244,8 +236,9 @@ export default function ChatModal({
 
   useEffect(() => {
     if (
-      ws.current.readyState === ws.current.CLOSED ||
-      ws.current.readyState === ws.current.CLOSING
+      ws.current &&
+      (ws.current.readyState === ws.current.CLOSED ||
+        ws.current.readyState === ws.current.CLOSING)
     ) {
       connectWS();
       setLockChat(false);