Skip to content

Commit 69e687a

Browse files
jsell-rhclaude
andcommitted
style: ruff format runner operational events
Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>
1 parent d272459 commit 69e687a

2 files changed

Lines changed: 17 additions & 11 deletions

File tree

components/runners/ambient-runner/ambient_runner/bridges/claude/operational_events.py

Lines changed: 14 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -32,15 +32,17 @@
3232
}
3333

3434
# TOOL_CALL_START and TOOL_CALL_ARGS are accumulated, pushed on TOOL_CALL_END.
35-
_SKIP_TYPES = frozenset({
36-
"TOOL_CALL_START",
37-
"TOOL_CALL_ARGS",
38-
"TEXT_MESSAGE_START",
39-
"TEXT_MESSAGE_CONTENT",
40-
"TEXT_MESSAGE_END",
41-
"STATE_SNAPSHOT",
42-
"MESSAGES_SNAPSHOT",
43-
})
35+
_SKIP_TYPES = frozenset(
36+
{
37+
"TOOL_CALL_START",
38+
"TOOL_CALL_ARGS",
39+
"TEXT_MESSAGE_START",
40+
"TEXT_MESSAGE_CONTENT",
41+
"TEXT_MESSAGE_END",
42+
"STATE_SNAPSHOT",
43+
"MESSAGES_SNAPSHOT",
44+
}
45+
)
4446

4547

4648
def _event_type_str(event: BaseEvent) -> Optional[str]:
@@ -92,7 +94,9 @@ def _build_payload(
9294
payload = {"custom_event": name}
9395
if value is not None:
9496
try:
95-
payload["value"] = json.loads(value) if isinstance(value, str) else value
97+
payload["value"] = (
98+
json.loads(value) if isinstance(value, str) else value
99+
)
96100
except (json.JSONDecodeError, TypeError):
97101
payload["value"] = str(value)
98102
return json.dumps(payload)

components/runners/ambient-runner/tests/test_operational_events.py

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -239,7 +239,9 @@ def test_text_message_content_skipped(self, writer, grpc_client):
239239
assert len(grpc_client.session_messages.calls) == 0
240240

241241
def test_tool_call_args_accumulates_no_push(self, writer, grpc_client):
242-
event = FakeEvent(type=FakeEventType.TOOL_CALL_ARGS, tool_call_id="tc-orphan", delta="data")
242+
event = FakeEvent(
243+
type=FakeEventType.TOOL_CALL_ARGS, tool_call_id="tc-orphan", delta="data"
244+
)
243245
asyncio.get_event_loop().run_until_complete(writer.consume(event))
244246
assert len(grpc_client.session_messages.calls) == 0
245247

0 commit comments

Comments
 (0)