Skip to content

Commit 809964b

Browse files
committed
clean up
1 parent 94a7052 commit 809964b

File tree

5 files changed

+6
-6
lines changed

5 files changed

+6
-6
lines changed

packages/service-library/src/servicelib/rabbitmq/rpc_interfaces/webserver/v1/functions.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -343,7 +343,7 @@ async def batch_register_function_jobs(
343343
"""Register a function job."""
344344
return TypeAdapter(BatchCreateRegisteredFunctionJobs).validate_python(
345345
await self._request(
346-
"register_function_job_batch",
346+
"batch_register_function_jobs",
347347
product_name=product_name,
348348
user_id=user_id,
349349
function_jobs=function_jobs,

services/api-server/src/simcore_service_api_server/_service_function_jobs.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -134,7 +134,7 @@ def create_function_job_inputs( # pylint: disable=no-self-use
134134
values=joined_inputs or {},
135135
)
136136

137-
async def pre_register_function_job(
137+
async def pre_register_function_jobs(
138138
self,
139139
*,
140140
function: RegisteredFunction,

services/api-server/src/simcore_service_api_server/_service_function_jobs_task_client.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -340,7 +340,7 @@ async def create_function_job_creation_tasks(
340340
]
341341

342342
pre_registered_function_job_data_list = (
343-
await self._function_job_service.pre_register_function_job(
343+
await self._function_job_service.pre_register_function_jobs(
344344
function=function,
345345
job_inputs=uncached_inputs,
346346
)

services/web/server/src/simcore_service_webserver/functions/_controller/_functions_rpc.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -109,14 +109,14 @@ async def register_function_job(
109109
FunctionJobsWriteApiAccessDeniedError,
110110
)
111111
)
112-
async def register_function_job_batch(
112+
async def batch_register_function_jobs(
113113
app: web.Application,
114114
*,
115115
user_id: UserID,
116116
product_name: ProductName,
117117
function_jobs: FunctionJobList,
118118
) -> BatchCreateRegisteredFunctionJobs:
119-
return await _functions_service.register_function_job_batch(
119+
return await _functions_service.batch_register_function_jobs(
120120
app=app, user_id=user_id, product_name=product_name, function_jobs=function_jobs
121121
)
122122

services/web/server/src/simcore_service_webserver/functions/_functions_service.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -107,7 +107,7 @@ async def register_function_job(
107107
return _decode_functionjob(created_items[0])
108108

109109

110-
async def register_function_job_batch(
110+
async def batch_register_function_jobs(
111111
app: web.Application,
112112
*,
113113
user_id: UserID,

0 commit comments

Comments
 (0)