@@ -134,6 +134,7 @@ async def _check_pipeline_startable(
134134@log_decorator (_logger )
135135async def _get_project_metadata (
136136 project_id : ProjectID ,
137+ workbench : NodesDict ,
137138 project_repo : ProjectsRepository ,
138139 projects_metadata_repo : ProjectsMetadataRepository ,
139140) -> ProjectMetadataDict :
@@ -154,15 +155,15 @@ async def _get_project_node_names(
154155 ) -> tuple [str , str ]:
155156 prj = await project_repo .get_project (project_uuid )
156157 node_id_str = f"{ node_id } "
157- if node_id_str not in prj . workbench :
158+ if node_id_str not in workbench :
158159 _logger .error (
159160 "%s not found in %s. it is an ancestor of %s. Please check!" ,
160161 f"{ node_id = } " ,
161162 f"{ prj .uuid = } " ,
162163 f"{ project_id = } " ,
163164 )
164165 return prj .name , _UNKNOWN_NODE
165- return prj .name , prj . workbench [node_id_str ].label
166+ return prj .name , workbench [node_id_str ].label
166167
167168 parent_project_name , parent_node_name = await _get_project_node_names (
168169 project_ancestors .parent_project_uuid , project_ancestors .parent_node_id
@@ -239,7 +240,7 @@ async def _try_start_pipeline(
239240 wallet_id = wallet_id ,
240241 wallet_name = wallet_name ,
241242 project_metadata = await _get_project_metadata (
242- computation .project_id , project_repo , projects_metadata_repo
243+ computation .project_id , workbench , project_repo , projects_metadata_repo
243244 ),
244245 )
245246 or {},
0 commit comments