Skip to content

Commit 7f1d3fb

Browse files
chore: format files
1 parent f5b48f8 commit 7f1d3fb

File tree

7 files changed

+27
-21
lines changed

7 files changed

+27
-21
lines changed

volcenginesdkarkruntime/_utils/_utils.py

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -11,6 +11,7 @@
1111
cast,
1212
TypeVar,
1313
)
14+
1415
from typing_extensions import TypeGuard
1516

1617
from .._types import NotGiven
@@ -97,15 +98,18 @@ def wrapper(*args, **kwargs):
9798

9899
return wrapper
99100

101+
100102
def async_disallow_aksk(func):
101103
async def wrapper(*args, **kwargs):
102104
_restrict_aksk(args, kwargs)
103105
return await func(*args, **kwargs)
104106

105107
return wrapper
106108

109+
107110
def _restrict_aksk(args, kwargs):
108111
assert len(args) > 0
109112

110113
ark_client = args[0]._client
111-
assert ark_client.api_key is not None, "ak&sk authentication is currently not supported for this method, please use api key instead"
114+
assert ark_client.api_key is not None, \
115+
"ak&sk authentication is currently not supported for this method, please use api key instead"
Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,17 +1,17 @@
11
from __future__ import annotations
22

3-
from ..._resource import SyncAPIResource, AsyncAPIResource
4-
from ..._compat import cached_property
5-
63
from .tasks import Tasks, AsyncTasks
4+
from ..._compat import cached_property
5+
from ..._resource import SyncAPIResource, AsyncAPIResource
76

87

98
class ContentGeneration(SyncAPIResource):
109
@cached_property
1110
def tasks(self) -> Tasks:
1211
return Tasks(self._client)
1312

13+
1414
class AsyncContentGeneration(AsyncAPIResource):
1515
@cached_property
1616
def tasks(self) -> AsyncTasks:
17-
return AsyncTasks(self._client)
17+
return AsyncTasks(self._client)

volcenginesdkarkruntime/resources/content_generation/tasks.py

Lines changed: 9 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -2,16 +2,17 @@
22

33
from functools import cached_property
44
from typing import Iterable, Union, List
5+
56
import httpx
67

8+
from volcenginesdkarkruntime._base_client import make_request_options
9+
from volcenginesdkarkruntime._resource import SyncAPIResource, AsyncAPIResource
10+
from volcenginesdkarkruntime.types.content_generation.create_task_content_param import CreateTaskContentParam
711
from ..._response import to_raw_response_wrapper, async_to_raw_response_wrapper
812
from ..._types import Body, Query, Headers
913
from ..._utils._utils import disallow_aksk, async_disallow_aksk
1014
from ...types.content_generation.content_generation_task import ContentGenerationTask
1115
from ...types.content_generation.content_generation_task_id import ContentGenerationTaskID
12-
from volcenginesdkarkruntime._base_client import make_request_options
13-
from volcenginesdkarkruntime._resource import SyncAPIResource, AsyncAPIResource
14-
from volcenginesdkarkruntime.types.content_generation.create_task_content_param import CreateTaskContentParam
1516
from ...types.content_generation.list_content_generation_tasks_response import ListContentGenerationTasksResponse
1617

1718

