pip install git+https://github.com/speakeasy-sdks/airbyte-oss-python.git

import airbyte
from airbyte.models import shared

s = airbyte.Airbyte()

req = shared.SaveStatsRequestBody(
    attempt_number=548814,
    job_id=592845,
    stats=shared.AttemptStats(
        bytes_emitted=715190,
        estimated_bytes=844266,
        estimated_records=602763,
        records_committed=857946,
        records_emitted=544883,
        state_messages_emitted=847252,
    ),
    stream_stats=[
        shared.AttemptStreamStats(
            stats=shared.AttemptStats(
                bytes_emitted=623564,
                estimated_bytes=645894,
                estimated_records=384382,
                records_committed=437587,
                records_emitted=297534,
                state_messages_emitted=891773,
            ),
            stream_name='ipsa',
            stream_namespace='delectus',
        ),
        shared.AttemptStreamStats(
            stats=shared.AttemptStats(
                bytes_emitted=272656,
                estimated_bytes=383441,
                estimated_records=477665,
                records_committed=791725,
                records_emitted=812169,
                state_messages_emitted=528895,
            ),
            stream_name='iusto',
            stream_namespace='excepturi',
        ),
    ],
)

res = s.attempt.save_stats(req)

if res.internal_operation_result is not None:
    # handle response

• save_stats - For worker to set sync stats of a running attempt.
• save_sync_config - For worker to save the AttemptSyncConfig for an attempt.
• set_workflow_in_attempt - For worker to register the workflow id in attempt.

• create_connection - Create a connection between a source and a destination
• delete_connection - Delete a connection
• get_connection - Get a connection
• list_all_connections_for_workspace - Returns all connections for a workspace, including deleted connections.
• list_connections_for_workspace - Returns all connections for a workspace.
• reset_connection - Reset the data for the connection. Deletes data generated by the connection in the destination. Resets any cursors back to initial state.
• search_connections - Search connections
• sync_connection - Trigger a manual sync of the connection
• update_connection - Update a connection

• check_connection_to_destination - Check connection to the destination
• check_connection_to_destination_for_update - Check connection for a proposed update to a destination
• clone_destination - Clone destination
• create_destination - Create a destination
• delete_destination - Delete the destination
• get_destination - Get configured destination
• list_destinations_for_workspace - List configured destinations for a workspace
• search_destinations - Search destinations
• update_destination - Update a destination

• create_custom_destination_definition - Creates a custom destinationDefinition for the given workspace
• delete_destination_definition - Delete a destination definition
• get_destination_definition - Get destinationDefinition
• get_destination_definition_for_workspace - Get a destinationDefinition that is configured for the given workspace
• grant_destination_definition_to_workspace - grant a private, non-custom destinationDefinition to a given workspace
• list_destination_definitions - List all the destinationDefinitions the current Airbyte deployment is configured to use
• list_destination_definitions_for_workspace - List all the destinationDefinitions the given workspace is configured to use
• list_latest_destination_definitions - List the latest destinationDefinitions Airbyte supports
• list_private_destination_definitions - List all private, non-custom destinationDefinitions, and for each indicate whether the given workspace has a grant for using the definition. Used by admins to view and modify a given workspace's grants.
• revoke_destination_definition_from_workspace - revoke a grant to a private, non-custom destinationDefinition from a given workspace
• update_destination_definition - Update destinationDefinition

• get_destination_definition_specification - Get specification for a destinationDefinition

• complete_destination_o_auth - Given a destination def ID generate an access/refresh token etc.
• get_destination_o_auth_consent - Given a destination connector definition ID, return the URL to the consent screen where to redirect the user to.
• set_instancewide_destination_oauth_params - Sets instancewide variables to be used for the oauth flow when creating this destination. When set, these variables will be injected into a connector's configuration before any interaction with the connector image itself. This enables running oauth flows with consistent variables e.g: the company's Google Ads developer_token, client_id, and client_secret without the user having to know about these variables.

• get_health_check - Health Check

• create_or_update_state - Create or update the state for a connection.
• get_attempt_normalization_statuses_for_job - Get normalization status to determine if we can bypass normalization phase
• save_stats - For worker to set sync stats of a running attempt.
• save_sync_config - For worker to save the AttemptSyncConfig for an attempt.
• set_workflow_in_attempt - For worker to register the workflow id in attempt.
• write_discover_catalog_result - Should only called from worker, to write result from discover activity back to DB.

