@@ -760,11 +760,12 @@ async def _start_dynamic_service( # noqa: C901
760760 get_redis_lock_manager_client_sdk (request .app ),
761761 lock_key = _nodes_service .get_service_start_lock_key (user_id , project_uuid ),
762762 blocking = True ,
763- blocking_timeout = datetime .timedelta (
764- seconds = _nodes_service .get_total_project_dynamic_nodes_creation_interval (
765- get_plugin_settings (request .app ).PROJECTS_MAX_NUM_RUNNING_DYNAMIC_NODES
766- )
767- ),
763+ blocking_timeout = None ,
764+ # blocking_timeout=datetime.timedelta(
765+ # seconds=_nodes_service.get_total_project_dynamic_nodes_creation_interval(
766+ # get_plugin_settings(request.app).PROJECTS_MAX_NUM_RUNNING_DYNAMIC_NODES
767+ # )
768+ # ),
768769 )
769770 async def _ () -> None :
770771 project_running_nodes = await dynamic_scheduler_service .list_dynamic_services (
@@ -884,7 +885,7 @@ async def _() -> None:
884885 service_version = service_version ,
885886 )
886887
887- service_resources : ServiceResourcesDict = await get_project_node_resources (
888+ service_resources = await get_project_node_resources (
888889 request .app ,
889890 user_id = user_id ,
890891 project_id = project_uuid ,
@@ -919,6 +920,7 @@ async def _() -> None:
919920 project = await get_project_for_user (
920921 request .app , f"{ project_uuid } " , user_id , include_state = True
921922 )
923+
922924 await notify_project_node_update (request .app , project , node_uuid , errors = None )
923925
924926 await _ ()
0 commit comments