@@ -607,6 +607,10 @@ def list_connection_configs(
607
607
List Configured Connectors
608
608
609
609
Args:
610
+ limit: Limit the number of items returned
611
+
612
+ offset: Offset the items returned
613
+
610
614
extra_headers: Send extra headers
611
615
612
616
extra_query: Add additional query parameters to the request
@@ -729,6 +733,10 @@ def list_connections(
729
733
730
734
expand: Expand the response with additional optionals
731
735
736
+ limit: Limit the number of items returned
737
+
738
+ offset: Offset the items returned
739
+
732
740
extra_headers: Send extra headers
733
741
734
742
extra_query: Add additional query parameters to the request
@@ -765,17 +773,23 @@ def list_connectors(
765
773
self ,
766
774
* ,
767
775
expand : List [Literal ["schemas" ]] | NotGiven = NOT_GIVEN ,
776
+ limit : int | NotGiven = NOT_GIVEN ,
777
+ offset : int | NotGiven = NOT_GIVEN ,
768
778
# Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs.
769
779
# The extra values given here take precedence over values defined on the client or passed to this method.
770
780
extra_headers : Headers | None = None ,
771
781
extra_query : Query | None = None ,
772
782
extra_body : Body | None = None ,
773
783
timeout : float | httpx .Timeout | None | NotGiven = NOT_GIVEN ,
774
- ) -> ListConnectorsResponse :
784
+ ) -> SyncOffsetPagination [ ListConnectorsResponse ] :
775
785
"""
776
786
List all connectors to understand what integrations are available to configure
777
787
778
788
Args:
789
+ limit: Limit the number of items returned
790
+
791
+ offset: Offset the items returned
792
+
779
793
extra_headers: Send extra headers
780
794
781
795
extra_query: Add additional query parameters to the request
@@ -784,16 +798,24 @@ def list_connectors(
784
798
785
799
timeout: Override the client-level default timeout for this request, in seconds
786
800
"""
787
- return self .get (
801
+ return self .get_api_list (
788
802
"/connector" ,
803
+ page = SyncOffsetPagination [ListConnectorsResponse ],
789
804
options = make_request_options (
790
805
extra_headers = extra_headers ,
791
806
extra_query = extra_query ,
792
807
extra_body = extra_body ,
793
808
timeout = timeout ,
794
- query = maybe_transform ({"expand" : expand }, client_list_connectors_params .ClientListConnectorsParams ),
809
+ query = maybe_transform (
810
+ {
811
+ "expand" : expand ,
812
+ "limit" : limit ,
813
+ "offset" : offset ,
814
+ },
815
+ client_list_connectors_params .ClientListConnectorsParams ,
816
+ ),
795
817
),
796
- cast_to = ListConnectorsResponse ,
818
+ model = ListConnectorsResponse ,
797
819
)
798
820
799
821
@override
@@ -1369,6 +1391,10 @@ def list_connection_configs(
1369
1391
List Configured Connectors
1370
1392
1371
1393
Args:
1394
+ limit: Limit the number of items returned
1395
+
1396
+ offset: Offset the items returned
1397
+
1372
1398
extra_headers: Send extra headers
1373
1399
1374
1400
extra_query: Add additional query parameters to the request
@@ -1491,6 +1517,10 @@ def list_connections(
1491
1517
1492
1518
expand: Expand the response with additional optionals
1493
1519
1520
+ limit: Limit the number of items returned
1521
+
1522
+ offset: Offset the items returned
1523
+
1494
1524
extra_headers: Send extra headers
1495
1525
1496
1526
extra_query: Add additional query parameters to the request
@@ -1523,21 +1553,27 @@ def list_connections(
1523
1553
model = cast (Any , ListConnectionsResponse ), # Union types cannot be passed in as arguments in the type system
1524
1554
)
1525
1555
1526
- async def list_connectors (
1556
+ def list_connectors (
1527
1557
self ,
1528
1558
* ,
1529
1559
expand : List [Literal ["schemas" ]] | NotGiven = NOT_GIVEN ,
1560
+ limit : int | NotGiven = NOT_GIVEN ,
1561
+ offset : int | NotGiven = NOT_GIVEN ,
1530
1562
# Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs.
1531
1563
# The extra values given here take precedence over values defined on the client or passed to this method.
1532
1564
extra_headers : Headers | None = None ,
1533
1565
extra_query : Query | None = None ,
1534
1566
extra_body : Body | None = None ,
1535
1567
timeout : float | httpx .Timeout | None | NotGiven = NOT_GIVEN ,
1536
- ) -> ListConnectorsResponse :
1568
+ ) -> AsyncPaginator [ ListConnectorsResponse , AsyncOffsetPagination [ ListConnectorsResponse ]] :
1537
1569
"""
1538
1570
List all connectors to understand what integrations are available to configure
1539
1571
1540
1572
Args:
1573
+ limit: Limit the number of items returned
1574
+
1575
+ offset: Offset the items returned
1576
+
1541
1577
extra_headers: Send extra headers
1542
1578
1543
1579
extra_query: Add additional query parameters to the request
@@ -1546,18 +1582,24 @@ async def list_connectors(
1546
1582
1547
1583
timeout: Override the client-level default timeout for this request, in seconds
1548
1584
"""
1549
- return await self .get (
1585
+ return self .get_api_list (
1550
1586
"/connector" ,
1587
+ page = AsyncOffsetPagination [ListConnectorsResponse ],
1551
1588
options = make_request_options (
1552
1589
extra_headers = extra_headers ,
1553
1590
extra_query = extra_query ,
1554
1591
extra_body = extra_body ,
1555
1592
timeout = timeout ,
1556
- query = await async_maybe_transform (
1557
- {"expand" : expand }, client_list_connectors_params .ClientListConnectorsParams
1593
+ query = maybe_transform (
1594
+ {
1595
+ "expand" : expand ,
1596
+ "limit" : limit ,
1597
+ "offset" : offset ,
1598
+ },
1599
+ client_list_connectors_params .ClientListConnectorsParams ,
1558
1600
),
1559
1601
),
1560
- cast_to = ListConnectorsResponse ,
1602
+ model = ListConnectorsResponse ,
1561
1603
)
1562
1604
1563
1605
@override
0 commit comments