debug

app.py

@@ -42,8 +42,16 @@ try:
             logger.info(f"startup.sh stdout:  {result.stdout}")
             logger.info(f"startup.sh stderr:  {result.stderr}")
             logger.info(f"Return code: {result.returncode}")
-        except:
-            logger.error(f"subprocess.run() encountered error.")
+        except Exception as e:
+            emsg = str(e)
+            logger.error(f"subprocess.run  EXCEPTION. e: {emsg}")
+            try:
+                with open("/app/startup.log", "r") as file:
+                    content = file.read()
+                    print(content)
+            except Exception as e2:
+                emsg = str(e2)
+                logger.error(f"#### Displaying startup.log EXCEPTION. e2: {emsg}")
         logger.info("### Running startup.sh complete")
     if 'runStartup' not in st.session_state:
         st.session_state.runStartup = True
@@ -81,30 +89,31 @@ try:
     ######################################################
     # Connect to the Weaviate vector database.
     #if 'client' not in st.session_state:
-    logger.info("#### Create Weaviate db client connection.")
-    client = weaviate.WeaviateClient(
-        connection_params=ConnectionParams.from_params(
-            http_host="localhost",
-            http_port="8080",
-            http_secure=False,
-            grpc_host="localhost",
-            grpc_port="50051",
-            grpc_secure=False
-        ),
-        additional_config=AdditionalConfig(
-            timeout=Timeout(init=60, query=1800, insert=1800),  # Values in seconds
+    if not st.session_state.client:
+        logger.info("#### Create Weaviate db client connection.")
+        client = weaviate.WeaviateClient(
+            connection_params=ConnectionParams.from_params(
+                http_host="localhost",
+                http_port="8080",
+                http_secure=False,
+                grpc_host="localhost",
+                grpc_port="50051",
+                grpc_secure=False
+            ),
+            additional_config=AdditionalConfig(
+                timeout=Timeout(init=60, query=1800, insert=1800),  # Values in seconds
+            )
         )
-    )
-    client.connect()
-    #    st.session_state.client = client
-    #else:
-    #    client = st.session_state.client
+        client.connect()
+        st.session_state.client = client
+    else:
+        client = st.session_state.client
 
 
     #######################################################
     # Read each text input file, parse it into a document,
     # chunk it, collect chunks and document name.
-    if not client.collections.exists("Documents") or not client.collections.exists("Documents") :
+    if not client.collections.exists("Documents") or not client.collections.exists("Documes") :
         logger.info("#### Read and chunk input text files.")
         for filename in os.listdir(pathString):
             logger.info(filename)