wip

Author: psachdeva-ss

singlestoredb/apps/_python_udfs.py

@@ -17,7 +17,7 @@
 async def run_udf_app(
     app: Application,
     log_level: str = 'error',
-    kill_existing_app_server: bool = True,
+    kill_existing_app_server: bool = False,
 ) -> ConnectionInfo:
     global _running_server
     from ._uvicorn_util import AwaitableUvicornServer
@@ -42,6 +42,8 @@ async def run_udf_app(
 
     app.root_path = app_config.base_path
 
+    print("Listening on port", app_config.listen_port)
+
     config = uvicorn.Config(
         app,
         host='0.0.0.0',

singlestoredb/config.py

@@ -310,7 +310,7 @@
 register_option(
     'external_function.url', 'string', check_str, 'http://localhost:8000/invoke',
     'Specifies the URL of the external function application.',
-    environ=['SINGLESTOREDB_EXT_FUNC_URL'],
+    environ=['SINGLESTOREDB_APP_BASE_URL'],
 )
 
 register_option(

singlestoredb/functions/ext/asgi.py

@@ -500,7 +500,7 @@ def __init__(
             ]
         ] = None,
         app_mode: str = get_option('external_function.app_mode'),
-        url: str = get_option('external_function.url'),
+        url: str = get_option('external_function.url') + "invoke",
         data_format: str = get_option('external_function.data_format'),
         data_version: str = get_option('external_function.data_version'),
         link_name: Optional[str] = get_option('external_function.link_name'),
@@ -652,6 +652,18 @@ async def __call__(
         func_info: Dict[str, Any] = {}
         if func_endpoint is not None:
             func, func_info = func_endpoint
+        
+        if method == 'GET' and (path == () or path == ""):
+            await send({
+                'type': 'http.response.start',
+                'status': 200,
+                'headers': [(b'content-type', b'text/plain')],
+            })
+            await send({
+                'type': 'http.response.body',
+                'body': b'Server is alive!',
+            })
+            return
 
         # Call the endpoint
         if method == 'POST' and func is not None and path == self.invoke_path:
@@ -884,6 +896,7 @@ def register_functions(
                     for link in links:
                         cur.execute(f'DROP LINK {link}')
                 for func in self.get_create_functions(replace=replace):
+                    print("FUNC: ", func)
                     cur.execute(func)
 
     def drop_functions(