|
2 | 2 |
|
3 | 3 | from __future__ import annotations |
4 | 4 |
|
| 5 | +import typing_extensions |
5 | 6 | from typing import Any, Dict, List, Union, Iterable, Optional, cast |
6 | 7 | from itertools import chain |
7 | 8 | from typing_extensions import Literal |
@@ -59,6 +60,7 @@ def with_streaming_response(self) -> TaskGroupResourceWithStreamingResponse: |
59 | 60 | """ |
60 | 61 | return TaskGroupResourceWithStreamingResponse(self) |
61 | 62 |
|
| 63 | + @typing_extensions.deprecated("Use GA Task Group instead") |
62 | 64 | def create( |
63 | 65 | self, |
64 | 66 | *, |
@@ -94,6 +96,7 @@ def create( |
94 | 96 | cast_to=TaskGroup, |
95 | 97 | ) |
96 | 98 |
|
| 99 | + @typing_extensions.deprecated("Use GA Task Group instead") |
97 | 100 | def retrieve( |
98 | 101 | self, |
99 | 102 | task_group_id: str, |
@@ -128,6 +131,7 @@ def retrieve( |
128 | 131 | cast_to=TaskGroup, |
129 | 132 | ) |
130 | 133 |
|
| 134 | + @typing_extensions.deprecated("Use GA Task Group instead") |
131 | 135 | def add_runs( |
132 | 136 | self, |
133 | 137 | task_group_id: str, |
@@ -201,6 +205,7 @@ def add_runs( |
201 | 205 | cast_to=TaskGroupRunResponse, |
202 | 206 | ) |
203 | 207 |
|
| 208 | + @typing_extensions.deprecated("Use GA Task Group instead") |
204 | 209 | def events( |
205 | 210 | self, |
206 | 211 | task_group_id: str, |
@@ -255,6 +260,7 @@ def events( |
255 | 260 | stream_cls=Stream[TaskGroupEventsResponse], |
256 | 261 | ) |
257 | 262 |
|
| 263 | + @typing_extensions.deprecated("Use GA Task Group instead") |
258 | 264 | def get_runs( |
259 | 265 | self, |
260 | 266 | task_group_id: str, |
@@ -345,6 +351,7 @@ def with_streaming_response(self) -> AsyncTaskGroupResourceWithStreamingResponse |
345 | 351 | """ |
346 | 352 | return AsyncTaskGroupResourceWithStreamingResponse(self) |
347 | 353 |
|
| 354 | + @typing_extensions.deprecated("Use GA Task Group instead") |
348 | 355 | async def create( |
349 | 356 | self, |
350 | 357 | *, |
@@ -380,6 +387,7 @@ async def create( |
380 | 387 | cast_to=TaskGroup, |
381 | 388 | ) |
382 | 389 |
|
| 390 | + @typing_extensions.deprecated("Use GA Task Group instead") |
383 | 391 | async def retrieve( |
384 | 392 | self, |
385 | 393 | task_group_id: str, |
@@ -414,6 +422,7 @@ async def retrieve( |
414 | 422 | cast_to=TaskGroup, |
415 | 423 | ) |
416 | 424 |
|
| 425 | + @typing_extensions.deprecated("Use GA Task Group instead") |
417 | 426 | async def add_runs( |
418 | 427 | self, |
419 | 428 | task_group_id: str, |
@@ -487,6 +496,7 @@ async def add_runs( |
487 | 496 | cast_to=TaskGroupRunResponse, |
488 | 497 | ) |
489 | 498 |
|
| 499 | + @typing_extensions.deprecated("Use GA Task Group instead") |
490 | 500 | async def events( |
491 | 501 | self, |
492 | 502 | task_group_id: str, |
@@ -541,6 +551,7 @@ async def events( |
541 | 551 | stream_cls=AsyncStream[TaskGroupEventsResponse], |
542 | 552 | ) |
543 | 553 |
|
| 554 | + @typing_extensions.deprecated("Use GA Task Group instead") |
544 | 555 | async def get_runs( |
545 | 556 | self, |
546 | 557 | task_group_id: str, |
@@ -613,81 +624,121 @@ class TaskGroupResourceWithRawResponse: |
613 | 624 | def __init__(self, task_group: TaskGroupResource) -> None: |
614 | 625 | self._task_group = task_group |
615 | 626 |
|
616 | | - self.create = to_raw_response_wrapper( |
617 | | - task_group.create, |
| 627 | + self.create = ( # pyright: ignore[reportDeprecated] |
| 628 | + to_raw_response_wrapper( |
| 629 | + task_group.create, # pyright: ignore[reportDeprecated], |
| 630 | + ) |
618 | 631 | ) |
619 | | - self.retrieve = to_raw_response_wrapper( |
620 | | - task_group.retrieve, |
| 632 | + self.retrieve = ( # pyright: ignore[reportDeprecated] |
| 633 | + to_raw_response_wrapper( |
| 634 | + task_group.retrieve, # pyright: ignore[reportDeprecated], |
| 635 | + ) |
621 | 636 | ) |
622 | | - self.add_runs = to_raw_response_wrapper( |
623 | | - task_group.add_runs, |
| 637 | + self.add_runs = ( # pyright: ignore[reportDeprecated] |
| 638 | + to_raw_response_wrapper( |
| 639 | + task_group.add_runs, # pyright: ignore[reportDeprecated], |
| 640 | + ) |
624 | 641 | ) |
625 | | - self.events = to_raw_response_wrapper( |
626 | | - task_group.events, |
| 642 | + self.events = ( # pyright: ignore[reportDeprecated] |
| 643 | + to_raw_response_wrapper( |
| 644 | + task_group.events, # pyright: ignore[reportDeprecated], |
| 645 | + ) |
627 | 646 | ) |
628 | | - self.get_runs = to_raw_response_wrapper( |
629 | | - task_group.get_runs, |
| 647 | + self.get_runs = ( # pyright: ignore[reportDeprecated] |
| 648 | + to_raw_response_wrapper( |
| 649 | + task_group.get_runs, # pyright: ignore[reportDeprecated], |
| 650 | + ) |
630 | 651 | ) |
631 | 652 |
|
632 | 653 |
|
633 | 654 | class AsyncTaskGroupResourceWithRawResponse: |
634 | 655 | def __init__(self, task_group: AsyncTaskGroupResource) -> None: |
635 | 656 | self._task_group = task_group |
636 | 657 |
|
637 | | - self.create = async_to_raw_response_wrapper( |
638 | | - task_group.create, |
| 658 | + self.create = ( # pyright: ignore[reportDeprecated] |
| 659 | + async_to_raw_response_wrapper( |
| 660 | + task_group.create, # pyright: ignore[reportDeprecated], |
| 661 | + ) |
639 | 662 | ) |
640 | | - self.retrieve = async_to_raw_response_wrapper( |
641 | | - task_group.retrieve, |
| 663 | + self.retrieve = ( # pyright: ignore[reportDeprecated] |
| 664 | + async_to_raw_response_wrapper( |
| 665 | + task_group.retrieve, # pyright: ignore[reportDeprecated], |
| 666 | + ) |
642 | 667 | ) |
643 | | - self.add_runs = async_to_raw_response_wrapper( |
644 | | - task_group.add_runs, |
| 668 | + self.add_runs = ( # pyright: ignore[reportDeprecated] |
| 669 | + async_to_raw_response_wrapper( |
| 670 | + task_group.add_runs, # pyright: ignore[reportDeprecated], |
| 671 | + ) |
645 | 672 | ) |
646 | | - self.events = async_to_raw_response_wrapper( |
647 | | - task_group.events, |
| 673 | + self.events = ( # pyright: ignore[reportDeprecated] |
| 674 | + async_to_raw_response_wrapper( |
| 675 | + task_group.events, # pyright: ignore[reportDeprecated], |
| 676 | + ) |
648 | 677 | ) |
649 | | - self.get_runs = async_to_raw_response_wrapper( |
650 | | - task_group.get_runs, |
| 678 | + self.get_runs = ( # pyright: ignore[reportDeprecated] |
| 679 | + async_to_raw_response_wrapper( |
| 680 | + task_group.get_runs, # pyright: ignore[reportDeprecated], |
| 681 | + ) |
651 | 682 | ) |
652 | 683 |
|
653 | 684 |
|
654 | 685 | class TaskGroupResourceWithStreamingResponse: |
655 | 686 | def __init__(self, task_group: TaskGroupResource) -> None: |
656 | 687 | self._task_group = task_group |
657 | 688 |
|
658 | | - self.create = to_streamed_response_wrapper( |
659 | | - task_group.create, |
| 689 | + self.create = ( # pyright: ignore[reportDeprecated] |
| 690 | + to_streamed_response_wrapper( |
| 691 | + task_group.create, # pyright: ignore[reportDeprecated], |
| 692 | + ) |
660 | 693 | ) |
661 | | - self.retrieve = to_streamed_response_wrapper( |
662 | | - task_group.retrieve, |
| 694 | + self.retrieve = ( # pyright: ignore[reportDeprecated] |
| 695 | + to_streamed_response_wrapper( |
| 696 | + task_group.retrieve, # pyright: ignore[reportDeprecated], |
| 697 | + ) |
663 | 698 | ) |
664 | | - self.add_runs = to_streamed_response_wrapper( |
665 | | - task_group.add_runs, |
| 699 | + self.add_runs = ( # pyright: ignore[reportDeprecated] |
| 700 | + to_streamed_response_wrapper( |
| 701 | + task_group.add_runs, # pyright: ignore[reportDeprecated], |
| 702 | + ) |
666 | 703 | ) |
667 | | - self.events = to_streamed_response_wrapper( |
668 | | - task_group.events, |
| 704 | + self.events = ( # pyright: ignore[reportDeprecated] |
| 705 | + to_streamed_response_wrapper( |
| 706 | + task_group.events, # pyright: ignore[reportDeprecated], |
| 707 | + ) |
669 | 708 | ) |
670 | | - self.get_runs = to_streamed_response_wrapper( |
671 | | - task_group.get_runs, |
| 709 | + self.get_runs = ( # pyright: ignore[reportDeprecated] |
| 710 | + to_streamed_response_wrapper( |
| 711 | + task_group.get_runs, # pyright: ignore[reportDeprecated], |
| 712 | + ) |
672 | 713 | ) |
673 | 714 |
|
674 | 715 |
|
675 | 716 | class AsyncTaskGroupResourceWithStreamingResponse: |
676 | 717 | def __init__(self, task_group: AsyncTaskGroupResource) -> None: |
677 | 718 | self._task_group = task_group |
678 | 719 |
|
679 | | - self.create = async_to_streamed_response_wrapper( |
680 | | - task_group.create, |
| 720 | + self.create = ( # pyright: ignore[reportDeprecated] |
| 721 | + async_to_streamed_response_wrapper( |
| 722 | + task_group.create, # pyright: ignore[reportDeprecated], |
| 723 | + ) |
681 | 724 | ) |
682 | | - self.retrieve = async_to_streamed_response_wrapper( |
683 | | - task_group.retrieve, |
| 725 | + self.retrieve = ( # pyright: ignore[reportDeprecated] |
| 726 | + async_to_streamed_response_wrapper( |
| 727 | + task_group.retrieve, # pyright: ignore[reportDeprecated], |
| 728 | + ) |
684 | 729 | ) |
685 | | - self.add_runs = async_to_streamed_response_wrapper( |
686 | | - task_group.add_runs, |
| 730 | + self.add_runs = ( # pyright: ignore[reportDeprecated] |
| 731 | + async_to_streamed_response_wrapper( |
| 732 | + task_group.add_runs, # pyright: ignore[reportDeprecated], |
| 733 | + ) |
687 | 734 | ) |
688 | | - self.events = async_to_streamed_response_wrapper( |
689 | | - task_group.events, |
| 735 | + self.events = ( # pyright: ignore[reportDeprecated] |
| 736 | + async_to_streamed_response_wrapper( |
| 737 | + task_group.events, # pyright: ignore[reportDeprecated], |
| 738 | + ) |
690 | 739 | ) |
691 | | - self.get_runs = async_to_streamed_response_wrapper( |
692 | | - task_group.get_runs, |
| 740 | + self.get_runs = ( # pyright: ignore[reportDeprecated] |
| 741 | + async_to_streamed_response_wrapper( |
| 742 | + task_group.get_runs, # pyright: ignore[reportDeprecated], |
| 743 | + ) |
693 | 744 | ) |
0 commit comments