@@ -560,11 +560,11 @@ async def update_project_node_resources_from_hardware_info(
560560 return
561561 try :
562562 rabbitmq_rpc_client = get_rabbitmq_rpc_client (app )
563- unordered_list_ec2_instance_types : list [
564- EC2InstanceTypeGet
565- ] = await get_instance_type_details (
566- rabbitmq_rpc_client ,
567- instance_type_names = set ( hardware_info . aws_ec2_instances ),
563+ unordered_list_ec2_instance_types : list [EC2InstanceTypeGet ] = (
564+ await get_instance_type_details (
565+ rabbitmq_rpc_client ,
566+ instance_type_names = set ( hardware_info . aws_ec2_instances ) ,
567+ )
568568 )
569569
570570 assert unordered_list_ec2_instance_types # nosec
@@ -1369,7 +1369,7 @@ async def _get_node_share_state(
13691369 * ,
13701370 project_uuid : ProjectID ,
13711371 node_id : NodeID ,
1372- computational_pipeline_running : bool ,
1372+ computational_pipeline_running : bool | None ,
13731373 user_primrary_groupid : GroupID ,
13741374) -> NodeShareState :
13751375 node = await _projects_nodes_repository .get (
@@ -1914,9 +1914,8 @@ async def add_project_states_for_user(
19141914 )
19151915
19161916 # compose the node states
1917- is_pipeline_running = (
1918- await director_v2_service .is_pipeline_running (app , user_id , project ["uuid" ])
1919- or True
1917+ is_pipeline_running = await director_v2_service .is_pipeline_running (
1918+ app , user_id , project ["uuid" ]
19201919 )
19211920 user_primary_group_id = await users_service .get_user_primary_group_id (app , user_id )
19221921 for node_uuid , node in project ["workbench" ].items ():
0 commit comments