Format and test changes

Signed-off-by: Muralidhar Andoorveedu <[email protected]>

tests/core/test_scheduler.py

@@ -5,7 +5,8 @@
 
 import pytest  # noqa
 
-from vllm.config import CacheConfig, LoRAConfig, ParallelConfig, SchedulerConfig
+from vllm.config import (CacheConfig, LoRAConfig, ParallelConfig,
+                         SchedulerConfig)
 from vllm.core.interfaces import AllocStatus
 from vllm.core.policy import PolicyFactory
 from vllm.core.scheduler import Scheduler, SchedulingBudget

vllm/engine/async_llm_engine.py

@@ -513,8 +513,9 @@ async def run_engine_loop(self):
                     result = task.result()
                     virtual_engine = requests_in_progress.index(task)
                     if self.engine_use_ray:
-                        has_unfinished_requests = await self.engine.has_unfinished_requests_for_virtual_engine.remote(
-                            virtual_engine)  # type: ignore
+                        has_unfinished_requests = \
+                            await self.engine.\
+                                  has_unfinished_requests_for_virtual_engine.remote(virtual_engine) # type: ignore
                     else:
                         has_unfinished_requests = self.engine.scheduler[
                             virtual_engine].has_unfinished_seqs()

vllm/engine/llm_engine.py

@@ -491,7 +491,9 @@ def has_unfinished_requests(self) -> bool:
 
     def has_unfinished_requests_for_virtual_engine(
             self, virtual_engine: int) -> bool:
-        """Returns True if there are unfinished requests for the virtual engine."""
+        """
+        Returns True if there are unfinished requests for the virtual engine.
+        """
         return self.scheduler[virtual_engine].has_unfinished_seqs()
 
     def _process_model_outputs(

vllm/lora/layers.py

@@ -9,11 +9,13 @@
 from transformers import PretrainedConfig
 
 from vllm.config import LoRAConfig
-from vllm.distributed import (
-    get_tensor_model_parallel_rank, get_tensor_model_parallel_src_rank,
-    get_tensor_model_parallel_world_size, split_tensor_along_last_dim,
-    tensor_model_parallel_all_gather, tensor_model_parallel_all_reduce,
-    tensor_model_parallel_gather)
+from vllm.distributed import (get_tensor_model_parallel_rank,
+                              get_tensor_model_parallel_src_rank,
+                              get_tensor_model_parallel_world_size,
+                              split_tensor_along_last_dim,
+                              tensor_model_parallel_all_gather,
+                              tensor_model_parallel_all_reduce,
+                              tensor_model_parallel_gather)
 from vllm.distributed.utils import divide
 from vllm.lora.punica import add_lora, add_lora_slice, bgmv
 from vllm.model_executor.layers.linear import (ColumnParallelLinear,

vllm/model_executor/models/gpt2.py

@@ -24,11 +24,13 @@
 from transformers import GPT2Config
 
 from vllm.attention import Attention, AttentionMetadata
-from vllm.distributed import (
-    get_pipeline_model_parallel_rank, get_pipeline_model_parallel_world_size,
-    get_pp_indices, get_tensor_model_parallel_world_size,
-    is_pipeline_model_parallel_first_rank,
-    is_pipeline_model_parallel_last_rank, recv_prev_rank, send_next_rank)
+from vllm.distributed import (get_pipeline_model_parallel_rank,
+                              get_pipeline_model_parallel_world_size,
+                              get_pp_indices,
+                              get_tensor_model_parallel_world_size,
+                              is_pipeline_model_parallel_first_rank,
+                              is_pipeline_model_parallel_last_rank,
+                              recv_prev_rank, send_next_rank)
 from vllm.model_executor.layers.activation import get_act_fn
 from vllm.model_executor.layers.linear import (ColumnParallelLinear,
                                                QKVParallelLinear,