Skip to content

Commit 1b35b96

Browse files
committed
Simplify the inheritance
1 parent 4935867 commit 1b35b96

35 files changed

+562
-423
lines changed

src/apify_client/_logging.py

Lines changed: 6 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,9 @@
1111
if TYPE_CHECKING:
1212
from collections.abc import Callable
1313

14-
from apify_client._resource_clients.base import BaseBaseClient
14+
from apify_client._resource_clients.base import BaseClient, BaseCollectionClient
15+
16+
_BaseClient = BaseClient | BaseCollectionClient
1517

1618

1719
logger_name = __name__.split('.')[0]
@@ -111,7 +113,7 @@ def _injects_client_details_to_log_context(fun: Callable) -> Callable:
111113
if inspect.iscoroutinefunction(fun):
112114

113115
@functools.wraps(fun)
114-
async def async_wrapper(resource_client: BaseBaseClient, *args: Any, **kwargs: Any) -> Any:
116+
async def async_wrapper(resource_client: _BaseClient, *args: Any, **kwargs: Any) -> Any:
115117
log_context.client_method.set(fun.__qualname__) # ty: ignore[unresolved-attribute]
116118
log_context.resource_id.set(resource_client.resource_id)
117119

@@ -122,7 +124,7 @@ async def async_wrapper(resource_client: BaseBaseClient, *args: Any, **kwargs: A
122124
if inspect.isasyncgenfunction(fun):
123125

124126
@functools.wraps(fun)
125-
async def async_generator_wrapper(resource_client: BaseBaseClient, *args: Any, **kwargs: Any) -> Any:
127+
async def async_generator_wrapper(resource_client: _BaseClient, *args: Any, **kwargs: Any) -> Any:
126128
log_context.client_method.set(fun.__qualname__) # ty: ignore[unresolved-attribute]
127129
log_context.resource_id.set(resource_client.resource_id)
128130

@@ -132,7 +134,7 @@ async def async_generator_wrapper(resource_client: BaseBaseClient, *args: Any, *
132134
return async_generator_wrapper
133135

134136
@functools.wraps(fun)
135-
def wrapper(resource_client: BaseBaseClient, *args: Any, **kwargs: Any) -> Any:
137+
def wrapper(resource_client: _BaseClient, *args: Any, **kwargs: Any) -> Any:
136138
log_context.client_method.set(fun.__qualname__) # ty: ignore[unresolved-attribute]
137139
log_context.resource_id.set(resource_client.resource_id)
138140

src/apify_client/_resource_clients/__init__.py

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,6 @@
44
from .actor_env_var_collection import ActorEnvVarCollectionClient, ActorEnvVarCollectionClientAsync
55
from .actor_version import ActorVersionClient, ActorVersionClientAsync
66
from .actor_version_collection import ActorVersionCollectionClient, ActorVersionCollectionClientAsync
7-
from .base import ActorJobBaseClient, ActorJobBaseClientAsync
87
from .build import BuildClient, BuildClientAsync
98
from .build_collection import BuildCollectionClient, BuildCollectionClientAsync
109
from .dataset import DatasetClient, DatasetClientAsync
@@ -36,8 +35,6 @@
3635
'ActorEnvVarClientAsync',
3736
'ActorEnvVarCollectionClient',
3837
'ActorEnvVarCollectionClientAsync',
39-
'ActorJobBaseClient',
40-
'ActorJobBaseClientAsync',
4138
'ActorVersionClient',
4239
'ActorVersionClientAsync',
4340
'ActorVersionCollectionClient',

src/apify_client/_resource_clients/actor.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -18,7 +18,7 @@
1818
ActorVersionCollectionClient,
1919
ActorVersionCollectionClientAsync,
2020
)
21-
from apify_client._resource_clients.base import ResourceClient, ResourceClientAsync
21+
from apify_client._resource_clients.base import BaseClient, BaseClientAsync
2222
from apify_client._resource_clients.build import BuildClient, BuildClientAsync
2323
from apify_client._resource_clients.build_collection import (
2424
BuildCollectionClient,
@@ -140,7 +140,7 @@ def get_actor_representation(
140140
return actor_dict
141141

142142

143-
class ActorClient(ResourceClient):
143+
class ActorClient(BaseClient):
144144
"""Sub-client for manipulating a single Actor."""
145145

146146
def __init__(self, *args: Any, **kwargs: Any) -> None:
@@ -566,7 +566,7 @@ def validate_input(
566566
return True
567567

568568

569-
class ActorClientAsync(ResourceClientAsync):
569+
class ActorClientAsync(BaseClientAsync):
570570
"""Async sub-client for manipulating a single Actor."""
571571

572572
def __init__(self, *args: Any, **kwargs: Any) -> None:

src/apify_client/_resource_clients/actor_collection.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -4,11 +4,11 @@
44

55
from apify_client._models import Actor, CreateActorResponse, GetListOfActorsResponse, ListOfActors
66
from apify_client._resource_clients.actor import get_actor_representation
7-
from apify_client._resource_clients.base import ResourceCollectionClient, ResourceCollectionClientAsync
7+
from apify_client._resource_clients.base import BaseCollectionClient, BaseCollectionClientAsync
88
from apify_client._utils import filter_out_none_values_recursively, response_to_dict
99

1010

11-
class ActorCollectionClient(ResourceCollectionClient):
11+
class ActorCollectionClient(BaseCollectionClient):
1212
"""Sub-client for manipulating Actors."""
1313

1414
def __init__(self, *args: Any, **kwargs: Any) -> None:
@@ -140,7 +140,7 @@ def create(
140140
return CreateActorResponse.model_validate(result).data
141141

142142

143-
class ActorCollectionClientAsync(ResourceCollectionClientAsync):
143+
class ActorCollectionClientAsync(BaseCollectionClientAsync):
144144
"""Async sub-client for manipulating Actors."""
145145

146146
def __init__(self, *args: Any, **kwargs: Any) -> None:

src/apify_client/_resource_clients/actor_env_var.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@
33
from typing import Any
44

55
from apify_client._models import EnvVar, GetEnvVarResponse
6-
from apify_client._resource_clients.base import ResourceClient, ResourceClientAsync
6+
from apify_client._resource_clients.base import BaseClient, BaseClientAsync
77
from apify_client._utils import filter_out_none_values_recursively
88

99

@@ -21,7 +21,7 @@ def get_actor_env_var_representation(
2121
}
2222

2323

24-
class ActorEnvVarClient(ResourceClient):
24+
class ActorEnvVarClient(BaseClient):
2525
"""Sub-client for manipulating a single Actor environment variable."""
2626

2727
def __init__(self, *args: Any, **kwargs: Any) -> None:
@@ -75,7 +75,7 @@ def delete(self) -> None:
7575
return self._delete()
7676

7777

78-
class ActorEnvVarClientAsync(ResourceClientAsync):
78+
class ActorEnvVarClientAsync(BaseClientAsync):
7979
"""Async sub-client for manipulating a single Actor environment variable."""
8080

8181
def __init__(self, *args: Any, **kwargs: Any) -> None:

src/apify_client/_resource_clients/actor_env_var_collection.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -4,11 +4,11 @@
44

55
from apify_client._models import EnvVar, GetEnvVarResponse, GetListOfEnvVarsResponse, ListOfEnvVars
66
from apify_client._resource_clients.actor_env_var import get_actor_env_var_representation
7-
from apify_client._resource_clients.base import ResourceCollectionClient, ResourceCollectionClientAsync
7+
from apify_client._resource_clients.base import BaseCollectionClient, BaseCollectionClientAsync
88
from apify_client._utils import filter_out_none_values_recursively, response_to_dict
99

1010

11-
class ActorEnvVarCollectionClient(ResourceCollectionClient):
11+
class ActorEnvVarCollectionClient(BaseCollectionClient):
1212
"""Sub-client for manipulating actor env vars."""
1313

1414
def __init__(self, *args: Any, **kwargs: Any) -> None:
@@ -60,7 +60,7 @@ def create(
6060
return GetEnvVarResponse.model_validate(result).data
6161

6262

63-
class ActorEnvVarCollectionClientAsync(ResourceCollectionClientAsync):
63+
class ActorEnvVarCollectionClientAsync(BaseCollectionClientAsync):
6464
"""Async sub-client for manipulating actor env vars."""
6565

6666
def __init__(self, *args: Any, **kwargs: Any) -> None:

src/apify_client/_resource_clients/actor_version.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,7 @@
88
ActorEnvVarCollectionClient,
99
ActorEnvVarCollectionClientAsync,
1010
)
11-
from apify_client._resource_clients.base import ResourceClient, ResourceClientAsync
11+
from apify_client._resource_clients.base import BaseClient, BaseClientAsync
1212
from apify_client._utils import filter_out_none_values_recursively, maybe_extract_enum_member_value
1313

1414

@@ -37,7 +37,7 @@ def _get_actor_version_representation(
3737
}
3838

3939

40-
class ActorVersionClient(ResourceClient):
40+
class ActorVersionClient(BaseClient):
4141
"""Sub-client for manipulating a single Actor version."""
4242

4343
def __init__(self, *args: Any, **kwargs: Any) -> None:
@@ -127,7 +127,7 @@ def env_var(self, env_var_name: str) -> ActorEnvVarClient:
127127
return ActorEnvVarClient(**self._sub_resource_init_options(resource_id=env_var_name))
128128

129129

130-
class ActorVersionClientAsync(ResourceClientAsync):
130+
class ActorVersionClientAsync(BaseClientAsync):
131131
"""Async sub-client for manipulating a single Actor version."""
132132

133133
def __init__(self, *args: Any, **kwargs: Any) -> None:

src/apify_client/_resource_clients/actor_version_collection.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -10,11 +10,11 @@
1010
VersionSourceType,
1111
)
1212
from apify_client._resource_clients.actor_version import _get_actor_version_representation
13-
from apify_client._resource_clients.base import ResourceCollectionClient, ResourceCollectionClientAsync
13+
from apify_client._resource_clients.base import BaseCollectionClient, BaseCollectionClientAsync
1414
from apify_client._utils import filter_out_none_values_recursively, response_to_dict
1515

1616

17-
class ActorVersionCollectionClient(ResourceCollectionClient):
17+
class ActorVersionCollectionClient(BaseCollectionClient):
1818
"""Sub-client for manipulating Actor versions."""
1919

2020
def __init__(self, *args: Any, **kwargs: Any) -> None:
@@ -90,7 +90,7 @@ def create(
9090
return GetVersionResponse.model_validate(result).data
9191

9292

93-
class ActorVersionCollectionClientAsync(ResourceCollectionClientAsync):
93+
class ActorVersionCollectionClientAsync(BaseCollectionClientAsync):
9494
"""Async sub-client for manipulating Actor versions."""
9595

9696
def __init__(self, *args: Any, **kwargs: Any) -> None:
Lines changed: 4 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -1,16 +1,9 @@
1-
from .actor_job_base_client import ActorJobBaseClient, ActorJobBaseClientAsync
2-
from .base_client import BaseBaseClient, BaseClient, BaseClientAsync
3-
from .resource_client import ResourceClient, ResourceClientAsync
4-
from .resource_collection_client import ResourceCollectionClient, ResourceCollectionClientAsync
1+
from .base_client import BaseClient, BaseClientAsync
2+
from .base_collection_client import BaseCollectionClient, BaseCollectionClientAsync
53

64
__all__ = [
7-
'ActorJobBaseClient',
8-
'ActorJobBaseClientAsync',
9-
'BaseBaseClient',
105
'BaseClient',
116
'BaseClientAsync',
12-
'ResourceClient',
13-
'ResourceClientAsync',
14-
'ResourceCollectionClient',
15-
'ResourceCollectionClientAsync',
7+
'BaseCollectionClient',
8+
'BaseCollectionClientAsync',
169
]

src/apify_client/_resource_clients/base/actor_job_base_client.py

Lines changed: 0 additions & 133 deletions
This file was deleted.

0 commit comments

Comments
 (0)