From def86ea81f8a52ec12d47c9edf2071a940cadc03 Mon Sep 17 00:00:00 2001 From: "convoy-sdk-bot[bot]" <307218117+convoy-sdk-bot[bot]@users.noreply.github.com> Date: Fri, 16 Oct 2026 22:12:20 +0000 Subject: [PATCH] feat: regenerate API client from OpenAPI spec --- .../batch_retry_event_delivery.py | 51 ++++++++++++++++++- .../get_event_deliveries_paged.py | 51 ++++++++++++++++++- src/convoy/api/events/batch_replay_events.py | 15 ++++++ .../api/events/count_affected_events.py | 15 ++++++ src/convoy/api/events/get_events_paged.py | 15 ++++++ src/convoy/models/models_update_source.py | 17 +++++++ 6 files changed, 162 insertions(+), 2 deletions(-) diff --git a/src/convoy/api/event_deliveries/batch_retry_event_delivery.py b/src/convoy/api/event_deliveries/batch_retry_event_delivery.py index ce80bc8..2cc42fe 100644 --- a/src/convoy/api/event_deliveries/batch_retry_event_delivery.py +++ b/src/convoy/api/event_deliveries/batch_retry_event_delivery.py @@ -33,11 +33,14 @@ def _get_kwargs( event_id: str | Unset = UNSET, event_type: str | Unset = UNSET, idempotency_key: str | Unset = UNSET, + idempotency_value: str | Unset = UNSET, + min_trials: int | Unset = UNSET, next_page_cursor: str | Unset = UNSET, per_page: int | Unset = UNSET, prev_page_cursor: str | Unset = UNSET, query: str | Unset = UNSET, sort: str | Unset = UNSET, + source_id: list[str] | Unset = UNSET, start_date: str | Unset = UNSET, status: list[str] | Unset = UNSET, subscription_id: str | Unset = UNSET, @@ -61,10 +64,14 @@ def _get_kwargs( params["eventId"] = event_id - params["event_type"] = event_type + params["eventType"] = event_type params["idempotencyKey"] = idempotency_key + params["idempotencyValue"] = idempotency_value + + params["minTrials"] = min_trials + params["next_page_cursor"] = next_page_cursor params["perPage"] = per_page @@ -75,6 +82,12 @@ def _get_kwargs( params["sort"] = sort + json_source_id: list[str] | Unset = UNSET + if not isinstance(source_id, Unset): + json_source_id = source_id + + params["sourceId"] = json_source_id + params["startDate"] = start_date json_status: list[str] | Unset = UNSET @@ -159,11 +172,14 @@ def sync_detailed( event_id: str | Unset = UNSET, event_type: str | Unset = UNSET, idempotency_key: str | Unset = UNSET, + idempotency_value: str | Unset = UNSET, + min_trials: int | Unset = UNSET, next_page_cursor: str | Unset = UNSET, per_page: int | Unset = UNSET, prev_page_cursor: str | Unset = UNSET, query: str | Unset = UNSET, sort: str | Unset = UNSET, + source_id: list[str] | Unset = UNSET, start_date: str | Unset = UNSET, status: list[str] | Unset = UNSET, subscription_id: str | Unset = UNSET, @@ -185,11 +201,14 @@ def sync_detailed( event_id (str | Unset): event_type (str | Unset): idempotency_key (str | Unset): + idempotency_value (str | Unset): + min_trials (int | Unset): next_page_cursor (str | Unset): per_page (int | Unset): prev_page_cursor (str | Unset): query (str | Unset): sort (str | Unset): + source_id (list[str] | Unset): start_date (str | Unset): status (list[str] | Unset): subscription_id (str | Unset): @@ -210,11 +229,14 @@ def sync_detailed( event_id=event_id, event_type=event_type, idempotency_key=idempotency_key, + idempotency_value=idempotency_value, + min_trials=min_trials, next_page_cursor=next_page_cursor, per_page=per_page, prev_page_cursor=prev_page_cursor, query=query, sort=sort, + source_id=source_id, start_date=start_date, status=status, subscription_id=subscription_id, @@ -237,11 +259,14 @@ def sync( event_id: str | Unset = UNSET, event_type: str | Unset = UNSET, idempotency_key: str | Unset = UNSET, + idempotency_value: str | Unset = UNSET, + min_trials: int | Unset = UNSET, next_page_cursor: str | Unset = UNSET, per_page: int | Unset = UNSET, prev_page_cursor: str | Unset = UNSET, query: str | Unset = UNSET, sort: str | Unset = UNSET, + source_id: list[str] | Unset = UNSET, start_date: str | Unset = UNSET, status: list[str] | Unset = UNSET, subscription_id: str | Unset = UNSET, @@ -264,11 +289,14 @@ def sync( event_id (str | Unset): event_type (str | Unset): idempotency_key (str | Unset): + idempotency_value (str | Unset): + min_trials (int | Unset): next_page_cursor (str | Unset): per_page (int | Unset): prev_page_cursor (str | Unset): query (str | Unset): sort (str | Unset): + source_id (list[str] | Unset): start_date (str | Unset): status (list[str] | Unset): subscription_id (str | Unset): @@ -290,11 +318,14 @@ def sync( event_id=event_id, event_type=event_type, idempotency_key=idempotency_key, + idempotency_value=idempotency_value, + min_trials=min_trials, next_page_cursor=next_page_cursor, per_page=per_page, prev_page_cursor=prev_page_cursor, query=query, sort=sort, + source_id=source_id, start_date=start_date, status=status, subscription_id=subscription_id, @@ -311,11 +342,14 @@ async def asyncio_detailed( event_id: str | Unset = UNSET, event_type: str | Unset = UNSET, idempotency_key: str | Unset = UNSET, + idempotency_value: str | Unset = UNSET, + min_trials: int | Unset = UNSET, next_page_cursor: str | Unset = UNSET, per_page: int | Unset = UNSET, prev_page_cursor: str | Unset = UNSET, query: str | Unset = UNSET, sort: str | Unset = UNSET, + source_id: list[str] | Unset = UNSET, start_date: str | Unset = UNSET, status: list[str] | Unset = UNSET, subscription_id: str | Unset = UNSET, @@ -337,11 +371,14 @@ async def asyncio_detailed( event_id (str | Unset): event_type (str | Unset): idempotency_key (str | Unset): + idempotency_value (str | Unset): + min_trials (int | Unset): next_page_cursor (str | Unset): per_page (int | Unset): prev_page_cursor (str | Unset): query (str | Unset): sort (str | Unset): + source_id (list[str] | Unset): start_date (str | Unset): status (list[str] | Unset): subscription_id (str | Unset): @@ -362,11 +399,14 @@ async def asyncio_detailed( event_id=event_id, event_type=event_type, idempotency_key=idempotency_key, + idempotency_value=idempotency_value, + min_trials=min_trials, next_page_cursor=next_page_cursor, per_page=per_page, prev_page_cursor=prev_page_cursor, query=query, sort=sort, + source_id=source_id, start_date=start_date, status=status, subscription_id=subscription_id, @@ -387,11 +427,14 @@ async def asyncio( event_id: str | Unset = UNSET, event_type: str | Unset = UNSET, idempotency_key: str | Unset = UNSET, + idempotency_value: str | Unset = UNSET, + min_trials: int | Unset = UNSET, next_page_cursor: str | Unset = UNSET, per_page: int | Unset = UNSET, prev_page_cursor: str | Unset = UNSET, query: str | Unset = UNSET, sort: str | Unset = UNSET, + source_id: list[str] | Unset = UNSET, start_date: str | Unset = UNSET, status: list[str] | Unset = UNSET, subscription_id: str | Unset = UNSET, @@ -414,11 +457,14 @@ async def asyncio( event_id (str | Unset): event_type (str | Unset): idempotency_key (str | Unset): + idempotency_value (str | Unset): + min_trials (int | Unset): next_page_cursor (str | Unset): per_page (int | Unset): prev_page_cursor (str | Unset): query (str | Unset): sort (str | Unset): + source_id (list[str] | Unset): start_date (str | Unset): status (list[str] | Unset): subscription_id (str | Unset): @@ -441,11 +487,14 @@ async def asyncio( event_id=event_id, event_type=event_type, idempotency_key=idempotency_key, + idempotency_value=idempotency_value, + min_trials=min_trials, next_page_cursor=next_page_cursor, per_page=per_page, prev_page_cursor=prev_page_cursor, query=query, sort=sort, + source_id=source_id, start_date=start_date, status=status, subscription_id=subscription_id, diff --git a/src/convoy/api/event_deliveries/get_event_deliveries_paged.py b/src/convoy/api/event_deliveries/get_event_deliveries_paged.py index a2ce7f9..4ceecc1 100644 --- a/src/convoy/api/event_deliveries/get_event_deliveries_paged.py +++ b/src/convoy/api/event_deliveries/get_event_deliveries_paged.py @@ -36,11 +36,14 @@ def _get_kwargs( event_id: str | Unset = UNSET, event_type: str | Unset = UNSET, idempotency_key: str | Unset = UNSET, + idempotency_value: str | Unset = UNSET, + min_trials: int | Unset = UNSET, next_page_cursor: str | Unset = UNSET, per_page: int | Unset = UNSET, prev_page_cursor: str | Unset = UNSET, query: str | Unset = UNSET, sort: str | Unset = UNSET, + source_id: list[str] | Unset = UNSET, start_date: str | Unset = UNSET, status: list[str] | Unset = UNSET, subscription_id: str | Unset = UNSET, @@ -64,10 +67,14 @@ def _get_kwargs( params["eventId"] = event_id - params["event_type"] = event_type + params["eventType"] = event_type params["idempotencyKey"] = idempotency_key + params["idempotencyValue"] = idempotency_value + + params["minTrials"] = min_trials + params["next_page_cursor"] = next_page_cursor params["perPage"] = per_page @@ -78,6 +85,12 @@ def _get_kwargs( params["sort"] = sort + json_source_id: list[str] | Unset = UNSET + if not isinstance(source_id, Unset): + json_source_id = source_id + + params["sourceId"] = json_source_id + params["startDate"] = start_date json_status: list[str] | Unset = UNSET @@ -169,11 +182,14 @@ def sync_detailed( event_id: str | Unset = UNSET, event_type: str | Unset = UNSET, idempotency_key: str | Unset = UNSET, + idempotency_value: str | Unset = UNSET, + min_trials: int | Unset = UNSET, next_page_cursor: str | Unset = UNSET, per_page: int | Unset = UNSET, prev_page_cursor: str | Unset = UNSET, query: str | Unset = UNSET, sort: str | Unset = UNSET, + source_id: list[str] | Unset = UNSET, start_date: str | Unset = UNSET, status: list[str] | Unset = UNSET, subscription_id: str | Unset = UNSET, @@ -196,11 +212,14 @@ def sync_detailed( event_id (str | Unset): event_type (str | Unset): idempotency_key (str | Unset): + idempotency_value (str | Unset): + min_trials (int | Unset): next_page_cursor (str | Unset): per_page (int | Unset): prev_page_cursor (str | Unset): query (str | Unset): sort (str | Unset): + source_id (list[str] | Unset): start_date (str | Unset): status (list[str] | Unset): subscription_id (str | Unset): @@ -221,11 +240,14 @@ def sync_detailed( event_id=event_id, event_type=event_type, idempotency_key=idempotency_key, + idempotency_value=idempotency_value, + min_trials=min_trials, next_page_cursor=next_page_cursor, per_page=per_page, prev_page_cursor=prev_page_cursor, query=query, sort=sort, + source_id=source_id, start_date=start_date, status=status, subscription_id=subscription_id, @@ -248,11 +270,14 @@ def sync( event_id: str | Unset = UNSET, event_type: str | Unset = UNSET, idempotency_key: str | Unset = UNSET, + idempotency_value: str | Unset = UNSET, + min_trials: int | Unset = UNSET, next_page_cursor: str | Unset = UNSET, per_page: int | Unset = UNSET, prev_page_cursor: str | Unset = UNSET, query: str | Unset = UNSET, sort: str | Unset = UNSET, + source_id: list[str] | Unset = UNSET, start_date: str | Unset = UNSET, status: list[str] | Unset = UNSET, subscription_id: str | Unset = UNSET, @@ -276,11 +301,14 @@ def sync( event_id (str | Unset): event_type (str | Unset): idempotency_key (str | Unset): + idempotency_value (str | Unset): + min_trials (int | Unset): next_page_cursor (str | Unset): per_page (int | Unset): prev_page_cursor (str | Unset): query (str | Unset): sort (str | Unset): + source_id (list[str] | Unset): start_date (str | Unset): status (list[str] | Unset): subscription_id (str | Unset): @@ -302,11 +330,14 @@ def sync( event_id=event_id, event_type=event_type, idempotency_key=idempotency_key, + idempotency_value=idempotency_value, + min_trials=min_trials, next_page_cursor=next_page_cursor, per_page=per_page, prev_page_cursor=prev_page_cursor, query=query, sort=sort, + source_id=source_id, start_date=start_date, status=status, subscription_id=subscription_id, @@ -323,11 +354,14 @@ async def asyncio_detailed( event_id: str | Unset = UNSET, event_type: str | Unset = UNSET, idempotency_key: str | Unset = UNSET, + idempotency_value: str | Unset = UNSET, + min_trials: int | Unset = UNSET, next_page_cursor: str | Unset = UNSET, per_page: int | Unset = UNSET, prev_page_cursor: str | Unset = UNSET, query: str | Unset = UNSET, sort: str | Unset = UNSET, + source_id: list[str] | Unset = UNSET, start_date: str | Unset = UNSET, status: list[str] | Unset = UNSET, subscription_id: str | Unset = UNSET, @@ -350,11 +384,14 @@ async def asyncio_detailed( event_id (str | Unset): event_type (str | Unset): idempotency_key (str | Unset): + idempotency_value (str | Unset): + min_trials (int | Unset): next_page_cursor (str | Unset): per_page (int | Unset): prev_page_cursor (str | Unset): query (str | Unset): sort (str | Unset): + source_id (list[str] | Unset): start_date (str | Unset): status (list[str] | Unset): subscription_id (str | Unset): @@ -375,11 +412,14 @@ async def asyncio_detailed( event_id=event_id, event_type=event_type, idempotency_key=idempotency_key, + idempotency_value=idempotency_value, + min_trials=min_trials, next_page_cursor=next_page_cursor, per_page=per_page, prev_page_cursor=prev_page_cursor, query=query, sort=sort, + source_id=source_id, start_date=start_date, status=status, subscription_id=subscription_id, @@ -400,11 +440,14 @@ async def asyncio( event_id: str | Unset = UNSET, event_type: str | Unset = UNSET, idempotency_key: str | Unset = UNSET, + idempotency_value: str | Unset = UNSET, + min_trials: int | Unset = UNSET, next_page_cursor: str | Unset = UNSET, per_page: int | Unset = UNSET, prev_page_cursor: str | Unset = UNSET, query: str | Unset = UNSET, sort: str | Unset = UNSET, + source_id: list[str] | Unset = UNSET, start_date: str | Unset = UNSET, status: list[str] | Unset = UNSET, subscription_id: str | Unset = UNSET, @@ -428,11 +471,14 @@ async def asyncio( event_id (str | Unset): event_type (str | Unset): idempotency_key (str | Unset): + idempotency_value (str | Unset): + min_trials (int | Unset): next_page_cursor (str | Unset): per_page (int | Unset): prev_page_cursor (str | Unset): query (str | Unset): sort (str | Unset): + source_id (list[str] | Unset): start_date (str | Unset): status (list[str] | Unset): subscription_id (str | Unset): @@ -455,11 +501,14 @@ async def asyncio( event_id=event_id, event_type=event_type, idempotency_key=idempotency_key, + idempotency_value=idempotency_value, + min_trials=min_trials, next_page_cursor=next_page_cursor, per_page=per_page, prev_page_cursor=prev_page_cursor, query=query, sort=sort, + source_id=source_id, start_date=start_date, status=status, subscription_id=subscription_id, diff --git a/src/convoy/api/events/batch_replay_events.py b/src/convoy/api/events/batch_replay_events.py index 40b291e..b77c806 100644 --- a/src/convoy/api/events/batch_replay_events.py +++ b/src/convoy/api/events/batch_replay_events.py @@ -22,6 +22,7 @@ def _get_kwargs( end_date: str | Unset = UNSET, endpoint_id: list[str] | Unset = UNSET, idempotency_key: str | Unset = UNSET, + idempotency_value: str | Unset = UNSET, next_page_cursor: str | Unset = UNSET, per_page: int | Unset = UNSET, prev_page_cursor: str | Unset = UNSET, @@ -51,6 +52,8 @@ def _get_kwargs( params["idempotencyKey"] = idempotency_key + params["idempotencyValue"] = idempotency_value + params["next_page_cursor"] = next_page_cursor params["perPage"] = per_page @@ -142,6 +145,7 @@ def sync_detailed( end_date: str | Unset = UNSET, endpoint_id: list[str] | Unset = UNSET, idempotency_key: str | Unset = UNSET, + idempotency_value: str | Unset = UNSET, next_page_cursor: str | Unset = UNSET, per_page: int | Unset = UNSET, prev_page_cursor: str | Unset = UNSET, @@ -166,6 +170,7 @@ def sync_detailed( end_date (str | Unset): endpoint_id (list[str] | Unset): idempotency_key (str | Unset): + idempotency_value (str | Unset): next_page_cursor (str | Unset): per_page (int | Unset): prev_page_cursor (str | Unset): @@ -189,6 +194,7 @@ def sync_detailed( end_date=end_date, endpoint_id=endpoint_id, idempotency_key=idempotency_key, + idempotency_value=idempotency_value, next_page_cursor=next_page_cursor, per_page=per_page, prev_page_cursor=prev_page_cursor, @@ -214,6 +220,7 @@ def sync( end_date: str | Unset = UNSET, endpoint_id: list[str] | Unset = UNSET, idempotency_key: str | Unset = UNSET, + idempotency_value: str | Unset = UNSET, next_page_cursor: str | Unset = UNSET, per_page: int | Unset = UNSET, prev_page_cursor: str | Unset = UNSET, @@ -239,6 +246,7 @@ def sync( end_date (str | Unset): endpoint_id (list[str] | Unset): idempotency_key (str | Unset): + idempotency_value (str | Unset): next_page_cursor (str | Unset): per_page (int | Unset): prev_page_cursor (str | Unset): @@ -263,6 +271,7 @@ def sync( end_date=end_date, endpoint_id=endpoint_id, idempotency_key=idempotency_key, + idempotency_value=idempotency_value, next_page_cursor=next_page_cursor, per_page=per_page, prev_page_cursor=prev_page_cursor, @@ -282,6 +291,7 @@ async def asyncio_detailed( end_date: str | Unset = UNSET, endpoint_id: list[str] | Unset = UNSET, idempotency_key: str | Unset = UNSET, + idempotency_value: str | Unset = UNSET, next_page_cursor: str | Unset = UNSET, per_page: int | Unset = UNSET, prev_page_cursor: str | Unset = UNSET, @@ -306,6 +316,7 @@ async def asyncio_detailed( end_date (str | Unset): endpoint_id (list[str] | Unset): idempotency_key (str | Unset): + idempotency_value (str | Unset): next_page_cursor (str | Unset): per_page (int | Unset): prev_page_cursor (str | Unset): @@ -329,6 +340,7 @@ async def asyncio_detailed( end_date=end_date, endpoint_id=endpoint_id, idempotency_key=idempotency_key, + idempotency_value=idempotency_value, next_page_cursor=next_page_cursor, per_page=per_page, prev_page_cursor=prev_page_cursor, @@ -352,6 +364,7 @@ async def asyncio( end_date: str | Unset = UNSET, endpoint_id: list[str] | Unset = UNSET, idempotency_key: str | Unset = UNSET, + idempotency_value: str | Unset = UNSET, next_page_cursor: str | Unset = UNSET, per_page: int | Unset = UNSET, prev_page_cursor: str | Unset = UNSET, @@ -377,6 +390,7 @@ async def asyncio( end_date (str | Unset): endpoint_id (list[str] | Unset): idempotency_key (str | Unset): + idempotency_value (str | Unset): next_page_cursor (str | Unset): per_page (int | Unset): prev_page_cursor (str | Unset): @@ -402,6 +416,7 @@ async def asyncio( end_date=end_date, endpoint_id=endpoint_id, idempotency_key=idempotency_key, + idempotency_value=idempotency_value, next_page_cursor=next_page_cursor, per_page=per_page, prev_page_cursor=prev_page_cursor, diff --git a/src/convoy/api/events/count_affected_events.py b/src/convoy/api/events/count_affected_events.py index 3f060c3..cc70c72 100644 --- a/src/convoy/api/events/count_affected_events.py +++ b/src/convoy/api/events/count_affected_events.py @@ -22,6 +22,7 @@ def _get_kwargs( end_date: str | Unset = UNSET, endpoint_id: list[str] | Unset = UNSET, idempotency_key: str | Unset = UNSET, + idempotency_value: str | Unset = UNSET, next_page_cursor: str | Unset = UNSET, per_page: int | Unset = UNSET, prev_page_cursor: str | Unset = UNSET, @@ -51,6 +52,8 @@ def _get_kwargs( params["idempotencyKey"] = idempotency_key + params["idempotencyValue"] = idempotency_value + params["next_page_cursor"] = next_page_cursor params["perPage"] = per_page @@ -142,6 +145,7 @@ def sync_detailed( end_date: str | Unset = UNSET, endpoint_id: list[str] | Unset = UNSET, idempotency_key: str | Unset = UNSET, + idempotency_value: str | Unset = UNSET, next_page_cursor: str | Unset = UNSET, per_page: int | Unset = UNSET, prev_page_cursor: str | Unset = UNSET, @@ -166,6 +170,7 @@ def sync_detailed( end_date (str | Unset): endpoint_id (list[str] | Unset): idempotency_key (str | Unset): + idempotency_value (str | Unset): next_page_cursor (str | Unset): per_page (int | Unset): prev_page_cursor (str | Unset): @@ -189,6 +194,7 @@ def sync_detailed( end_date=end_date, endpoint_id=endpoint_id, idempotency_key=idempotency_key, + idempotency_value=idempotency_value, next_page_cursor=next_page_cursor, per_page=per_page, prev_page_cursor=prev_page_cursor, @@ -214,6 +220,7 @@ def sync( end_date: str | Unset = UNSET, endpoint_id: list[str] | Unset = UNSET, idempotency_key: str | Unset = UNSET, + idempotency_value: str | Unset = UNSET, next_page_cursor: str | Unset = UNSET, per_page: int | Unset = UNSET, prev_page_cursor: str | Unset = UNSET, @@ -239,6 +246,7 @@ def sync( end_date (str | Unset): endpoint_id (list[str] | Unset): idempotency_key (str | Unset): + idempotency_value (str | Unset): next_page_cursor (str | Unset): per_page (int | Unset): prev_page_cursor (str | Unset): @@ -263,6 +271,7 @@ def sync( end_date=end_date, endpoint_id=endpoint_id, idempotency_key=idempotency_key, + idempotency_value=idempotency_value, next_page_cursor=next_page_cursor, per_page=per_page, prev_page_cursor=prev_page_cursor, @@ -282,6 +291,7 @@ async def asyncio_detailed( end_date: str | Unset = UNSET, endpoint_id: list[str] | Unset = UNSET, idempotency_key: str | Unset = UNSET, + idempotency_value: str | Unset = UNSET, next_page_cursor: str | Unset = UNSET, per_page: int | Unset = UNSET, prev_page_cursor: str | Unset = UNSET, @@ -306,6 +316,7 @@ async def asyncio_detailed( end_date (str | Unset): endpoint_id (list[str] | Unset): idempotency_key (str | Unset): + idempotency_value (str | Unset): next_page_cursor (str | Unset): per_page (int | Unset): prev_page_cursor (str | Unset): @@ -329,6 +340,7 @@ async def asyncio_detailed( end_date=end_date, endpoint_id=endpoint_id, idempotency_key=idempotency_key, + idempotency_value=idempotency_value, next_page_cursor=next_page_cursor, per_page=per_page, prev_page_cursor=prev_page_cursor, @@ -352,6 +364,7 @@ async def asyncio( end_date: str | Unset = UNSET, endpoint_id: list[str] | Unset = UNSET, idempotency_key: str | Unset = UNSET, + idempotency_value: str | Unset = UNSET, next_page_cursor: str | Unset = UNSET, per_page: int | Unset = UNSET, prev_page_cursor: str | Unset = UNSET, @@ -377,6 +390,7 @@ async def asyncio( end_date (str | Unset): endpoint_id (list[str] | Unset): idempotency_key (str | Unset): + idempotency_value (str | Unset): next_page_cursor (str | Unset): per_page (int | Unset): prev_page_cursor (str | Unset): @@ -402,6 +416,7 @@ async def asyncio( end_date=end_date, endpoint_id=endpoint_id, idempotency_key=idempotency_key, + idempotency_value=idempotency_value, next_page_cursor=next_page_cursor, per_page=per_page, prev_page_cursor=prev_page_cursor, diff --git a/src/convoy/api/events/get_events_paged.py b/src/convoy/api/events/get_events_paged.py index 8d98242..0bc07b5 100644 --- a/src/convoy/api/events/get_events_paged.py +++ b/src/convoy/api/events/get_events_paged.py @@ -24,6 +24,7 @@ def _get_kwargs( end_date: str | Unset = UNSET, endpoint_id: list[str] | Unset = UNSET, idempotency_key: str | Unset = UNSET, + idempotency_value: str | Unset = UNSET, next_page_cursor: str | Unset = UNSET, per_page: int | Unset = UNSET, prev_page_cursor: str | Unset = UNSET, @@ -53,6 +54,8 @@ def _get_kwargs( params["idempotencyKey"] = idempotency_key + params["idempotencyValue"] = idempotency_value + params["next_page_cursor"] = next_page_cursor params["perPage"] = per_page @@ -158,6 +161,7 @@ def sync_detailed( end_date: str | Unset = UNSET, endpoint_id: list[str] | Unset = UNSET, idempotency_key: str | Unset = UNSET, + idempotency_value: str | Unset = UNSET, next_page_cursor: str | Unset = UNSET, per_page: int | Unset = UNSET, prev_page_cursor: str | Unset = UNSET, @@ -184,6 +188,7 @@ def sync_detailed( end_date (str | Unset): endpoint_id (list[str] | Unset): idempotency_key (str | Unset): + idempotency_value (str | Unset): next_page_cursor (str | Unset): per_page (int | Unset): prev_page_cursor (str | Unset): @@ -207,6 +212,7 @@ def sync_detailed( end_date=end_date, endpoint_id=endpoint_id, idempotency_key=idempotency_key, + idempotency_value=idempotency_value, next_page_cursor=next_page_cursor, per_page=per_page, prev_page_cursor=prev_page_cursor, @@ -232,6 +238,7 @@ def sync( end_date: str | Unset = UNSET, endpoint_id: list[str] | Unset = UNSET, idempotency_key: str | Unset = UNSET, + idempotency_value: str | Unset = UNSET, next_page_cursor: str | Unset = UNSET, per_page: int | Unset = UNSET, prev_page_cursor: str | Unset = UNSET, @@ -259,6 +266,7 @@ def sync( end_date (str | Unset): endpoint_id (list[str] | Unset): idempotency_key (str | Unset): + idempotency_value (str | Unset): next_page_cursor (str | Unset): per_page (int | Unset): prev_page_cursor (str | Unset): @@ -283,6 +291,7 @@ def sync( end_date=end_date, endpoint_id=endpoint_id, idempotency_key=idempotency_key, + idempotency_value=idempotency_value, next_page_cursor=next_page_cursor, per_page=per_page, prev_page_cursor=prev_page_cursor, @@ -302,6 +311,7 @@ async def asyncio_detailed( end_date: str | Unset = UNSET, endpoint_id: list[str] | Unset = UNSET, idempotency_key: str | Unset = UNSET, + idempotency_value: str | Unset = UNSET, next_page_cursor: str | Unset = UNSET, per_page: int | Unset = UNSET, prev_page_cursor: str | Unset = UNSET, @@ -328,6 +338,7 @@ async def asyncio_detailed( end_date (str | Unset): endpoint_id (list[str] | Unset): idempotency_key (str | Unset): + idempotency_value (str | Unset): next_page_cursor (str | Unset): per_page (int | Unset): prev_page_cursor (str | Unset): @@ -351,6 +362,7 @@ async def asyncio_detailed( end_date=end_date, endpoint_id=endpoint_id, idempotency_key=idempotency_key, + idempotency_value=idempotency_value, next_page_cursor=next_page_cursor, per_page=per_page, prev_page_cursor=prev_page_cursor, @@ -374,6 +386,7 @@ async def asyncio( end_date: str | Unset = UNSET, endpoint_id: list[str] | Unset = UNSET, idempotency_key: str | Unset = UNSET, + idempotency_value: str | Unset = UNSET, next_page_cursor: str | Unset = UNSET, per_page: int | Unset = UNSET, prev_page_cursor: str | Unset = UNSET, @@ -401,6 +414,7 @@ async def asyncio( end_date (str | Unset): endpoint_id (list[str] | Unset): idempotency_key (str | Unset): + idempotency_value (str | Unset): next_page_cursor (str | Unset): per_page (int | Unset): prev_page_cursor (str | Unset): @@ -426,6 +440,7 @@ async def asyncio( end_date=end_date, endpoint_id=endpoint_id, idempotency_key=idempotency_key, + idempotency_value=idempotency_value, next_page_cursor=next_page_cursor, per_page=per_page, prev_page_cursor=prev_page_cursor, diff --git a/src/convoy/models/models_update_source.py b/src/convoy/models/models_update_source.py index 416a38b..8be29dd 100644 --- a/src/convoy/models/models_update_source.py +++ b/src/convoy/models/models_update_source.py @@ -6,6 +6,7 @@ from attrs import define as _attrs_define from attrs import field as _attrs_field +from ..models.datastore_source_provider import DatastoreSourceProvider from ..models.datastore_source_type import DatastoreSourceType from ..types import UNSET, Unset @@ -35,6 +36,7 @@ class ModelsUpdateSource: identify the event in an incoming webhooks project. is_disabled (bool | Unset): This is used to manually enable/disable the source. name (str | Unset): Source name. + provider (DatastoreSourceProvider | Unset): pub_sub (ModelsPubSubConfig | Unset): type_ (DatastoreSourceType | Unset): verifier (ModelsVerifierConfig | Unset): @@ -48,6 +50,7 @@ class ModelsUpdateSource: idempotency_keys: list[str] | Unset = UNSET is_disabled: bool | Unset = UNSET name: str | Unset = UNSET + provider: DatastoreSourceProvider | Unset = UNSET pub_sub: ModelsPubSubConfig | Unset = UNSET type_: DatastoreSourceType | Unset = UNSET verifier: ModelsVerifierConfig | Unset = UNSET @@ -76,6 +79,10 @@ def to_dict(self) -> dict[str, Any]: name = self.name + provider: str | Unset = UNSET + if not isinstance(self.provider, Unset): + provider = self.provider.value + pub_sub: dict[str, Any] | Unset = UNSET if not isinstance(self.pub_sub, Unset): pub_sub = self.pub_sub.to_dict() @@ -107,6 +114,8 @@ def to_dict(self) -> dict[str, Any]: field_dict["is_disabled"] = is_disabled if name is not UNSET: field_dict["name"] = name + if provider is not UNSET: + field_dict["provider"] = provider if pub_sub is not UNSET: field_dict["pub_sub"] = pub_sub if type_ is not UNSET: @@ -144,6 +153,13 @@ def from_dict(cls: type[T], src_dict: Mapping[str, Any]) -> T: name = d.pop("name", UNSET) + _provider = d.pop("provider", UNSET) + provider: DatastoreSourceProvider | Unset + if isinstance(_provider, Unset): + provider = UNSET + else: + provider = DatastoreSourceProvider(_provider) + _pub_sub = d.pop("pub_sub", UNSET) pub_sub: ModelsPubSubConfig | Unset if isinstance(_pub_sub, Unset): @@ -174,6 +190,7 @@ def from_dict(cls: type[T], src_dict: Mapping[str, Any]) -> T: idempotency_keys=idempotency_keys, is_disabled=is_disabled, name=name, + provider=provider, pub_sub=pub_sub, type_=type_, verifier=verifier,