File tree Expand file tree Collapse file tree 5 files changed +7
-7
lines changed
src/servicelib/long_running_interfaces
tests/long_running_interfaces
services/web/server/src/simcore_service_webserver/projects Expand file tree Collapse file tree 5 files changed +7
-7
lines changed Original file line number Diff line number Diff line change @@ -294,7 +294,7 @@ async def ensure_result( # type: ignore[valid-type]
294294 ) from e
295295 finally :
296296 # when completed remove the task form memory both on the server and the client
297- # TODO : unsure if these should be caught and ingored, if we want to catch them both
298- # shoudl support some automatic cleanup in case the are forgotten
297+ # NOTE : unsure if these should be caught and ingored. In the case we decide to
298+ # catch them there should be some automatic cleanup in case the are forgotten
299299 await self ._rpc_interface .remove (unique_id )
300300 await self ._store_interface .remove (unique_id )
Original file line number Diff line number Diff line change @@ -30,7 +30,7 @@ class AlreadyStartedError(BaseLongRunningError):
3030
3131
3232class JobNotFoundError (BaseLongRunningError ):
33- msg_template = "unique_id='{unique_id}' is not presnet "
33+ msg_template = "unique_id='{unique_id}' is not present "
3434
3535
3636class NoResultIsAvailableError (BaseLongRunningError ):
Original file line number Diff line number Diff line change 66_RPC_NAME : Final [str ] = "long_running_interface"
77
88
9- def get_rpc_namespace (long_running_namepsace : LongRunningNamespace ) -> RPCNamespace :
9+ def get_rpc_namespace (long_running_namespace : LongRunningNamespace ) -> RPCNamespace :
1010 return RPCNamespace .from_entries (
11- {"name" : _RPC_NAME , "long_running_namepsace " : long_running_namepsace }
11+ {"name" : _RPC_NAME , "long_running_namespace " : long_running_namespace }
1212 )
Original file line number Diff line number Diff line change @@ -87,7 +87,7 @@ async def start(
8787 params : StartParams ,
8888 timeout : timedelta , # noqa: ASYNC109
8989 ) -> None :
90- print (f"starging { name } " )
90+ print (f"starting { name } " )
9191 self ._storage [unique_id ] = {
9292 "params" : params ,
9393 "time_remaining" : int (timeout .total_seconds ()),
Original file line number Diff line number Diff line change @@ -1200,7 +1200,7 @@ async def is_node_id_present_in_any_project_workbench(
12001200 app : web .Application ,
12011201 node_id : NodeID ,
12021202) -> bool :
1203- """If the node_id is presnet in one of the projects' workbenche returns True"""
1203+ """If the node_id is present in one of the projects' workbenche returns True"""
12041204 db : ProjectDBAPI = app [APP_PROJECT_DBAPI ]
12051205 return await db .node_id_exists (node_id )
12061206
You can’t perform that action at this time.
0 commit comments