@@ -56,7 +57,7 @@ def get(
5657
extra_query: Query | None = None,
5758
extra_body: Body | None = None,
5859
timeout: float | httpx.Timeout | None = None,
59-
) -> ContentGenerationTask:
60+
) -> ContentGenerationTask:
6061
resp = self._get(
6162
path=f"/contents/generations/tasks/{task_id}",
6263
options=make_request_options(
@@ -75,13 +76,13 @@ def list(
7576
page_num: int | None = None,
7677
page_size: int | None = None,
7778
status: str | None = None,
78-
task_ids : Union[List[str], str] | None = None,
79+
task_ids: Union[List[str], str] | None = None,
7980
model: str | None = None,
8081
extra_headers: Headers | None = None,
8182
extra_body: Body | None = None,
8283
extra_query: Query | None = None,
8384
timeout: float | httpx.Timeout | None = None,
84-
) -> ListContentGenerationTasksResponse:
85+
) -> ListContentGenerationTasksResponse:
8586

8687
query_params = []
8788
if page_num:
@@ -138,7 +139,6 @@ class AsyncTasks(AsyncAPIResource):
138139
def with_raw_response(self) -> AsyncTasksWithRawResponse:
139140
return AsyncTasksWithRawResponse(self)
140141

141-
142142
@async_disallow_aksk
143143
async def create(
144144
self,
@@ -166,7 +166,6 @@ async def create(
166166
)
167167
return resp
168168

169-
170169
@async_disallow_aksk
171170
async def get(
172171
self,
@@ -195,7 +194,7 @@ async def list(
195194
page_num: int | None = None,
196195
page_size: int | None = None,
197196
status: str | None = None,
198-
task_ids : Union[List[str], str] | None = None,
197+
task_ids: Union[List[str], str] | None = None,
199198
model: str | None = None,
200199
extra_headers: Headers | None = None,
201200
extra_body: Body | None = None,
@@ -261,6 +260,7 @@ def __init__(self, tasks: Tasks) -> None:
261260
tasks.create,
262261
)
263262

263+
264264
class AsyncTasksWithRawResponse:
265265
def __init__(self, tasks: AsyncTasks) -> None:
266266
self._tasks = tasks

volcenginesdkarkruntime/types/content_generation/content_generation_task.py

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,3 @@
1-
21
__all__ = ["ContentGenerationTask"]
32

43
from volcenginesdkarkruntime._models import BaseModel
@@ -8,10 +7,12 @@ class Usage(BaseModel):
87
completion_tokens: int
98
"""The number of tokens used for completion."""
109

10+
1111
class Content(BaseModel):
1212
video_url: str
1313
"""The URL of the generated video, if any."""
1414

15+
1516
class ContentGenerationTask(BaseModel):
1617
id: str
1718
"""A unique identifier for the task."""
@@ -35,4 +36,4 @@ class ContentGenerationTask(BaseModel):
3536
"""The Unix timestamp when the task was created."""
3637

3738
updated_at: int
38-
"""The Unix timestamp when the task was last updated."""
39+
"""The Unix timestamp when the task was last updated."""

volcenginesdkarkruntime/types/content_generation/create_task_content_param.py

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,7 @@
11
from __future__ import annotations
2+
23
from typing import Union
4+
35
from typing_extensions import Literal, TypedDict
46

57
__all__ = [

volcenginesdkarkruntime/types/content_generation/list_content_generation_tasks_response.py

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -47,4 +47,3 @@ class ListContentGenerationTasksResponse(BaseModel):
4747

4848
items: List[Item]
4949
"""List of content generation task items."""
50-

volcenginesdkexamples/volcenginesdkarkruntime/content_generation_tasks.py

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -13,11 +13,11 @@
1313
model="${YOUR_MODEL_EP}",
1414
content=[
1515
{
16-
"type":"text",
17-
"text":"龙与地下城女骑士背景是起伏的平原,目光从镜头转向平原"
16+
"type": "text",
17+
"text": "龙与地下城女骑士背景是起伏的平原,目光从镜头转向平原"
1818
},
1919
{
20-
"type":"image_url",
20+
"type": "image_url",
2121
"image_url": {
2222
"url": "${YOUR_IMAGE_URL}"
2323
},
@@ -45,4 +45,4 @@
4545
client.content_generation.tasks.delete(task_id=create_result.id)
4646
print(create_result.id)
4747
except Exception as e:
48-
print(f"failed to delete task: {e}")
48+
print(f"failed to delete task: {e}")

0 commit comments

Comments
 (0)