Skip to content

Commit a01f9ae

Browse files
remove replace_existing
1 parent 4e6dce4 commit a01f9ae

File tree

2 files changed

+3
-4
lines changed

2 files changed

+3
-4
lines changed

singlestoredb/apps/_python_udfs.py

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,6 @@
1515

1616

1717
async def run_udf_app(
18-
replace_existing: bool,
1918
log_level: str = 'error',
2019
kill_existing_app_server: bool = True,
2120
) -> UdfConnectionInfo:
@@ -57,7 +56,7 @@ async def run_udf_app(
5756

5857
# Register the functions only if the app is running interactively.
5958
if app_config.running_interactively:
60-
app.register_functions(replace=replace_existing)
59+
app.register_functions(replace=True)
6160

6261
asyncio.create_task(_running_server.serve())
6362
await _running_server.wait_for_startup()

singlestoredb/functions/ext/asgi.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -967,7 +967,7 @@ def get_function_info(
967967
# Generate CREATE FUNCTION SQL for each function using get_create_functions
968968
create_sqls = self.get_create_functions(replace=True)
969969
sql_map = {}
970-
for key, (_, info), sql in zip(self.endpoints.keys(), self.endpoints.values(), create_sqls):
970+
for (_, info), sql in zip(self.endpoints.values(), create_sqls):
971971
sig = info['signature']
972972
sql_map[sig['name']] = sql
973973

@@ -1013,7 +1013,7 @@ def get_function_info(
10131013
args=args,
10141014
returns=returns,
10151015
function_type=info['function_type'],
1016-
sql_statement= sql,
1016+
sql_statement=sql,
10171017
)
10181018

10191019
return functions

0 commit comments

Comments
 (0)