airbyte-cdk

• Add schema validation for declarative YAML connector configs

• Bugfix: Correctly set parent slice stream for sub-resource streams

• Improve filter_secrets skip empty secret

• Replace JelloRecordExtractor with DpathRecordExtractor

• Bugfix: Fix bug in DatetimeStreamSlicer's parsing method

• Bugfix: Fix bug in DatetimeStreamSlicer's format method

• Refactor declarative package to dataclasses
• Bugfix: Requester header always converted to string
• Bugfix: Reset paginator state between stream slices
• Bugfix: Record selector handles single records

• Bugfix: DatetimeStreamSlicer cast interpolated result to string before converting to datetime
• Bugfix: Set stream slicer's request options in SimpleRetriever

• AbstractSource emits a state message when reading incremental even if there were no stream slices to process.

• Replace parse-time string interpolation with run-time interpolation in YAML-based sources

• Add support declarative token authenticator.

• Call init_uncaught_exception_handler from AirbyteEntrypoint.init and Destination.run_cmd
• Add the ability to remove & add records in YAML-based sources

• Allow for detailed debug messages to be enabled using the --debug command.

• Add support for configurable oauth request payload and declarative oauth authenticator.

• Define namespace property on the Stream class inside core.py.

Bugfix: Correctly obfuscate nested secrets and secrets specified inside oneOf blocks inside the connector's spec.

• Remove legacy sentry code

• Add requests.exceptions.ChunkedEncodingError to transient errors so it could be retried

• Add Stream.get_error_display_message() to retrieve user-friendly messages from exceptions encountered while reading streams.
• Add default error error message retrieval logic for HTTPStreams following common API patterns.

TypeTransformer.default_convert catch TypeError

Update protocol models to support per-stream state: #12829.

• Update protocol models to include AirbyteTraceMessage
• Emit an AirbyteTraceMessage on uncaught exceptions
• Add AirbyteTracedException

Add support for reading the spec from a YAML file (spec.yaml)

• Add ability to import IncrementalMixin from airbyte_cdk.sources.streams.
• Bumped minimum supported Python version to 3.9.

Remove a false positive error logging during the send process.

Fix BaseBackoffException constructor

Improve logging for Error handling during send process.

Add support for streams with explicit state attribute.

Fix type annotations.

Fix typing errors.

Integrate Sentry for performance and errors tracking.

Log http response status code and its content.

Fix logging of unhandled exceptions: print stacktrace.

Add base pydantic model for connector config and schemas.

Fix build error

Add __init__.py to mark the directory airbyte_cdk/utils as a package.

Improve URL-creation in CDK. Changed to using urllib.parse.urljoin().

Fix emitted_at from seconds * 1000 to correct milliseconds.

Fix broken logger in streams: add logger inheritance for streams from airbyte.

Fix false warnings on record transform.

Fix logging inside source and streams

Resolve $ref fields for discover json schema.

• Added Sphinx docs airbyte-cdk/python/reference_docs module.
• Added module documents at airbyte-cdk/python/sphinx-docs.md.
• Added Read the Docs publishing configuration at .readthedocs.yaml.

Transforming Python log levels to Airbyte protocol log levels

Updated OAuth2Specification.rootObject type in airbyte_protocol to allow string or int

Fix import logger error

Added check_config_against_spec parameter to Connector abstract class to allow skipping validating the input config against the spec for non-check calls

Improving unit test for logger

Use python standard logging instead of custom class

Modified OAuth2Specification model, added new fields: rootObject and oauthFlowOutputParameters

Added Transform class to use for mutating record value types so they adhere to jsonschema definition.

Added the ability to use caching for efficient synchronization of nested streams.

Allow passing custom headers to request in OAuth2Authenticator.refresh_access_token(): https://github.com/airbytehq/airbyte/pull/6219

Resolve nested schema references and move external references to single schema definitions.

• Allow using requests.auth.AuthBase as authenticators instead of custom CDK authenticators.
• Implement Oauth2Authenticator, MultipleTokenAuthenticator and TokenAuthenticator authenticators.
• Add support for both legacy and requests native authenticator to HttpStream class.

Fix incremental stream not saved state when internal limit config set.