fix(ci): resolve root lint failures across workspace packages

This commit is contained in:
2026-03-04 12:15:14 -08:00
parent e5200f6c6b
commit 7a53a1ab49
20 changed files with 178 additions and 184 deletions
+3 -3
View File
@@ -22,7 +22,6 @@ import os
import shutil
import signal
import subprocess
import sys
from pathlib import Path
from typing import Any
@@ -436,7 +435,7 @@ def _install_bot() -> bool:
return False
try:
console.print(f"[cyan]Installing {NPM_PACKAGE}...[/cyan]")
result = subprocess.run(
subprocess.run(
[npm, "install", "-g", NPM_PACKAGE],
check=True,
capture_output=True,
@@ -674,9 +673,10 @@ def _bot_password_login(
username: str | None = None, password: str | None = None
) -> str:
"""Login via password grant using the hanzobot client. Returns access_token."""
import httpx
import time
import httpx
if not username:
username = click.prompt("Email")
if not password:
+2 -6
View File
@@ -17,14 +17,14 @@ Usage::
print(bucket.name, bucket.creation_date)
"""
from minio import Minio, credentials, sse # backward compat
from minio import Minio as S3Client
from minio import Minio # backward compat
from minio.datatypes import Object
from minio.error import (
InvalidResponseError,
S3Error,
ServerError,
)
from minio.datatypes import Object
from minio.helpers import ObjectWriteResult
# Convenience aliases
@@ -33,10 +33,6 @@ Error = S3Error
S3Exception = S3Error
ObjectWriteResponse = ObjectWriteResult
# Re-export useful sub-modules
from minio import credentials # noqa: F401
from minio import sse # noqa: F401
__version__ = "1.0.0"
__all__ = [
+2 -2
View File
@@ -12,9 +12,9 @@ Usage::
info = admin.info()
"""
from minio.minioadmin import MinioAdmin as S3Admin
from minio.minioadmin import MinioAdmin # backward compat
from minio.error import MinioAdminException as S3AdminException
from minio.minioadmin import MinioAdmin # backward compat
from minio.minioadmin import MinioAdmin as S3Admin
# Convenience alias
Admin = S3Admin
@@ -4,8 +4,8 @@ Provides the HanzoSession singleton for shared auth state, and
the LoginTool MCP tool for auth management.
"""
from .login_tool import LoginTool
from .session import HanzoSession
from .login_tool import LoginTool
# Tools list for entry point discovery
TOOLS = [LoginTool]
@@ -8,11 +8,11 @@ from __future__ import annotations
import json
import logging
from typing import Annotated, Any, final
from typing import Any, Annotated, final
from pydantic import Field
from mcp.server import FastMCP
from mcp.server.fastmcp import Context as MCPContext
from pydantic import Field
from hanzo_tools.core.base import BaseTool
@@ -11,12 +11,12 @@ Token resolution order:
from __future__ import annotations
import json
import logging
import os
import json
import time
from pathlib import Path
import logging
from typing import Any
from pathlib import Path
logger = logging.getLogger(__name__)
@@ -244,14 +244,14 @@ class HanzoSession:
if self._kms_client:
return self._kms_client
from hanzo_kms import ClientSettings, KMSClient
from hanzo_kms import KMSClient, ClientSettings
kms_url = os.getenv("HANZO_KMS_URL", "https://kms.hanzo.ai")
client_id = os.getenv("HANZO_KMS_CLIENT_ID", "")
client_secret = os.getenv("HANZO_KMS_CLIENT_SECRET", "")
if client_id and client_secret:
from hanzo_kms import AuthenticationOptions, UniversalAuthMethod
from hanzo_kms import UniversalAuthMethod, AuthenticationOptions
settings = ClientSettings(
site_url=kms_url,
@@ -6,14 +6,14 @@ Auth: Uses HanzoSession from hanzo-tools-auth for bearer tokens.
from __future__ import annotations
import os
import json
import logging
import os
from typing import Annotated, Any, final
from typing import Any, Annotated, final
from pydantic import Field
from mcp.server import FastMCP
from mcp.server.fastmcp import Context as MCPContext
from pydantic import Field
from hanzo_tools.core.base import BaseTool
@@ -6,14 +6,14 @@ Auth: Uses HanzoSession from hanzo-tools-auth for bearer tokens.
from __future__ import annotations
import os
import json
import logging
import os
from typing import Annotated, Any, final
from typing import Any, Annotated, final
from pydantic import Field
from mcp.server import FastMCP
from mcp.server.fastmcp import Context as MCPContext
from pydantic import Field
from hanzo_tools.core.base import BaseTool
@@ -9,15 +9,15 @@ Backend: Casdoor IAM at hanzo.id/api/
from __future__ import annotations
import os
import json
import logging
import os
from typing import Annotated, Any, final
from typing import Any, Annotated, final
import httpx
from pydantic import Field
from mcp.server import FastMCP
from mcp.server.fastmcp import Context as MCPContext
from pydantic import Field
from hanzo_tools.core.base import BaseTool
@@ -11,11 +11,11 @@ from __future__ import annotations
import json
import logging
from typing import Annotated, Any, final
from typing import Any, Annotated, final
from pydantic import Field
from mcp.server import FastMCP
from mcp.server.fastmcp import Context as MCPContext
from pydantic import Field
from hanzo_tools.core.base import BaseTool
@@ -7,14 +7,14 @@ environment variables (same pattern as hanzo-cli).
from __future__ import annotations
import os
import json
import logging
import os
from typing import Annotated, Any, final
from typing import Any, Annotated, final
from pydantic import Field
from mcp.server import FastMCP
from mcp.server.fastmcp import Context as MCPContext
from pydantic import Field
from hanzo_tools.core.base import BaseTool
@@ -35,14 +35,14 @@ Actions:
def _get_kms_client() -> Any:
"""Build a KMS client from environment."""
from hanzo_kms import ClientSettings, KMSClient
from hanzo_kms import KMSClient, ClientSettings
kms_url = os.getenv("HANZO_KMS_URL", "https://kms.hanzo.ai")
client_id = os.getenv("HANZO_KMS_CLIENT_ID", "")
client_secret = os.getenv("HANZO_KMS_CLIENT_SECRET", "")
if client_id and client_secret:
from hanzo_kms import AuthenticationOptions, UniversalAuthMethod
from hanzo_kms import UniversalAuthMethod, AuthenticationOptions
settings = ClientSettings(
site_url=kms_url,
@@ -14,7 +14,6 @@ Tool list (registered individually as MCP tools):
from mcp.server import FastMCP
from hanzo_tools.core import BaseTool, ToolRegistry
from hanzo_tools.memory.memory_tools import (
MEMORY_TOOL_CLASSES,
CreateMemoriesTool,
@@ -20,8 +20,8 @@ if TYPE_CHECKING:
# Use lazy loading from memory_tools
from hanzo_tools.memory.memory_tools import (
_check_memory_available,
_get_backend,
_check_memory_available,
_get_lazy_memory_service,
)
@@ -8,15 +8,14 @@ This is the default backend when hanzo-memory is not installed.
from __future__ import annotations
import json
import os
import re
from dataclasses import dataclass, field
from datetime import datetime
from pathlib import Path
from typing import Dict, List, Optional
import json
from uuid import uuid4
from typing import Dict, List, Optional
from pathlib import Path
from datetime import datetime
from dataclasses import field, dataclass
# Files to scan for context
CONTEXT_MD_FILES = [
@@ -7,7 +7,7 @@ the lightweight MarkdownMemoryBackend which reads from local .md files
IMPORTANT: All hanzo-memory imports are lazy to avoid slow startup.
"""
from typing import TYPE_CHECKING, Dict, List, Optional, Union, final, override
from typing import TYPE_CHECKING, Dict, List, Union, Optional, final, override
from mcp.server import FastMCP
from mcp.server.fastmcp import Context as MCPContext
@@ -11,11 +11,11 @@ from __future__ import annotations
import json
import logging
from typing import Annotated, Any, final
from typing import Any, Annotated, final
from pydantic import Field
from mcp.server import FastMCP
from mcp.server.fastmcp import Context as MCPContext
from pydantic import Field
from hanzo_tools.core.base import BaseTool
@@ -11,11 +11,11 @@ from __future__ import annotations
import json
import logging
from typing import Annotated, Any, final
from typing import Any, Annotated, final
from pydantic import Field
from mcp.server import FastMCP
from mcp.server.fastmcp import Context as MCPContext
from pydantic import Field
from hanzo_tools.core.base import BaseTool
@@ -9,15 +9,15 @@ Backend: Hanzo Team service.
from __future__ import annotations
import os
import json
import logging
import os
from typing import Annotated, Any, final
from typing import Any, Annotated, final
import httpx
from pydantic import Field
from mcp.server import FastMCP
from mcp.server.fastmcp import Context as MCPContext
from pydantic import Field
from hanzo_tools.core.base import BaseTool
+47 -47
View File
@@ -34,96 +34,96 @@ from ._response import (
async_to_streamed_response_wrapper,
)
from .resources import (
add,
billing,
db,
dns,
pages,
kms,
kv,
add,
dns,
iam,
kms,
mpc,
cart,
edge,
jobs,
paas,
pods,
test,
user,
azure,
spend,
utils,
active,
access,
agents,
audit,
budget,
azure,
build,
cart,
chain,
docdb,
miner,
nodes,
pages,
spend,
tasks,
utils,
access,
active,
agents,
budget,
cohere,
commerce,
coupons,
delete,
device,
docdb,
edge,
gemini,
graphs,
health,
iam,
ingress,
jobs,
models,
miner,
nodes,
orders,
paas,
pods,
policy,
pubsub,
queues,
rerank,
routes,
stores,
tasks,
tokens,
tunnel,
bedrock,
campaigns,
checkout,
containers,
customer,
datastore,
deployments,
billing,
coupons,
gateway,
identity,
inference,
langfuse,
machines,
mcp_servers,
ingress,
network,
observability,
products,
provider,
providers,
referrals,
registry,
release,
secrets,
settings,
storage,
subscriptions,
team_workspace,
vectors,
wallets,
checkout,
commerce,
customer,
identity,
langfuse,
machines,
products,
provider,
registry,
settings,
anthropic,
campaigns,
datastore,
inference,
providers,
referrals,
vertex_ai,
workflows,
affiliates,
anthropic,
vertex_ai,
assemblyai,
assistants,
containers,
embeddings,
guardrails,
completions,
credentials,
deployments,
mcp_servers,
model_group,
moderations,
eu_assemblyai,
observability,
subscriptions,
team_workspace,
)
from ._streaming import Stream as Stream, AsyncStream as AsyncStream
from ._exceptions import HanzoError, APIStatusError
+86 -86
View File
@@ -33,13 +33,15 @@ from .dns import (
DNSResourceWithStreamingResponse,
AsyncDNSResourceWithStreamingResponse,
)
from .pages import (
PagesResource,
AsyncPagesResource,
PagesResourceWithRawResponse,
AsyncPagesResourceWithRawResponse,
PagesResourceWithStreamingResponse,
AsyncPagesResourceWithStreamingResponse,
# IAM Resources
from .iam import (
IAMResource,
AsyncIAMResource,
IAMResourceWithRawResponse,
AsyncIAMResourceWithRawResponse,
IAMResourceWithStreamingResponse,
AsyncIAMResourceWithStreamingResponse,
)
from .key import (
KeyResource,
@@ -57,6 +59,16 @@ from .kms import (
KMSResourceWithStreamingResponse,
AsyncKMSResourceWithStreamingResponse,
)
# New Platform Resources
from .mpc import (
MPCResource,
AsyncMPCResource,
MPCResourceWithRawResponse,
AsyncMPCResourceWithRawResponse,
MPCResourceWithStreamingResponse,
AsyncMPCResourceWithStreamingResponse,
)
from .cart import (
CartResource,
AsyncCartResource,
@@ -91,6 +103,14 @@ from .jobs import (
JobsResourceWithStreamingResponse,
AsyncJobsResourceWithStreamingResponse,
)
from .paas import (
PaaSResource,
AsyncPaaSResource,
PaaSResourceWithRawResponse,
AsyncPaaSResourceWithRawResponse,
PaaSResourceWithStreamingResponse,
AsyncPaaSResourceWithStreamingResponse,
)
from .pods import (
PodsResource,
AsyncPodsResource,
@@ -175,6 +195,14 @@ from .chain import (
ChainResourceWithStreamingResponse,
AsyncChainResourceWithStreamingResponse,
)
from .docdb import (
DocDBResource,
AsyncDocDBResource,
DocDBResourceWithRawResponse,
AsyncDocDBResourceWithRawResponse,
DocDBResourceWithStreamingResponse,
AsyncDocDBResourceWithStreamingResponse,
)
from .files import (
FilesResource,
AsyncFilesResource,
@@ -207,6 +235,14 @@ from .nodes import (
NodesResourceWithStreamingResponse,
AsyncNodesResourceWithStreamingResponse,
)
from .pages import (
PagesResource,
AsyncPagesResource,
PagesResourceWithRawResponse,
AsyncPagesResourceWithRawResponse,
PagesResourceWithStreamingResponse,
AsyncPagesResourceWithStreamingResponse,
)
from .spend import (
SpendResource,
AsyncSpendResource,
@@ -433,6 +469,16 @@ from .bedrock import (
BedrockResourceWithStreamingResponse,
AsyncBedrockResourceWithStreamingResponse,
)
# Billing Resources
from .billing import (
BillingResource,
AsyncBillingResource,
BillingResourceWithRawResponse,
AsyncBillingResourceWithRawResponse,
BillingResourceWithStreamingResponse,
AsyncBillingResourceWithStreamingResponse,
)
from .coupons import (
CouponsResource,
AsyncCouponsResource,
@@ -465,6 +511,14 @@ from .global_ import (
GlobalResourceWithStreamingResponse,
AsyncGlobalResourceWithStreamingResponse,
)
from .ingress import (
IngressResource,
AsyncIngressResource,
IngressResourceWithRawResponse,
AsyncIngressResourceWithRawResponse,
IngressResourceWithStreamingResponse,
AsyncIngressResourceWithStreamingResponse,
)
# Network/Blockchain Resources
from .network import (
@@ -533,6 +587,16 @@ from .checkout import (
CheckoutResourceWithStreamingResponse,
AsyncCheckoutResourceWithStreamingResponse,
)
# Commerce Resources (unified)
from .commerce import (
CommerceResource,
AsyncCommerceResource,
CommerceResourceWithRawResponse,
AsyncCommerceResourceWithRawResponse,
CommerceResourceWithStreamingResponse,
AsyncCommerceResourceWithStreamingResponse,
)
from .customer import (
CustomerResource,
AsyncCustomerResource,
@@ -619,6 +683,14 @@ from .campaigns import (
CampaignsResourceWithStreamingResponse,
AsyncCampaignsResourceWithStreamingResponse,
)
from .datastore import (
DatastoreResource,
AsyncDatastoreResource,
DatastoreResourceWithRawResponse,
AsyncDatastoreResourceWithRawResponse,
DatastoreResourceWithStreamingResponse,
AsyncDatastoreResourceWithStreamingResponse,
)
# AI Runtime Resources
from .inference import (
@@ -801,35 +873,13 @@ from .observability import (
ObservabilityResourceWithStreamingResponse,
AsyncObservabilityResourceWithStreamingResponse,
)
# Billing Resources
from .billing import (
BillingResource,
AsyncBillingResource,
BillingResourceWithRawResponse,
AsyncBillingResourceWithRawResponse,
BillingResourceWithStreamingResponse,
AsyncBillingResourceWithStreamingResponse,
)
# IAM Resources
from .iam import (
IAMResource,
AsyncIAMResource,
IAMResourceWithRawResponse,
AsyncIAMResourceWithRawResponse,
IAMResourceWithStreamingResponse,
AsyncIAMResourceWithStreamingResponse,
)
# Commerce Resources (unified)
from .commerce import (
CommerceResource,
AsyncCommerceResource,
CommerceResourceWithRawResponse,
AsyncCommerceResourceWithRawResponse,
CommerceResourceWithStreamingResponse,
AsyncCommerceResourceWithStreamingResponse,
from .subscriptions import (
SubscriptionsResource,
AsyncSubscriptionsResource,
SubscriptionsResourceWithRawResponse,
AsyncSubscriptionsResourceWithRawResponse,
SubscriptionsResourceWithStreamingResponse,
AsyncSubscriptionsResourceWithStreamingResponse,
)
# Team Workspace Resources
@@ -842,56 +892,6 @@ from .team_workspace import (
AsyncTeamWorkspaceResourceWithStreamingResponse,
)
# New Platform Resources
from .mpc import (
MPCResource,
AsyncMPCResource,
MPCResourceWithRawResponse,
AsyncMPCResourceWithRawResponse,
MPCResourceWithStreamingResponse,
AsyncMPCResourceWithStreamingResponse,
)
from .paas import (
PaaSResource,
AsyncPaaSResource,
PaaSResourceWithRawResponse,
AsyncPaaSResourceWithRawResponse,
PaaSResourceWithStreamingResponse,
AsyncPaaSResourceWithStreamingResponse,
)
from .docdb import (
DocDBResource,
AsyncDocDBResource,
DocDBResourceWithRawResponse,
AsyncDocDBResourceWithRawResponse,
DocDBResourceWithStreamingResponse,
AsyncDocDBResourceWithStreamingResponse,
)
from .ingress import (
IngressResource,
AsyncIngressResource,
IngressResourceWithRawResponse,
AsyncIngressResourceWithRawResponse,
IngressResourceWithStreamingResponse,
AsyncIngressResourceWithStreamingResponse,
)
from .datastore import (
DatastoreResource,
AsyncDatastoreResource,
DatastoreResourceWithRawResponse,
AsyncDatastoreResourceWithRawResponse,
DatastoreResourceWithStreamingResponse,
AsyncDatastoreResourceWithStreamingResponse,
)
from .subscriptions import (
SubscriptionsResource,
AsyncSubscriptionsResource,
SubscriptionsResourceWithRawResponse,
AsyncSubscriptionsResourceWithRawResponse,
SubscriptionsResourceWithStreamingResponse,
AsyncSubscriptionsResourceWithStreamingResponse,
)
__all__ = [
"ModelsResource",
"AsyncModelsResource",