|
23 | 23 | from .utils import ( |
24 | 24 | SKIP_IN_PATH, |
25 | 25 | Stability, |
| 26 | + Visibility, |
| 27 | + _availability_warning, |
26 | 28 | _quote, |
27 | 29 | _rewrite_parameters, |
28 | | - _stability_warning, |
29 | 30 | ) |
30 | 31 |
|
31 | 32 |
|
32 | 33 | class ConnectorClient(NamespacedClient): |
33 | 34 |
|
34 | 35 | @_rewrite_parameters() |
35 | | - @_stability_warning(Stability.EXPERIMENTAL) |
| 36 | + @_availability_warning(Stability.EXPERIMENTAL) |
36 | 37 | async def check_in( |
37 | 38 | self, |
38 | 39 | *, |
@@ -77,7 +78,7 @@ async def check_in( |
77 | 78 | ) |
78 | 79 |
|
79 | 80 | @_rewrite_parameters() |
80 | | - @_stability_warning(Stability.BETA) |
| 81 | + @_availability_warning(Stability.BETA) |
81 | 82 | async def delete( |
82 | 83 | self, |
83 | 84 | *, |
@@ -130,7 +131,7 @@ async def delete( |
130 | 131 | ) |
131 | 132 |
|
132 | 133 | @_rewrite_parameters() |
133 | | - @_stability_warning(Stability.BETA) |
| 134 | + @_availability_warning(Stability.BETA) |
134 | 135 | async def get( |
135 | 136 | self, |
136 | 137 | *, |
@@ -190,7 +191,7 @@ async def get( |
190 | 191 | "sync_cursor", |
191 | 192 | ), |
192 | 193 | ) |
193 | | - @_stability_warning(Stability.EXPERIMENTAL) |
| 194 | + @_availability_warning(Stability.EXPERIMENTAL, Visibility.PRIVATE) |
194 | 195 | async def last_sync( |
195 | 196 | self, |
196 | 197 | *, |
@@ -324,7 +325,7 @@ async def last_sync( |
324 | 325 | @_rewrite_parameters( |
325 | 326 | parameter_aliases={"from": "from_"}, |
326 | 327 | ) |
327 | | - @_stability_warning(Stability.BETA) |
| 328 | + @_availability_warning(Stability.BETA) |
328 | 329 | async def list( |
329 | 330 | self, |
330 | 331 | *, |
@@ -402,7 +403,7 @@ async def list( |
402 | 403 | "service_type", |
403 | 404 | ), |
404 | 405 | ) |
405 | | - @_stability_warning(Stability.BETA) |
| 406 | + @_availability_warning(Stability.BETA) |
406 | 407 | async def post( |
407 | 408 | self, |
408 | 409 | *, |
@@ -486,7 +487,7 @@ async def post( |
486 | 487 | "service_type", |
487 | 488 | ), |
488 | 489 | ) |
489 | | - @_stability_warning(Stability.BETA) |
| 490 | + @_availability_warning(Stability.BETA) |
490 | 491 | async def put( |
491 | 492 | self, |
492 | 493 | *, |
@@ -566,7 +567,7 @@ async def put( |
566 | 567 | ) |
567 | 568 |
|
568 | 569 | @_rewrite_parameters() |
569 | | - @_stability_warning(Stability.BETA) |
| 570 | + @_availability_warning(Stability.BETA) |
570 | 571 | async def sync_job_cancel( |
571 | 572 | self, |
572 | 573 | *, |
@@ -616,7 +617,7 @@ async def sync_job_cancel( |
616 | 617 | ) |
617 | 618 |
|
618 | 619 | @_rewrite_parameters() |
619 | | - @_stability_warning(Stability.EXPERIMENTAL) |
| 620 | + @_availability_warning(Stability.EXPERIMENTAL) |
620 | 621 | async def sync_job_check_in( |
621 | 622 | self, |
622 | 623 | *, |
@@ -670,7 +671,7 @@ async def sync_job_check_in( |
670 | 671 | @_rewrite_parameters( |
671 | 672 | body_fields=("worker_hostname", "sync_cursor"), |
672 | 673 | ) |
673 | | - @_stability_warning(Stability.EXPERIMENTAL) |
| 674 | + @_availability_warning(Stability.EXPERIMENTAL) |
674 | 675 | async def sync_job_claim( |
675 | 676 | self, |
676 | 677 | *, |
@@ -739,7 +740,7 @@ async def sync_job_claim( |
739 | 740 | ) |
740 | 741 |
|
741 | 742 | @_rewrite_parameters() |
742 | | - @_stability_warning(Stability.BETA) |
| 743 | + @_availability_warning(Stability.BETA) |
743 | 744 | async def sync_job_delete( |
744 | 745 | self, |
745 | 746 | *, |
@@ -790,7 +791,7 @@ async def sync_job_delete( |
790 | 791 | @_rewrite_parameters( |
791 | 792 | body_fields=("error",), |
792 | 793 | ) |
793 | | - @_stability_warning(Stability.EXPERIMENTAL) |
| 794 | + @_availability_warning(Stability.EXPERIMENTAL) |
794 | 795 | async def sync_job_error( |
795 | 796 | self, |
796 | 797 | *, |
@@ -849,7 +850,7 @@ async def sync_job_error( |
849 | 850 | ) |
850 | 851 |
|
851 | 852 | @_rewrite_parameters() |
852 | | - @_stability_warning(Stability.BETA) |
| 853 | + @_availability_warning(Stability.BETA) |
853 | 854 | async def sync_job_get( |
854 | 855 | self, |
855 | 856 | *, |
@@ -897,7 +898,7 @@ async def sync_job_get( |
897 | 898 | @_rewrite_parameters( |
898 | 899 | parameter_aliases={"from": "from_"}, |
899 | 900 | ) |
900 | | - @_stability_warning(Stability.BETA) |
| 901 | + @_availability_warning(Stability.BETA) |
901 | 902 | async def sync_job_list( |
902 | 903 | self, |
903 | 904 | *, |
@@ -980,7 +981,7 @@ async def sync_job_list( |
980 | 981 | @_rewrite_parameters( |
981 | 982 | body_fields=("id", "job_type", "trigger_method"), |
982 | 983 | ) |
983 | | - @_stability_warning(Stability.BETA) |
| 984 | + @_availability_warning(Stability.BETA) |
984 | 985 | async def sync_job_post( |
985 | 986 | self, |
986 | 987 | *, |
@@ -1052,7 +1053,7 @@ async def sync_job_post( |
1052 | 1053 | "total_document_count", |
1053 | 1054 | ), |
1054 | 1055 | ) |
1055 | | - @_stability_warning(Stability.EXPERIMENTAL) |
| 1056 | + @_availability_warning(Stability.EXPERIMENTAL) |
1056 | 1057 | async def sync_job_update_stats( |
1057 | 1058 | self, |
1058 | 1059 | *, |
@@ -1146,7 +1147,7 @@ async def sync_job_update_stats( |
1146 | 1147 | ) |
1147 | 1148 |
|
1148 | 1149 | @_rewrite_parameters() |
1149 | | - @_stability_warning(Stability.EXPERIMENTAL) |
| 1150 | + @_availability_warning(Stability.EXPERIMENTAL) |
1150 | 1151 | async def update_active_filtering( |
1151 | 1152 | self, |
1152 | 1153 | *, |
@@ -1193,7 +1194,7 @@ async def update_active_filtering( |
1193 | 1194 | @_rewrite_parameters( |
1194 | 1195 | body_fields=("api_key_id", "api_key_secret_id"), |
1195 | 1196 | ) |
1196 | | - @_stability_warning(Stability.BETA) |
| 1197 | + @_availability_warning(Stability.BETA) |
1197 | 1198 | async def update_api_key_id( |
1198 | 1199 | self, |
1199 | 1200 | *, |
@@ -1255,7 +1256,7 @@ async def update_api_key_id( |
1255 | 1256 | @_rewrite_parameters( |
1256 | 1257 | body_fields=("configuration", "values"), |
1257 | 1258 | ) |
1258 | | - @_stability_warning(Stability.BETA) |
| 1259 | + @_availability_warning(Stability.BETA) |
1259 | 1260 | async def update_configuration( |
1260 | 1261 | self, |
1261 | 1262 | *, |
@@ -1314,7 +1315,7 @@ async def update_configuration( |
1314 | 1315 | @_rewrite_parameters( |
1315 | 1316 | body_fields=("error",), |
1316 | 1317 | ) |
1317 | | - @_stability_warning(Stability.EXPERIMENTAL) |
| 1318 | + @_availability_warning(Stability.EXPERIMENTAL) |
1318 | 1319 | async def update_error( |
1319 | 1320 | self, |
1320 | 1321 | *, |
@@ -1373,7 +1374,7 @@ async def update_error( |
1373 | 1374 | @_rewrite_parameters( |
1374 | 1375 | body_fields=("features",), |
1375 | 1376 | ) |
1376 | | - @_stability_warning(Stability.EXPERIMENTAL) |
| 1377 | + @_availability_warning(Stability.EXPERIMENTAL) |
1377 | 1378 | async def update_features( |
1378 | 1379 | self, |
1379 | 1380 | *, |
@@ -1441,7 +1442,7 @@ async def update_features( |
1441 | 1442 | @_rewrite_parameters( |
1442 | 1443 | body_fields=("advanced_snippet", "filtering", "rules"), |
1443 | 1444 | ) |
1444 | | - @_stability_warning(Stability.BETA) |
| 1445 | + @_availability_warning(Stability.BETA) |
1445 | 1446 | async def update_filtering( |
1446 | 1447 | self, |
1447 | 1448 | *, |
@@ -1506,7 +1507,7 @@ async def update_filtering( |
1506 | 1507 | @_rewrite_parameters( |
1507 | 1508 | body_fields=("validation",), |
1508 | 1509 | ) |
1509 | | - @_stability_warning(Stability.EXPERIMENTAL) |
| 1510 | + @_availability_warning(Stability.EXPERIMENTAL) |
1510 | 1511 | async def update_filtering_validation( |
1511 | 1512 | self, |
1512 | 1513 | *, |
@@ -1563,7 +1564,7 @@ async def update_filtering_validation( |
1563 | 1564 | @_rewrite_parameters( |
1564 | 1565 | body_fields=("index_name",), |
1565 | 1566 | ) |
1566 | | - @_stability_warning(Stability.BETA) |
| 1567 | + @_availability_warning(Stability.BETA) |
1567 | 1568 | async def update_index_name( |
1568 | 1569 | self, |
1569 | 1570 | *, |
@@ -1620,7 +1621,7 @@ async def update_index_name( |
1620 | 1621 | @_rewrite_parameters( |
1621 | 1622 | body_fields=("description", "name"), |
1622 | 1623 | ) |
1623 | | - @_stability_warning(Stability.BETA) |
| 1624 | + @_availability_warning(Stability.BETA) |
1624 | 1625 | async def update_name( |
1625 | 1626 | self, |
1626 | 1627 | *, |
@@ -1678,7 +1679,7 @@ async def update_name( |
1678 | 1679 | @_rewrite_parameters( |
1679 | 1680 | body_fields=("is_native",), |
1680 | 1681 | ) |
1681 | | - @_stability_warning(Stability.BETA) |
| 1682 | + @_availability_warning(Stability.BETA) |
1682 | 1683 | async def update_native( |
1683 | 1684 | self, |
1684 | 1685 | *, |
@@ -1734,7 +1735,7 @@ async def update_native( |
1734 | 1735 | @_rewrite_parameters( |
1735 | 1736 | body_fields=("pipeline",), |
1736 | 1737 | ) |
1737 | | - @_stability_warning(Stability.BETA) |
| 1738 | + @_availability_warning(Stability.BETA) |
1738 | 1739 | async def update_pipeline( |
1739 | 1740 | self, |
1740 | 1741 | *, |
@@ -1791,7 +1792,7 @@ async def update_pipeline( |
1791 | 1792 | @_rewrite_parameters( |
1792 | 1793 | body_fields=("scheduling",), |
1793 | 1794 | ) |
1794 | | - @_stability_warning(Stability.BETA) |
| 1795 | + @_availability_warning(Stability.BETA) |
1795 | 1796 | async def update_scheduling( |
1796 | 1797 | self, |
1797 | 1798 | *, |
@@ -1847,7 +1848,7 @@ async def update_scheduling( |
1847 | 1848 | @_rewrite_parameters( |
1848 | 1849 | body_fields=("service_type",), |
1849 | 1850 | ) |
1850 | | - @_stability_warning(Stability.BETA) |
| 1851 | + @_availability_warning(Stability.BETA) |
1851 | 1852 | async def update_service_type( |
1852 | 1853 | self, |
1853 | 1854 | *, |
@@ -1903,7 +1904,7 @@ async def update_service_type( |
1903 | 1904 | @_rewrite_parameters( |
1904 | 1905 | body_fields=("status",), |
1905 | 1906 | ) |
1906 | | - @_stability_warning(Stability.EXPERIMENTAL) |
| 1907 | + @_availability_warning(Stability.EXPERIMENTAL) |
1907 | 1908 | async def update_status( |
1908 | 1909 | self, |
1909 | 1910 | *, |
|
0 commit comments