Skip to content

Commit 38ccc6b

Browse files
committed
Pass auth_options to op.update
1 parent 92d0bff commit 38ccc6b

3 files changed

Lines changed: 10 additions & 3 deletions

File tree

pyproject.toml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -190,7 +190,7 @@ oci = [
190190
"dstack[server]",
191191
]
192192
nebius = [
193-
"nebius>=0.3.0,<0.4; python_version >= '3.10'",
193+
"nebius>=0.3.4,<0.4; python_version >= '3.10'",
194194
"dstack[server]",
195195
]
196196
all = [

src/dstack/_internal/core/backends/nebius/compute.py

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -379,7 +379,12 @@ def _wait_for_instance(sdk: SDK, op: SDKOperation[Operation]) -> None:
379379
op.status(),
380380
)
381381
time.sleep(WAIT_FOR_INSTANCE_UPDATE_INTERVAL)
382-
resources.LOOP.await_(op.update(per_retry_timeout=resources.REQUEST_TIMEOUT))
382+
resources.LOOP.await_(
383+
op.update(
384+
per_retry_timeout=resources.REQUEST_TIMEOUT,
385+
auth_options=resources.REQUEST_AUTH_OPTIONS,
386+
)
387+
)
383388

384389

385390
def _supported_instances(offer: InstanceOffer) -> bool:

src/dstack/_internal/core/backends/nebius/resources.py

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -117,7 +117,9 @@ def wait_for_operation(
117117
if time.monotonic() + interval > deadline:
118118
raise TimeoutError(f"Operation {op.id} wait timeout")
119119
time.sleep(interval)
120-
LOOP.await_(op.update(per_retry_timeout=REQUEST_TIMEOUT))
120+
LOOP.await_(
121+
op.update(per_retry_timeout=REQUEST_TIMEOUT, auth_options=REQUEST_AUTH_OPTIONS)
122+
)
121123

122124

123125
def get_region_to_project_id_map(

0 commit comments

Comments
 (0)