|
3 | 3 | from __future__ import annotations |
4 | 4 |
|
5 | 5 | from typing import Dict, List, Iterable, Optional |
6 | | -from typing_extensions import Self, Literal, override |
| 6 | +from typing_extensions import Self, Unpack, Literal, override |
7 | 7 |
|
8 | 8 | from ..types import ScenarioCreateParams, ScenarioEnvironmentParam |
| 9 | +from ._types import LongRequestOptions |
9 | 10 | from .._client import AsyncRunloop |
10 | 11 | from .async_scenario import AsyncScenario |
11 | 12 | from .async_snapshot import AsyncSnapshot |
@@ -443,13 +444,14 @@ def _build_params(self) -> ScenarioCreateParams: |
443 | 444 |
|
444 | 445 | return params |
445 | 446 |
|
446 | | - async def push(self) -> AsyncScenario: |
| 447 | + async def push(self, **options: Unpack[LongRequestOptions]) -> AsyncScenario: |
447 | 448 | """Create the scenario on the platform. |
448 | 449 |
|
| 450 | + :param options: Optional long-running request configuration |
449 | 451 | :raises ValueError: If required fields are missing |
450 | 452 | :return: Created scenario wrapper |
451 | 453 | :rtype: AsyncScenario |
452 | 454 | """ |
453 | 455 | params = self._build_params() |
454 | | - scenario_view = await self._client.scenarios.create(**params) |
| 456 | + scenario_view = await self._client.scenarios.create(**params, **options) |
455 | 457 | return AsyncScenario(self._client, scenario_view.id) |
0 commit comments