Skip to content

Commit dcd74d6

Browse files
committed
Add reserve context
1 parent 4949971 commit dcd74d6

File tree

1 file changed

+6
-1
lines changed

1 file changed

+6
-1
lines changed

tests/worker/test_worker.py

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -471,7 +471,12 @@ async def reserve_slot(self, ctx: SlotReserveContext) -> SlotPermit:
471471
self.reserve_asserts(ctx)
472472
# Verify an async call doesn't bungle things
473473
await asyncio.sleep(0.01)
474-
logger.info("Reserve slot %d", self.reserves)
474+
logger.info(
475+
"Reserve slot %d - %s - %s",
476+
self.reserves,
477+
ctx.slot_type,
478+
ctx.task_queue,
479+
)
475480
self.reserves += 1
476481
return MyPermit(self.reserves)
477482

0 commit comments

Comments
 (0)