Skip to content

Commit b19fe24

Browse files
committed
fix lint
1 parent a72f4de commit b19fe24

File tree

3 files changed

+6
-9
lines changed

3 files changed

+6
-9
lines changed

apps/grpo/main.py

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,6 @@
1414
import torch.nn.functional as F
1515
from datasets import load_dataset
1616
from forge.actors.policy import EngineConfig, Policy, SamplingOverrides
17-
from forge.actors.reference_actor import compute_sequence_logprobs, TitanRefModel
1817
from forge.actors.replay_buffer import ReplayBuffer
1918
from forge.controller.actor import ForgeActor
2019
from forge.controller.service import ServiceConfig, shutdown_service, spawn_service

apps/vllm/main.py

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,6 @@ async def run(cfg: DictConfig):
3030

3131
print("Spawning service...")
3232

33-
3433
policy = await spawn_service(
3534
ServiceConfig(**cfg.policy.service), Policy, **cfg.policy
3635
)

src/forge/actors/policy.py

Lines changed: 6 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -14,14 +14,7 @@
1414
from typing import Any, Dict, List
1515

1616
import torch
17-
18-
from forge.controller import ForgeActor, get_proc_mesh, stop_proc_mesh
19-
20-
from forge.data.sharding import VLLMSharding
21-
from forge.interfaces import Policy as PolicyInterface
22-
from forge.types import ProcessConfig
2317
from monarch.actor import current_rank, endpoint, ProcMesh
24-
from omegaconf import DictConfig
2518
from torchstore import MultiProcessStore
2619
from torchstore._state_dict_utils import DELIM
2720

@@ -45,6 +38,12 @@
4538
from vllm.v1.structured_output import StructuredOutputManager
4639
from vllm.worker.worker_base import WorkerWrapperBase
4740

41+
from forge.controller import ForgeActor, get_proc_mesh, stop_proc_mesh
42+
43+
from forge.data.sharding import VLLMSharding
44+
from forge.interfaces import Policy as PolicyInterface
45+
from forge.types import ProcessConfig
46+
4847

4948
logger = logging.getLogger(__name__)
5049

0 commit comments

Comments
 (0)