Skip to content

Commit 07dd1b4

Browse files
committed
fix(data): avoid requiring straw without queue leases
1 parent 78121c3 commit 07dd1b4

1 file changed

Lines changed: 2 additions & 2 deletions

File tree

‎slime/data/transport.py‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -176,8 +176,6 @@ class TrainBatchRef(DiskPayloadRef):
176176

177177

178178
def group_lease(group):
179-
from straw.protocol import Lease
180-
181179
from slime.rollout.base_types import iter_samples
182180

183181
samples = list(iter_samples(group))
@@ -186,6 +184,8 @@ def group_lease(group):
186184
return None
187185
if not all(value == leases[0] for value in leases):
188186
raise ValueError("A queue group must preserve one task authorization across all trajectories")
187+
from straw.protocol import Lease
188+
189189
return Lease(**leases[0])
190190

191191

0 commit comments

Comments
 (0)