UPDATE

analyticsHub/components/__init__.py

@@ -1,2 +1,25 @@
-from langchain_experimental.utilities import PythonREPL
-replManager = PythonREPL()
+import io
+import traceback
+import contextlib
+
+class REPLManager:
+    def __init__(self):
+        self.__stdout = io.StringIO()
+        self.__stderr = io.StringIO()
+    def run(self, codeString):
+        with contextlib.redirect_stdout(self.__stdout), contextlib.redirect_stderr(self.__stderr):
+            try:
+                exec(codeString)
+            except Exception:
+                traceback.print_exc(file=self.__stderr)
+        output, error = self.__stdout.getvalue(), self.__stderr.getvalue()
+        self.__stdout.truncate(0)
+        self.__stdout.seek(0)
+        self.__stderr.truncate(0)
+        self.__stderr.seek(0)
+        if error == "":
+            return output
+        else:
+            return error
+
+replManager = REPLManager()

app.py

@@ -40,7 +40,6 @@ app.include_router(utilities.router, prefix = "/utils", tags = ["Utilities"])
 
 @app.on_event("startup")
 async def startupEvent():
-    projectIds = [x["projectId"] for x in client.table("Projects").select("projectId").execute().data]
     params = readYaml("params.yaml")
     _ = replManager.run(params["redisFunctionCode"])
     _ = replManager.run(params["jsonSerializer"])