Feature migrate adapters to facade pattern

pyproject.toml

@@ -151,7 +151,9 @@ ignore = [
     # too-many-return-statements
     "PLR0911",
     # flake8-type-checking (150 errors)
-    "TC"
+    "TC",
+    # PT013: Arguments starting with underscore in function definitions starting with `test_` (e.g., test_connectivity in event_resource_api.py)
+    "PT019"
 ]
 
 [tool.ruff.lint.isort]
@@ -215,20 +217,10 @@ plugins = [
     "pydantic.mypy"
 ]
 disable_error_code = [
-    "no-redef",
-    "return-value",
-    "var-annotated",
     "assignment",
-    "call-arg",
     "arg-type",
-    "override",
-    "dict-item",
-    "index",
-    "operator",
-    "call-overload",
     "misc",
     "attr-defined",
-    "union-attr",
     "name-defined",
 ]
 

src/conductor/asyncio_client/adapters/api/admin_resource_api.py

@@ -1,4 +1,135 @@
+from __future__ import annotations
+
+from typing import Annotated, Any, Dict, List, Optional, Tuple, Union
+
+from pydantic import Field, StrictFloat, StrictInt, StrictStr
+
+from conductor.asyncio_client.adapters import ApiClient
+from conductor.asyncio_client.adapters.models.task_adapter import TaskAdapter
+from conductor.asyncio_client.adapters.utils import convert_list_to_adapter
 from conductor.asyncio_client.http.api import AdminResourceApi
 
 
-class AdminResourceApiAdapter(AdminResourceApi): ...
+class AdminResourceApiAdapter:
+    """Adapter for AdminResourceApi that converts between generated models and adapters."""
+
+    def __init__(self, api_client: ApiClient):
+        self._api = AdminResourceApi(api_client)
+
+    async def clear_task_execution_cache(
+        self,
+        task_def_name: StrictStr,
+        _request_timeout: Union[
+            None,
+            Annotated[StrictFloat, Field(gt=0)],
+            Tuple[Annotated[StrictFloat, Field(gt=0)], Annotated[StrictFloat, Field(gt=0)]],
+        ] = None,
+        _request_auth: Optional[Dict[StrictStr, Any]] = None,
+        _content_type: Optional[StrictStr] = None,
+        _headers: Optional[Dict[StrictStr, Any]] = None,
+        _host_index: Annotated[StrictInt, Field(ge=0, le=0)] = 0,
+    ) -> None:
+        """Clear the task execution cache"""
+        await self._api.clear_task_execution_cache(
+            task_def_name,
+            _request_timeout=_request_timeout,
+            _request_auth=_request_auth,
+            _content_type=_content_type,
+            _headers=_headers,
+            _host_index=_host_index,
+        )
+
+    async def get_redis_usage(
+        self,
+        _request_timeout: Union[
+            None,
+            Annotated[StrictFloat, Field(gt=0)],
+            Tuple[Annotated[StrictFloat, Field(gt=0)], Annotated[StrictFloat, Field(gt=0)]],
+        ] = None,
+        _request_auth: Optional[Dict[StrictStr, Any]] = None,
+        _content_type: Optional[StrictStr] = None,
+        _headers: Optional[Dict[StrictStr, Any]] = None,
+        _host_index: Annotated[StrictInt, Field(ge=0, le=0)] = 0,
+    ) -> Dict[str, object]:
+        """Get the Redis usage"""
+        return await self._api.get_redis_usage(
+            _request_timeout=_request_timeout,
+            _request_auth=_request_auth,
+            _content_type=_content_type,
+            _headers=_headers,
+            _host_index=_host_index,
+        )
+
+    async def requeue_sweep(
+        self,
+        workflow_id: StrictStr,
+        _request_timeout: Union[
+            None,
+            Annotated[StrictFloat, Field(gt=0)],
+            Tuple[Annotated[StrictFloat, Field(gt=0)], Annotated[StrictFloat, Field(gt=0)]],
+        ] = None,
+        _request_auth: Optional[Dict[StrictStr, Any]] = None,
+        _content_type: Optional[StrictStr] = None,
+        _headers: Optional[Dict[StrictStr, Any]] = None,
+        _host_index: Annotated[StrictInt, Field(ge=0, le=0)] = 0,
+    ) -> str:
+        """Requeue sweep"""
+        return await self._api.requeue_sweep(
+            workflow_id,
+            _request_timeout=_request_timeout,
+            _request_auth=_request_auth,
+            _content_type=_content_type,
+            _headers=_headers,
+            _host_index=_host_index,
+        )
+
+    async def verify_and_repair_workflow_consistency(
+        self,
+        workflow_id: StrictStr,
+        _request_timeout: Union[
+            None,
+            Annotated[StrictFloat, Field(gt=0)],
+            Tuple[Annotated[StrictFloat, Field(gt=0)], Annotated[StrictFloat, Field(gt=0)]],
+        ] = None,
+        _request_auth: Optional[Dict[StrictStr, Any]] = None,
+        _content_type: Optional[StrictStr] = None,
+        _headers: Optional[Dict[StrictStr, Any]] = None,
+        _host_index: Annotated[StrictInt, Field(ge=0, le=0)] = 0,
+    ) -> str:
+        """Verify and repair workflow consistency"""
+        return await self._api.verify_and_repair_workflow_consistency(
+            workflow_id,
+            _request_timeout=_request_timeout,
+            _request_auth=_request_auth,
+            _content_type=_content_type,
+            _headers=_headers,
+            _host_index=_host_index,
+        )
+
+    async def view(
+        self,
+        tasktype: StrictStr,
+        start: Optional[StrictInt] = None,
+        count: Optional[StrictInt] = None,
+        _request_timeout: Union[
+            None,
+            Annotated[StrictFloat, Field(gt=0)],
+            Tuple[Annotated[StrictFloat, Field(gt=0)], Annotated[StrictFloat, Field(gt=0)]],
+        ] = None,
+        _request_auth: Optional[Dict[StrictStr, Any]] = None,
+        _content_type: Optional[StrictStr] = None,
+        _headers: Optional[Dict[StrictStr, Any]] = None,
+        _host_index: Annotated[StrictInt, Field(ge=0, le=0)] = 0,
+    ) -> List[TaskAdapter]:
+        """View tasks"""
+        result = await self._api.view(
+            tasktype,
+            start,
+            count,
+            _request_timeout=_request_timeout,
+            _request_auth=_request_auth,
+            _content_type=_content_type,
+            _headers=_headers,
+            _host_index=_host_index,
+        )
+        return convert_list_to_adapter(result, TaskAdapter)