Skip to content

Commit c67a860

Browse files
ruff format whitespace-only on opencti + sift-gateway files (pre-push check fix)
1 parent b91aeab commit c67a860

4 files changed

Lines changed: 6 additions & 14 deletions

File tree

packages/opencti/src/opencti_mcp/client.py

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -68,8 +68,7 @@ def _load_startup_probe_timeout() -> int:
6868
val = int(raw)
6969
except ValueError as e:
7070
raise ValueError(
71-
f"OPENCTI_STARTUP_TIMEOUT must be an integer (1-300 seconds); "
72-
f"got {raw!r}"
71+
f"OPENCTI_STARTUP_TIMEOUT must be an integer (1-300 seconds); got {raw!r}"
7372
) from e
7473
if not 1 <= val <= 300:
7574
raise ValueError(

packages/opencti/src/opencti_mcp/server.py

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -116,9 +116,7 @@
116116
class OpenCTIMCPServer:
117117
"""MCP server for OpenCTI threat intelligence (read-only)."""
118118

119-
def __init__(
120-
self, config: Config, client: OpenCTIClient | None = None
121-
) -> None:
119+
def __init__(self, config: Config, client: OpenCTIClient | None = None) -> None:
122120
"""Construct the MCP server.
123121
124122
Args:

packages/sift-gateway/src/sift_gateway/backends/stdio_backend.py

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -140,9 +140,7 @@ async def stop(self) -> None:
140140
return
141141
if self._exit_stack is not None:
142142
try:
143-
await asyncio.wait_for(
144-
self._exit_stack.aclose(), timeout=_STOP_TIMEOUT
145-
)
143+
await asyncio.wait_for(self._exit_stack.aclose(), timeout=_STOP_TIMEOUT)
146144
# Successful close: state-reset still runs in finally below
147145
except asyncio.TimeoutError:
148146
logger.warning(

tests/test_opencti/test_new_features.py

Lines changed: 3 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -363,9 +363,7 @@ def test_validate_startup_timeout_returns_degraded(self, mock_config):
363363

364364
client = OpenCTIClient(mock_config)
365365
with patch.object(client, "_connect_probe") as mock_probe:
366-
mock_probe.side_effect = requests.exceptions.Timeout(
367-
"Read timed out"
368-
)
366+
mock_probe.side_effect = requests.exceptions.Timeout("Read timed out")
369367
result = client.validate_startup()
370368

371369
assert client._degraded is True
@@ -427,8 +425,7 @@ def test_degraded_mode_tools_fail_fast(self, mock_config):
427425
# surface can fail-fast at the next layer.
428426
serialized = str(result)
429427
assert "DEGRADED" in serialized.upper() or "degraded" in serialized, (
430-
f"{method_name} returned without DEGRADED marker: "
431-
f"{result!r}"
428+
f"{method_name} returned without DEGRADED marker: {result!r}"
432429
)
433430
except (DegradedError, Exception) as e:
434431
# DegradedError direct, or wrapped (e.g., QueryError
@@ -464,7 +461,7 @@ def test_validate_startup_uses_probe_not_runtime_client(self, mock_config):
464461
client.validate_startup()
465462
except Exception:
466463
pass # post-probe path may raise; we only care
467-
# that connect() was bypassed
464+
# that connect() was bypassed
468465
mp.assert_called()
469466
mc.assert_not_called()
470467

0 commit comments

Comments
 (0)