1movmedia/pyworker
2
0
Fork 0
Code Pull Requests Activity

Await endpoint.session() in null pyworker client

Browse Source 
endpoint.session() forwards to start_endpoint_session, which is async
def — so the call returns a coroutine, not a Session, despite the
SDK's return-type annotation. Use 'async with await endpoint.session(...)'
so the coroutine resolves to a Session before entering the context.

Co-Authored-By: Claude Opus 4.7 (1M context) <noreply@anthropic.com>
This commit is contained in:
Rob Ballantyne
2026-05-12 11:07:32 +01:00
parent ef248ef695
commit d51f04a176
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
workers/null/client.py
+1 -1
View File
@@ -40,7 +40,7 @@ async def reserve(
lifetime = hold_for + 60 lifetime = hold_for + 60
start = time.monotonic() start = time.monotonic()
log.info("[%s] creating session (lifetime=%.0fs, hold=%.0fs)", label, lifetime, hold_for) log.info("[%s] creating session (lifetime=%.0fs, hold=%.0fs)", label, lifetime, hold_for)
async with endpoint.session(cost=SESSION_COST, lifetime=lifetime) as s: async with await endpoint.session(cost=SESSION_COST, lifetime=lifetime) as s:
log.info("[%s] session %s open", label, s.session_id) log.info("[%s] session %s open", label, s.session_id)
try: try:
await asyncio.sleep(hold_for) await asyncio.sleep(hold_for)