version 22.0.0 (#96)

Co-authored-by: klaviyo-sdk <klaviyo-sdk@klaviyo.com>

Author: klaviyo-sdk

CHANGELOG.md

@@ -7,6 +7,12 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 
 NOTE: For more granular API-specific changes, please see our [API Changelog](https://developers.klaviyo.com/en/docs/changelog_)
 
+## [22.0.0] - revision 2026-01-15
+### Added
+- Added a new [single data source record create endpoint](https://github.com/klaviyo/klaviyo-api-python?tab=readme-ov-file#create-data-source-record) for one-at-a-time ingestion workloads
+### Changed
+- **Breaking:** removed `anonymous_id` from profile payloads
+
 ## [21.0.0] - revision 2025-10-15
 ### Added
 #### Flow Actions API

README.md

@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "openapi_client"
-version = "21.0.0"
+version = "22.0.0"
 description = "Klaviyo API"
 authors = ["Klaviyo Developer Experience Team <developers@klaviyo.com>"]
 license = "License"

pyproject.toml

@@ -1,6 +1,6 @@
 [metadata]
 name = klaviyo-api
-version = 21.0.0
+version = 22.0.0
 author = Klaviyo Developers
 author_email = developers@klaviyo.com
 description = Klaviyo Python SDK

setup.cfg

@@ -19,7 +19,7 @@ class KlaviyoAPI:
     options: Dict[str, Any] = field(default_factory=dict)
 
 
-    _REVISION = "2025-10-15"
+    _REVISION = "2026-01-15"
 
     _STATUS_CODE_CONNECTION_RESET_BY_PEER = 104
     _STATUS_CODE_TOO_MANY_REQUESTS = 429
@@ -321,6 +321,8 @@ def Custom_Objects(self):
         Custom_Objects.bulk_create_data_source_records=self._page_cursor_update(self.retry_logic(Custom_Objects.bulk_create_data_source_records))
         Custom_Objects.create_data_source_record_bulk_create_job=self._page_cursor_update(self.retry_logic(Custom_Objects.create_data_source_record_bulk_create_job))
         Custom_Objects.create_data_source=self._page_cursor_update(self.retry_logic(Custom_Objects.create_data_source))
+        Custom_Objects.create_data_source_record=self._page_cursor_update(self.retry_logic(Custom_Objects.create_data_source_record))
+        Custom_Objects.create_data_source_record_create_job=self._page_cursor_update(self.retry_logic(Custom_Objects.create_data_source_record_create_job))
         Custom_Objects.delete_data_source=self._page_cursor_update(self.retry_logic(Custom_Objects.delete_data_source))
         Custom_Objects.get_data_source=self._page_cursor_update(self.retry_logic(Custom_Objects.get_data_source))
         Custom_Objects.get_data_sources=self._page_cursor_update(self.retry_logic(Custom_Objects.get_data_sources))

src/klaviyo_api/wrapper.py

@@ -14,7 +14,7 @@
 """  # noqa: E501
 
 
-__version__ = "21.0.0"
+__version__ = "22.0.0"
 
 from typing import TYPE_CHECKING
 
@@ -285,6 +285,11 @@
     from openapi_client.models.data_source_record_bulk_create_job_create_query_resource_object_relationships_data_source import DataSourceRecordBulkCreateJobCreateQueryResourceObjectRelationshipsDataSource
     from openapi_client.models.data_source_record_bulk_create_job_create_query_resource_object_relationships_data_source_data import DataSourceRecordBulkCreateJobCreateQueryResourceObjectRelationshipsDataSourceData
     from openapi_client.models.data_source_record_bulk_create_job_enum import DataSourceRecordBulkCreateJobEnum
+    from openapi_client.models.data_source_record_create_job_create_query import DataSourceRecordCreateJobCreateQuery
+    from openapi_client.models.data_source_record_create_job_create_query_resource_object import DataSourceRecordCreateJobCreateQueryResourceObject
+    from openapi_client.models.data_source_record_create_job_create_query_resource_object_attributes import DataSourceRecordCreateJobCreateQueryResourceObjectAttributes
+    from openapi_client.models.data_source_record_create_job_create_query_resource_object_attributes_data_source_record import DataSourceRecordCreateJobCreateQueryResourceObjectAttributesDataSourceRecord
+    from openapi_client.models.data_source_record_create_job_enum import DataSourceRecordCreateJobEnum
     from openapi_client.models.data_source_record_enum import DataSourceRecordEnum
     from openapi_client.models.data_source_record_resource_object import DataSourceRecordResourceObject
     from openapi_client.models.data_source_record_resource_object_attributes import DataSourceRecordResourceObjectAttributes
@@ -755,6 +760,7 @@
     from openapi_client.models.list_members_delete_query import ListMembersDeleteQuery
     from openapi_client.models.list_partial_update_query import ListPartialUpdateQuery
     from openapi_client.models.list_partial_update_query_resource_object import ListPartialUpdateQueryResourceObject
+    from openapi_client.models.list_partial_update_query_resource_object_attributes import ListPartialUpdateQueryResourceObjectAttributes
     from openapi_client.models.list_response_object_resource import ListResponseObjectResource
     from openapi_client.models.list_retrieve_response_object_resource_attributes import ListRetrieveResponseObjectResourceAttributes
     from openapi_client.models.list_retrieve_response_object_resource_extended import ListRetrieveResponseObjectResourceExtended
@@ -988,7 +994,6 @@
     from openapi_client.models.profile_meta_patch_properties import ProfileMetaPatchProperties
     from openapi_client.models.profile_partial_update_query import ProfilePartialUpdateQuery
     from openapi_client.models.profile_partial_update_query_resource_object import ProfilePartialUpdateQueryResourceObject
-    from openapi_client.models.profile_partial_update_query_resource_object_attributes import ProfilePartialUpdateQueryResourceObjectAttributes
     from openapi_client.models.profile_response_object_resource import ProfileResponseObjectResource
     from openapi_client.models.profile_response_object_resource_attributes import ProfileResponseObjectResourceAttributes
     from openapi_client.models.profile_response_object_resource_extended import ProfileResponseObjectResourceExtended
@@ -1482,6 +1487,11 @@
     "DataSourceRecordBulkCreateJobCreateQueryResourceObjectRelationshipsDataSource": "openapi_client.models.data_source_record_bulk_create_job_create_query_resource_object_relationships_data_source",
     "DataSourceRecordBulkCreateJobCreateQueryResourceObjectRelationshipsDataSourceData": "openapi_client.models.data_source_record_bulk_create_job_create_query_resource_object_relationships_data_source_data",
     "DataSourceRecordBulkCreateJobEnum": "openapi_client.models.data_source_record_bulk_create_job_enum",
+    "DataSourceRecordCreateJobCreateQuery": "openapi_client.models.data_source_record_create_job_create_query",
+    "DataSourceRecordCreateJobCreateQueryResourceObject": "openapi_client.models.data_source_record_create_job_create_query_resource_object",
+    "DataSourceRecordCreateJobCreateQueryResourceObjectAttributes": "openapi_client.models.data_source_record_create_job_create_query_resource_object_attributes",
+    "DataSourceRecordCreateJobCreateQueryResourceObjectAttributesDataSourceRecord": "openapi_client.models.data_source_record_create_job_create_query_resource_object_attributes_data_source_record",
+    "DataSourceRecordCreateJobEnum": "openapi_client.models.data_source_record_create_job_enum",
     "DataSourceRecordEnum": "openapi_client.models.data_source_record_enum",
     "DataSourceRecordResourceObject": "openapi_client.models.data_source_record_resource_object",
     "DataSourceRecordResourceObjectAttributes": "openapi_client.models.data_source_record_resource_object_attributes",
@@ -1952,6 +1962,7 @@
     "ListMembersDeleteQuery": "openapi_client.models.list_members_delete_query",
     "ListPartialUpdateQuery": "openapi_client.models.list_partial_update_query",
     "ListPartialUpdateQueryResourceObject": "openapi_client.models.list_partial_update_query_resource_object",
+    "ListPartialUpdateQueryResourceObjectAttributes": "openapi_client.models.list_partial_update_query_resource_object_attributes",
     "ListResponseObjectResource": "openapi_client.models.list_response_object_resource",
     "ListRetrieveResponseObjectResourceAttributes": "openapi_client.models.list_retrieve_response_object_resource_attributes",
     "ListRetrieveResponseObjectResourceExtended": "openapi_client.models.list_retrieve_response_object_resource_extended",
@@ -2185,7 +2196,6 @@
     "ProfileMetaPatchProperties": "openapi_client.models.profile_meta_patch_properties",
     "ProfilePartialUpdateQuery": "openapi_client.models.profile_partial_update_query",
     "ProfilePartialUpdateQueryResourceObject": "openapi_client.models.profile_partial_update_query_resource_object",
-    "ProfilePartialUpdateQueryResourceObjectAttributes": "openapi_client.models.profile_partial_update_query_resource_object_attributes",
     "ProfileResponseObjectResource": "openapi_client.models.profile_response_object_resource",
     "ProfileResponseObjectResourceAttributes": "openapi_client.models.profile_response_object_resource_attributes",
     "ProfileResponseObjectResourceExtended": "openapi_client.models.profile_response_object_resource_extended",

src/openapi_client/__init__.py

@@ -49,7 +49,7 @@ def __init__(self, api_client=None) -> None:
     def get_account(        
         self,
         id: Annotated[StrictStr, Field(description="The ID of the account")],
-        fields_account: Annotated[Optional[List[StrictStr]], Field(description="For more information please visit https://developers.klaviyo.com/en/v2025-10-15/reference/api-overview#sparse-fieldsets")] = None,
+        fields_account: Annotated[Optional[List[StrictStr]], Field(description="For more information please visit https://developers.klaviyo.com/en/v2026-01-15/reference/api-overview#sparse-fieldsets")] = None,
         _request_timeout: Union[
             None,
             Annotated[StrictFloat, Field(gt=0)],
@@ -70,7 +70,7 @@ def get_account(
 
         :param id: The ID of the account (required)
         :type id: str
-        :param fields_account: For more information please visit https://developers.klaviyo.com/en/v2025-10-15/reference/api-overview#sparse-fieldsets
+        :param fields_account: For more information please visit https://developers.klaviyo.com/en/v2026-01-15/reference/api-overview#sparse-fieldsets
         :type fields_account: List[str]
         :param _request_timeout: timeout setting for this request. If one
                                  number provided, it will be total request
@@ -135,7 +135,7 @@ def get_account(
     def get_account_with_http_info(        
         self,
         id: Annotated[StrictStr, Field(description="The ID of the account")],
-        fields_account: Annotated[Optional[List[StrictStr]], Field(description="For more information please visit https://developers.klaviyo.com/en/v2025-10-15/reference/api-overview#sparse-fieldsets")] = None,
+        fields_account: Annotated[Optional[List[StrictStr]], Field(description="For more information please visit https://developers.klaviyo.com/en/v2026-01-15/reference/api-overview#sparse-fieldsets")] = None,
         _request_timeout: Union[
             None,
             Annotated[StrictFloat, Field(gt=0)],
@@ -156,7 +156,7 @@ def get_account_with_http_info(
 
         :param id: The ID of the account (required)
         :type id: str
-        :param fields_account: For more information please visit https://developers.klaviyo.com/en/v2025-10-15/reference/api-overview#sparse-fieldsets
+        :param fields_account: For more information please visit https://developers.klaviyo.com/en/v2026-01-15/reference/api-overview#sparse-fieldsets
         :type fields_account: List[str]
         :param _request_timeout: timeout setting for this request. If one
                                  number provided, it will be total request
@@ -219,7 +219,7 @@ def get_account_with_http_info(
     def get_account_without_preload_content(
         self,
         id: Annotated[StrictStr, Field(description="The ID of the account")],
-        fields_account: Annotated[Optional[List[StrictStr]], Field(description="For more information please visit https://developers.klaviyo.com/en/v2025-10-15/reference/api-overview#sparse-fieldsets")] = None,
+        fields_account: Annotated[Optional[List[StrictStr]], Field(description="For more information please visit https://developers.klaviyo.com/en/v2026-01-15/reference/api-overview#sparse-fieldsets")] = None,
         _request_timeout: Union[
             None,
             Annotated[StrictFloat, Field(gt=0)],
@@ -238,7 +238,7 @@ def get_account_without_preload_content(
 
         :param id: The ID of the account (required)
         :type id: str
-        :param fields_account: For more information please visit https://developers.klaviyo.com/en/v2025-10-15/reference/api-overview#sparse-fieldsets
+        :param fields_account: For more information please visit https://developers.klaviyo.com/en/v2026-01-15/reference/api-overview#sparse-fieldsets
         :type fields_account: List[str]
         :param _request_timeout: timeout setting for this request. If one
                                  number provided, it will be total request
@@ -376,7 +376,7 @@ def _get_account_serialize(
     @validate_call
     def get_accounts(        
         self,
-        fields_account: Annotated[Optional[List[StrictStr]], Field(description="For more information please visit https://developers.klaviyo.com/en/v2025-10-15/reference/api-overview#sparse-fieldsets")] = None,
+        fields_account: Annotated[Optional[List[StrictStr]], Field(description="For more information please visit https://developers.klaviyo.com/en/v2026-01-15/reference/api-overview#sparse-fieldsets")] = None,
         _request_timeout: Union[
             None,
             Annotated[StrictFloat, Field(gt=0)],
@@ -395,7 +395,7 @@ def get_accounts(
 
         Retrieve the account(s) associated with a given private API key. This will return 1 account object within the array.  You can use this to retrieve account-specific data (contact information, timezone, currency, Public API key, etc.) or test if a Private API Key belongs to the correct account prior to performing subsequent actions with the API.<br><br>*Rate limits*:<br>Burst: `1/s`<br>Steady: `15/m`  **Scopes:** `accounts:read`
 
-        :param fields_account: For more information please visit https://developers.klaviyo.com/en/v2025-10-15/reference/api-overview#sparse-fieldsets
+        :param fields_account: For more information please visit https://developers.klaviyo.com/en/v2026-01-15/reference/api-overview#sparse-fieldsets
         :type fields_account: List[str]
         :param _request_timeout: timeout setting for this request. If one
                                  number provided, it will be total request
@@ -458,7 +458,7 @@ def get_accounts(
     @validate_call
     def get_accounts_with_http_info(        
         self,
-        fields_account: Annotated[Optional[List[StrictStr]], Field(description="For more information please visit https://developers.klaviyo.com/en/v2025-10-15/reference/api-overview#sparse-fieldsets")] = None,
+        fields_account: Annotated[Optional[List[StrictStr]], Field(description="For more information please visit https://developers.klaviyo.com/en/v2026-01-15/reference/api-overview#sparse-fieldsets")] = None,
         _request_timeout: Union[
             None,
             Annotated[StrictFloat, Field(gt=0)],
@@ -477,7 +477,7 @@ def get_accounts_with_http_info(
 
         Retrieve the account(s) associated with a given private API key. This will return 1 account object within the array.  You can use this to retrieve account-specific data (contact information, timezone, currency, Public API key, etc.) or test if a Private API Key belongs to the correct account prior to performing subsequent actions with the API.<br><br>*Rate limits*:<br>Burst: `1/s`<br>Steady: `15/m`  **Scopes:** `accounts:read`
 
-        :param fields_account: For more information please visit https://developers.klaviyo.com/en/v2025-10-15/reference/api-overview#sparse-fieldsets
+        :param fields_account: For more information please visit https://developers.klaviyo.com/en/v2026-01-15/reference/api-overview#sparse-fieldsets
         :type fields_account: List[str]
         :param _request_timeout: timeout setting for this request. If one
                                  number provided, it will be total request
@@ -538,7 +538,7 @@ def get_accounts_with_http_info(
     @validate_call
     def get_accounts_without_preload_content(
         self,
-        fields_account: Annotated[Optional[List[StrictStr]], Field(description="For more information please visit https://developers.klaviyo.com/en/v2025-10-15/reference/api-overview#sparse-fieldsets")] = None,
+        fields_account: Annotated[Optional[List[StrictStr]], Field(description="For more information please visit https://developers.klaviyo.com/en/v2026-01-15/reference/api-overview#sparse-fieldsets")] = None,
         _request_timeout: Union[
             None,
             Annotated[StrictFloat, Field(gt=0)],
@@ -555,7 +555,7 @@ def get_accounts_without_preload_content(
 
         Retrieve the account(s) associated with a given private API key. This will return 1 account object within the array.  You can use this to retrieve account-specific data (contact information, timezone, currency, Public API key, etc.) or test if a Private API Key belongs to the correct account prior to performing subsequent actions with the API.<br><br>*Rate limits*:<br>Burst: `1/s`<br>Steady: `15/m`  **Scopes:** `accounts:read`
 
-        :param fields_account: For more information please visit https://developers.klaviyo.com/en/v2025-10-15/reference/api-overview#sparse-fieldsets
+        :param fields_account: For more information please visit https://developers.klaviyo.com/en/v2026-01-15/reference/api-overview#sparse-fieldsets
         :type fields_account: List[str]
         :param _request_timeout: timeout setting for this request. If one
                                  number provided, it will be total request