style(flowlens): satisfy repository format gates

Author: try1004

backend/packages/harness/deerflow/mcp/tools.py

@@ -41,11 +41,7 @@ def _safe_mcp_tool_metadata(
     """Return bounded MCP metadata without connection secrets."""
 
     source = tool.metadata if isinstance(tool.metadata, dict) else {}
-    safe = {
-        key: redact_value(value, max_string_length=200)
-        for key, value in source.items()
-        if isinstance(key, str) and key.casefold() not in _SENSITIVE_METADATA_KEYS
-    }
+    safe = {key: redact_value(value, max_string_length=200) for key, value in source.items() if isinstance(key, str) and key.casefold() not in _SENSITIVE_METADATA_KEYS}
     prefix = f"{server_name}_"
     original_name = tool.name[len(prefix) :] if tool.name.startswith(prefix) else tool.name
     safe.update(

backend/packages/harness/deerflow/runtime/diagnostics/attribution.py

@@ -141,9 +141,7 @@ def attribute_failure(record: Any | None, timeline: list[dict[str, Any]]) -> dic
 
     mcp_auth = _find(
         timeline,
-        lambda item: item.get("phase") == "mcp"
-        and item.get("status") == "error"
-        and _contains(item, "auth", "oauth", "unauthorized", "401"),
+        lambda item: item.get("phase") == "mcp" and item.get("status") == "error" and _contains(item, "auth", "oauth", "unauthorized", "401"),
     )
     if mcp_auth is not None:
         matches.append(
@@ -159,9 +157,7 @@ def attribute_failure(record: Any | None, timeline: list[dict[str, Any]]) -> dic
 
     mcp_session = _find(
         timeline,
-        lambda item: item.get("phase") == "mcp"
-        and item.get("status") == "error"
-        and _contains(item, "session", "transport", "connect"),
+        lambda item: item.get("phase") == "mcp" and item.get("status") == "error" and _contains(item, "session", "transport", "connect"),
     )
     if mcp_session is not None:
         matches.append(
@@ -241,9 +237,7 @@ def attribute_failure(record: Any | None, timeline: list[dict[str, Any]]) -> dic
 
     mcp_tool_error = _find(
         timeline,
-        lambda item: item.get("phase") == "mcp"
-        and item.get("status") == "error"
-        and _contains(item, "tool"),
+        lambda item: item.get("phase") == "mcp" and item.get("status") == "error" and _contains(item, "tool"),
     )
     if mcp_tool_error is not None:
         matches.append(

backend/packages/harness/deerflow/runtime/diagnostics/emitter.py

@@ -40,8 +40,6 @@ def find_diagnostic_recorder(runtime: Any) -> DiagnosticRecorder | None:
     if not isinstance(callbacks, (list, tuple)):
         return None
     for callback in callbacks:
-        if callable(getattr(callback, "record_diagnostic_event", None)) and callable(
-            getattr(callback, "record_diagnostic_event_threadsafe", None)
-        ):
+        if callable(getattr(callback, "record_diagnostic_event", None)) and callable(getattr(callback, "record_diagnostic_event_threadsafe", None)):
             return callback
     return None

backend/packages/harness/deerflow/runtime/diagnostics/explainer.py

@@ -111,12 +111,7 @@ async def explain(
         payload = self._prompt_payload(diagnostics)
         messages = [
             SystemMessage(content=_SYSTEM_PROMPT),
-            HumanMessage(
-                content=(
-                    f"Explain this diagnosis in {'Chinese' if locale == 'zh' else 'English'}:\n"
-                    f"{json.dumps(payload, ensure_ascii=False, sort_keys=True)}"
-                )
-            ),
+            HumanMessage(content=(f"Explain this diagnosis in {'Chinese' if locale == 'zh' else 'English'}:\n{json.dumps(payload, ensure_ascii=False, sort_keys=True)}")),
         ]
         try:
             async with self._semaphore:

backend/packages/harness/deerflow/runtime/diagnostics/metrics.py

@@ -85,11 +85,7 @@ def _span_key(item: dict[str, Any], index: int) -> str:
 
 
 def _unique_count(timeline: list[dict[str, Any]], predicate) -> int:
-    keys = {
-        _span_key(item, index)
-        for index, item in enumerate(timeline)
-        if predicate(item)
-    }
+    keys = {_span_key(item, index) for index, item in enumerate(timeline) if predicate(item)}
     return len(keys)
 
 

backend/packages/harness/deerflow/runtime/diagnostics/redaction.py

@@ -37,12 +37,7 @@ def redact_value(value: Any, *, max_string_length: int = 4000) -> Any:
     """Return a recursively redacted copy while preserving container shapes."""
 
     if isinstance(value, dict):
-        return {
-            key: _REDACTED
-            if isinstance(key, str) and key.casefold() in _SENSITIVE_KEYS
-            else redact_value(item, max_string_length=max_string_length)
-            for key, item in value.items()
-        }
+        return {key: _REDACTED if isinstance(key, str) and key.casefold() in _SENSITIVE_KEYS else redact_value(item, max_string_length=max_string_length) for key, item in value.items()}
     if isinstance(value, list):
         return [redact_value(item, max_string_length=max_string_length) for item in value]
     if isinstance(value, tuple):

backend/packages/harness/deerflow/runtime/diagnostics/timeline.py

@@ -112,12 +112,7 @@ def _duration_ms(metadata: dict[str, Any]) -> int | float | None:
 
 
 def _summary_for(event_type: str, content: Any, metadata: dict[str, Any]) -> str:
-    return (
-        _event_text(content)
-        or _string_metadata(metadata, "reason")
-        or _string_metadata(metadata, "error_type")
-        or event_type
-    )
+    return _event_text(content) or _string_metadata(metadata, "reason") or _string_metadata(metadata, "error_type") or event_type
 
 
 def _string_metadata(metadata: dict[str, Any], key: str) -> str | None:

backend/packages/harness/deerflow/runtime/runs/store/memory.py

@@ -79,11 +79,7 @@ async def list_recent(
             results = [run for run in results if run["created_at"] < started_before]
         if cursor is not None:
             decoded = decode_run_cursor(cursor)
-            results = [
-                run
-                for run in results
-                if (run["created_at"], run["run_id"]) < (decoded.created_at, decoded.run_id)
-            ]
+            results = [run for run in results if (run["created_at"], run["run_id"]) < (decoded.created_at, decoded.run_id)]
         results.sort(key=lambda run: (run["created_at"], run["run_id"]), reverse=True)
         return results[:limit]
 

backend/scripts/benchmark_flowlens.py

@@ -150,4 +150,3 @@ def main() -> int:
 
 if __name__ == "__main__":
     raise SystemExit(main())
-

backend/tests/test_flowlens_benchmark_contract.py

@@ -38,4 +38,3 @@ def test_synthetic_events_are_deterministic_and_correlated():
     assert len(first) == 25
     assert [event["seq"] for event in first] == list(range(1, 26))
     assert all(event["metadata"]["span_id"] for event in first)
-