Skip to content

Live Runner + Scope support#20

Draft
j0sh wants to merge 30 commits into
mainfrom
ja/live-runner
Draft

Live Runner + Scope support#20
j0sh wants to merge 30 commits into
mainfrom
ja/live-runner

Conversation

@j0sh
Copy link
Copy Markdown
Collaborator

@j0sh j0sh commented May 21, 2026

No description provided.

j0sh added 30 commits May 15, 2026 16:43
The new runner uses `address` as an opaque blob
Registers the app as a runner with an orchestrator.
None of these have anything to do with orchestrators.
Keep only small shims for backwards compatibility.
@coderabbitai
Copy link
Copy Markdown

coderabbitai Bot commented May 21, 2026

Important

Review skipped

Draft detected.

Please check the settings in the CodeRabbit UI or the .coderabbit.yaml file in this repository. To trigger a single review, invoke the @coderabbitai review command.

⚙️ Run configuration

Configuration used: defaults

Review profile: CHILL

Plan: Pro

Run ID: 0e53c818-5ea1-43f9-ab57-e6e5d588ef37

You can disable this status message by setting the reviews.review_status to false in the CodeRabbit configuration file.

Use the checkbox below for a quick retry:

  • 🔍 Trigger review
✨ Finishing Touches
🧪 Generate unit tests (beta)
  • Create PR with unit tests
  • Commit unit tests in branch ja/live-runner

Thanks for using CodeRabbit! It's free for OSS, and your support helps us grow. If you like it, consider giving us a shout-out.

❤️ Share

Comment @coderabbitai help to get the list of available commands and usage tips.


async def _maybe_await(value: object) -> None:
if inspect.isawaitable(value):
await value


class LiveRunnerSessionHeaders(Protocol):
def get(self, key: str, default: str = "") -> str: ...

async def _maybe_await(value: None | Awaitable[None]) -> None:
if inspect.isawaitable(value):
await value
if wait_callback and (timeout is None or timeout > 0):
try:
await self.wait_callback(timeout=timeout)
except asyncio.TimeoutError:
task.cancel()
try:
await task
except asyncio.CancelledError:
def _release_session_id(self, session_id: str) -> None:
try:
self._active_session_ids.remove(session_id)
except ValueError:
if wait_callbacks and (timeout is None or timeout > 0):
try:
await self.wait_callbacks(timeout=timeout)
except asyncio.TimeoutError:
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant