|
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 | *, |
@@ -134,7 +135,7 @@ async def delete( |
134 | 135 | ) |
135 | 136 |
|
136 | 137 | @_rewrite_parameters() |
137 | | - @_stability_warning(Stability.BETA) |
| 138 | + @_availability_warning(Stability.BETA) |
138 | 139 | async def get( |
139 | 140 | self, |
140 | 141 | *, |
@@ -199,7 +200,7 @@ async def get( |
199 | 200 | "sync_cursor", |
200 | 201 | ), |
201 | 202 | ) |
202 | | - @_stability_warning(Stability.EXPERIMENTAL) |
| 203 | + @_availability_warning(Stability.EXPERIMENTAL, Visibility.PRIVATE) |
203 | 204 | async def last_sync( |
204 | 205 | self, |
205 | 206 | *, |
@@ -333,7 +334,7 @@ async def last_sync( |
333 | 334 | @_rewrite_parameters( |
334 | 335 | parameter_aliases={"from": "from_"}, |
335 | 336 | ) |
336 | | - @_stability_warning(Stability.BETA) |
| 337 | + @_availability_warning(Stability.BETA) |
337 | 338 | async def list( |
338 | 339 | self, |
339 | 340 | *, |
@@ -416,7 +417,7 @@ async def list( |
416 | 417 | "service_type", |
417 | 418 | ), |
418 | 419 | ) |
419 | | - @_stability_warning(Stability.BETA) |
| 420 | + @_availability_warning(Stability.BETA) |
420 | 421 | async def post( |
421 | 422 | self, |
422 | 423 | *, |
@@ -500,7 +501,7 @@ async def post( |
500 | 501 | "service_type", |
501 | 502 | ), |
502 | 503 | ) |
503 | | - @_stability_warning(Stability.BETA) |
| 504 | + @_availability_warning(Stability.BETA) |
504 | 505 | async def put( |
505 | 506 | self, |
506 | 507 | *, |
@@ -580,7 +581,7 @@ async def put( |
580 | 581 | ) |
581 | 582 |
|
582 | 583 | @_rewrite_parameters() |
583 | | - @_stability_warning(Stability.BETA) |
| 584 | + @_availability_warning(Stability.BETA) |
584 | 585 | async def sync_job_cancel( |
585 | 586 | self, |
586 | 587 | *, |
@@ -630,7 +631,7 @@ async def sync_job_cancel( |
630 | 631 | ) |
631 | 632 |
|
632 | 633 | @_rewrite_parameters() |
633 | | - @_stability_warning(Stability.EXPERIMENTAL) |
| 634 | + @_availability_warning(Stability.EXPERIMENTAL) |
634 | 635 | async def sync_job_check_in( |
635 | 636 | self, |
636 | 637 | *, |
@@ -684,7 +685,7 @@ async def sync_job_check_in( |
684 | 685 | @_rewrite_parameters( |
685 | 686 | body_fields=("worker_hostname", "sync_cursor"), |
686 | 687 | ) |
687 | | - @_stability_warning(Stability.EXPERIMENTAL) |
| 688 | + @_availability_warning(Stability.EXPERIMENTAL) |
688 | 689 | async def sync_job_claim( |
689 | 690 | self, |
690 | 691 | *, |
@@ -753,7 +754,7 @@ async def sync_job_claim( |
753 | 754 | ) |
754 | 755 |
|
755 | 756 | @_rewrite_parameters() |
756 | | - @_stability_warning(Stability.BETA) |
| 757 | + @_availability_warning(Stability.BETA) |
757 | 758 | async def sync_job_delete( |
758 | 759 | self, |
759 | 760 | *, |
@@ -804,7 +805,7 @@ async def sync_job_delete( |
804 | 805 | @_rewrite_parameters( |
805 | 806 | body_fields=("error",), |
806 | 807 | ) |
807 | | - @_stability_warning(Stability.EXPERIMENTAL) |
| 808 | + @_availability_warning(Stability.EXPERIMENTAL) |
808 | 809 | async def sync_job_error( |
809 | 810 | self, |
810 | 811 | *, |
@@ -863,7 +864,7 @@ async def sync_job_error( |
863 | 864 | ) |
864 | 865 |
|
865 | 866 | @_rewrite_parameters() |
866 | | - @_stability_warning(Stability.BETA) |
| 867 | + @_availability_warning(Stability.BETA) |
867 | 868 | async def sync_job_get( |
868 | 869 | self, |
869 | 870 | *, |
@@ -911,7 +912,7 @@ async def sync_job_get( |
911 | 912 | @_rewrite_parameters( |
912 | 913 | parameter_aliases={"from": "from_"}, |
913 | 914 | ) |
914 | | - @_stability_warning(Stability.BETA) |
| 915 | + @_availability_warning(Stability.BETA) |
915 | 916 | async def sync_job_list( |
916 | 917 | self, |
917 | 918 | *, |
@@ -994,7 +995,7 @@ async def sync_job_list( |
994 | 995 | @_rewrite_parameters( |
995 | 996 | body_fields=("id", "job_type", "trigger_method"), |
996 | 997 | ) |
997 | | - @_stability_warning(Stability.BETA) |
| 998 | + @_availability_warning(Stability.BETA) |
998 | 999 | async def sync_job_post( |
999 | 1000 | self, |
1000 | 1001 | *, |
@@ -1066,7 +1067,7 @@ async def sync_job_post( |
1066 | 1067 | "total_document_count", |
1067 | 1068 | ), |
1068 | 1069 | ) |
1069 | | - @_stability_warning(Stability.EXPERIMENTAL) |
| 1070 | + @_availability_warning(Stability.EXPERIMENTAL) |
1070 | 1071 | async def sync_job_update_stats( |
1071 | 1072 | self, |
1072 | 1073 | *, |
@@ -1160,7 +1161,7 @@ async def sync_job_update_stats( |
1160 | 1161 | ) |
1161 | 1162 |
|
1162 | 1163 | @_rewrite_parameters() |
1163 | | - @_stability_warning(Stability.EXPERIMENTAL) |
| 1164 | + @_availability_warning(Stability.EXPERIMENTAL) |
1164 | 1165 | async def update_active_filtering( |
1165 | 1166 | self, |
1166 | 1167 | *, |
@@ -1207,7 +1208,7 @@ async def update_active_filtering( |
1207 | 1208 | @_rewrite_parameters( |
1208 | 1209 | body_fields=("api_key_id", "api_key_secret_id"), |
1209 | 1210 | ) |
1210 | | - @_stability_warning(Stability.BETA) |
| 1211 | + @_availability_warning(Stability.BETA) |
1211 | 1212 | async def update_api_key_id( |
1212 | 1213 | self, |
1213 | 1214 | *, |
@@ -1269,7 +1270,7 @@ async def update_api_key_id( |
1269 | 1270 | @_rewrite_parameters( |
1270 | 1271 | body_fields=("configuration", "values"), |
1271 | 1272 | ) |
1272 | | - @_stability_warning(Stability.BETA) |
| 1273 | + @_availability_warning(Stability.BETA) |
1273 | 1274 | async def update_configuration( |
1274 | 1275 | self, |
1275 | 1276 | *, |
@@ -1328,7 +1329,7 @@ async def update_configuration( |
1328 | 1329 | @_rewrite_parameters( |
1329 | 1330 | body_fields=("error",), |
1330 | 1331 | ) |
1331 | | - @_stability_warning(Stability.EXPERIMENTAL) |
| 1332 | + @_availability_warning(Stability.EXPERIMENTAL) |
1332 | 1333 | async def update_error( |
1333 | 1334 | self, |
1334 | 1335 | *, |
@@ -1387,7 +1388,7 @@ async def update_error( |
1387 | 1388 | @_rewrite_parameters( |
1388 | 1389 | body_fields=("features",), |
1389 | 1390 | ) |
1390 | | - @_stability_warning(Stability.EXPERIMENTAL) |
| 1391 | + @_availability_warning(Stability.EXPERIMENTAL) |
1391 | 1392 | async def update_features( |
1392 | 1393 | self, |
1393 | 1394 | *, |
@@ -1455,7 +1456,7 @@ async def update_features( |
1455 | 1456 | @_rewrite_parameters( |
1456 | 1457 | body_fields=("advanced_snippet", "filtering", "rules"), |
1457 | 1458 | ) |
1458 | | - @_stability_warning(Stability.BETA) |
| 1459 | + @_availability_warning(Stability.BETA) |
1459 | 1460 | async def update_filtering( |
1460 | 1461 | self, |
1461 | 1462 | *, |
@@ -1520,7 +1521,7 @@ async def update_filtering( |
1520 | 1521 | @_rewrite_parameters( |
1521 | 1522 | body_fields=("validation",), |
1522 | 1523 | ) |
1523 | | - @_stability_warning(Stability.EXPERIMENTAL) |
| 1524 | + @_availability_warning(Stability.EXPERIMENTAL) |
1524 | 1525 | async def update_filtering_validation( |
1525 | 1526 | self, |
1526 | 1527 | *, |
@@ -1577,7 +1578,7 @@ async def update_filtering_validation( |
1577 | 1578 | @_rewrite_parameters( |
1578 | 1579 | body_fields=("index_name",), |
1579 | 1580 | ) |
1580 | | - @_stability_warning(Stability.BETA) |
| 1581 | + @_availability_warning(Stability.BETA) |
1581 | 1582 | async def update_index_name( |
1582 | 1583 | self, |
1583 | 1584 | *, |
@@ -1634,7 +1635,7 @@ async def update_index_name( |
1634 | 1635 | @_rewrite_parameters( |
1635 | 1636 | body_fields=("description", "name"), |
1636 | 1637 | ) |
1637 | | - @_stability_warning(Stability.BETA) |
| 1638 | + @_availability_warning(Stability.BETA) |
1638 | 1639 | async def update_name( |
1639 | 1640 | self, |
1640 | 1641 | *, |
@@ -1692,7 +1693,7 @@ async def update_name( |
1692 | 1693 | @_rewrite_parameters( |
1693 | 1694 | body_fields=("is_native",), |
1694 | 1695 | ) |
1695 | | - @_stability_warning(Stability.BETA) |
| 1696 | + @_availability_warning(Stability.BETA) |
1696 | 1697 | async def update_native( |
1697 | 1698 | self, |
1698 | 1699 | *, |
@@ -1748,7 +1749,7 @@ async def update_native( |
1748 | 1749 | @_rewrite_parameters( |
1749 | 1750 | body_fields=("pipeline",), |
1750 | 1751 | ) |
1751 | | - @_stability_warning(Stability.BETA) |
| 1752 | + @_availability_warning(Stability.BETA) |
1752 | 1753 | async def update_pipeline( |
1753 | 1754 | self, |
1754 | 1755 | *, |
@@ -1805,7 +1806,7 @@ async def update_pipeline( |
1805 | 1806 | @_rewrite_parameters( |
1806 | 1807 | body_fields=("scheduling",), |
1807 | 1808 | ) |
1808 | | - @_stability_warning(Stability.BETA) |
| 1809 | + @_availability_warning(Stability.BETA) |
1809 | 1810 | async def update_scheduling( |
1810 | 1811 | self, |
1811 | 1812 | *, |
@@ -1861,7 +1862,7 @@ async def update_scheduling( |
1861 | 1862 | @_rewrite_parameters( |
1862 | 1863 | body_fields=("service_type",), |
1863 | 1864 | ) |
1864 | | - @_stability_warning(Stability.BETA) |
| 1865 | + @_availability_warning(Stability.BETA) |
1865 | 1866 | async def update_service_type( |
1866 | 1867 | self, |
1867 | 1868 | *, |
@@ -1917,7 +1918,7 @@ async def update_service_type( |
1917 | 1918 | @_rewrite_parameters( |
1918 | 1919 | body_fields=("status",), |
1919 | 1920 | ) |
1920 | | - @_stability_warning(Stability.EXPERIMENTAL) |
| 1921 | + @_availability_warning(Stability.EXPERIMENTAL) |
1921 | 1922 | async def update_status( |
1922 | 1923 | self, |
1923 | 1924 | *, |
|
0 commit comments