• cancel_job - Cancels a job
• get_attempt_normalization_statuses_for_job - Get normalization status to determine if we can bypass normalization phase
• get_job_debug_info - Gets all information needed to debug this job
• get_job_info - Get information about a job
• get_job_info_light - Get information about a job excluding attempt info and logs
• get_last_replication_job
• list_jobs_for - Returns recent jobs for a connection. Jobs are returned in descending order by createdAt.

• get_logs - Get logs

• try_notification_config - Try sending a notifications

• get_open_api_spec - Returns the openapi specification

• check_operation - Check if an operation to be created is valid
• create_operation - Create an operation to be applied as part of a connection pipeline
• delete_operation - Delete an operation
• get_operation - Returns an operation
• list_operations_for_connection - Returns all operations for a connection.
• update_operation - Update an operation

• execute_destination_check_connection - Run check connection for a given destination configuration
• execute_source_check_connection - Run check connection for a given source configuration
• execute_source_discover_schema - Run discover schema for a given source a source configuration

• check_connection_to_source - Check connection to the source
• check_connection_to_source_for_update - Check connection for a proposed update to a source
• clone_source - Clone source
• create_source - Create a source
• delete_source - Delete a source
• discover_schema_for_source - Discover the schema catalog of the source
• get_most_recent_source_actor_catalog - Get most recent ActorCatalog for source
• get_source - Get source
• list_sources_for_workspace - List sources for workspace
• search_sources - Search sources
• update_source - Update a source
• write_discover_catalog_result - Should only called from worker, to write result from discover activity back to DB.

• create_custom_source_definition - Creates a custom sourceDefinition for the given workspace
• delete_source_definition - Delete a source definition
• get_source_definition - Get source
• get_source_definition_for_workspace - Get a sourceDefinition that is configured for the given workspace
• grant_source_definition_to_workspace - grant a private, non-custom sourceDefinition to a given workspace
• list_latest_source_definitions - List the latest sourceDefinitions Airbyte supports
• list_private_source_definitions - List all private, non-custom sourceDefinitions, and for each indicate whether the given workspace has a grant for using the definition. Used by admins to view and modify a given workspace's grants.
• list_source_definitions - List all the sourceDefinitions the current Airbyte deployment is configured to use
• list_source_definitions_for_workspace - List all the sourceDefinitions the given workspace is configured to use
• revoke_source_definition_from_workspace - revoke a grant to a private, non-custom sourceDefinition from a given workspace
• update_source_definition - Update a sourceDefinition

• get_source_definition_specification - Get specification for a SourceDefinition.

• complete_source_o_auth - Given a source def ID generate an access/refresh token etc.
• get_source_o_auth_consent - Given a source connector definition ID, return the URL to the consent screen where to redirect the user to.
• set_instancewide_source_oauth_params - Sets instancewide variables to be used for the oauth flow when creating this source. When set, these variables will be injected into a connector's configuration before any interaction with the connector image itself. This enables running oauth flows with consistent variables e.g: the company's Google Ads developer_token, client_id, and client_secret without the user having to know about these variables.

• create_or_update_state - Create or update the state for a connection.
• get_state - Fetch the current state for a connection.

• get_state_type - Fetch the current state type for a connection.

• web_backend_check_updates - Returns a summary of source and destination definitions that could be updated.

• web_backend_create_connection - Create a connection

• web_backend_get_connection - Get a connection

• web_backend_get_workspace_state - Returns the current state of a workspace

• web_backend_list_connections_for_workspace - Returns all non-deleted connections for a workspace.

• web_backend_list_geographies - Returns available geographies can be selected to run data syncs in a particular geography. The 'auto' entry indicates that the sync will be automatically assigned to a geography according to the platform default behavior. Entries other than 'auto' are two-letter country codes that follow the ISO 3166-1 alpha-2 standard.

• web_backend_update_connection - Update a connection

• create_workspace - Creates a workspace
• delete_workspace - Deletes a workspace
• get_workspace - Find workspace by ID
• get_workspace_by_connection_id - Find workspace by connection id
• get_workspace_by_slug - Find workspace by slug
• list_workspaces - List all workspaces registered in the current Airbyte deployment
• update_workspace - Update workspace state
• update_workspace_feedback - Update workspace feedback state
• update_workspace_name - Update workspace name

This SDK is in beta, and there may be breaking changes between versions without a major version update. Therefore, we recommend pinning usage to a specific package version. This way, you can install the same version each time without breaking changes unless you are intentionally looking for the latest version.

While we value open-source contributions to this SDK, this library is generated programmatically. Feel free to open a PR or a Github issue as a proof of concept and we'll do our best to include it in a future release !