1
0
mirror of synced 2025-12-26 05:05:18 -05:00

santa: rename sdk --> cdk (#3040)

This commit is contained in:
Sherif A. Nada
2021-04-23 15:07:27 -07:00
committed by GitHub
parent 159a27f989
commit 6bec66ed8d
17 changed files with 20 additions and 20 deletions

View File

@@ -27,13 +27,13 @@ from base_python.catalog_helpers import CatalogHelper
from base_python.client import BaseClient
from base_python.integration import AirbyteSpec, Destination, Integration, Source
from base_python.logger import AirbyteLogger
from base_python.sdk.abstract_source import AbstractSource
from base_python.cdk.abstract_source import AbstractSource
# Separate the SDK imports so they can be moved somewhere else more easily
from base_python.sdk.streams.auth.core import HttpAuthenticator
from base_python.sdk.streams.auth.token import TokenAuthenticator
from base_python.sdk.streams.core import Stream
from base_python.sdk.streams.http import HttpStream
from base_python.cdk.streams.auth.core import HttpAuthenticator
from base_python.cdk.streams.auth.token import TokenAuthenticator
from base_python.cdk.streams.core import Stream
from base_python.cdk.streams.http import HttpStream
from base_python.source import BaseSource
# Must be the last one because the way we load the connector module creates a circular

View File

@@ -42,7 +42,7 @@ from airbyte_protocol import (
from airbyte_protocol import Type as MessageType
from base_python.integration import Source
from base_python.logger import AirbyteLogger
from base_python.sdk.streams.core import Stream
from base_python.cdk.streams.core import Stream
class AbstractSource(Source, ABC):

View File

@@ -25,7 +25,7 @@ SOFTWARE.
from typing import Any, Mapping
from base_python.sdk.streams.auth.core import HttpAuthenticator
from base_python.cdk.streams.auth.core import HttpAuthenticator
class JWTAuthenticator(HttpAuthenticator):

View File

@@ -27,7 +27,7 @@ from typing import Any, Mapping, Tuple
import pendulum
import requests
from base_python.sdk.streams.auth.core import HttpAuthenticator
from base_python.cdk.streams.auth.core import HttpAuthenticator
class Oauth2Authenticator(HttpAuthenticator):

View File

@@ -25,7 +25,7 @@ SOFTWARE.
from typing import Any, Mapping
from base_python.sdk.streams.auth.core import HttpAuthenticator
from base_python.cdk.streams.auth.core import HttpAuthenticator
class TokenAuthenticator(HttpAuthenticator):

View File

@@ -27,7 +27,7 @@ import inspect
from abc import ABC, abstractmethod
from typing import Any, Iterable, List, Mapping, MutableMapping, Optional, Union
import base_python.sdk.utils.casing as casing
import base_python.cdk.utils.casing as casing
from airbyte_protocol import AirbyteStream, SyncMode
from base_python.logger import AirbyteLogger
from base_python.schema_helpers import ResourceSchemaLoader

View File

@@ -28,10 +28,10 @@ from typing import Any, Iterable, List, Mapping, MutableMapping, Optional
import requests
from airbyte_protocol import SyncMode
from base_python.sdk.streams.auth.core import HttpAuthenticator, NoAuth
from base_python.sdk.streams.core import Stream
from base_python.sdk.streams.exceptions import DefaultBackoffException, UserDefinedBackoffException
from base_python.sdk.streams.rate_limiting import default_backoff_handler, user_defined_backoff_handler
from base_python.cdk.streams.auth.core import HttpAuthenticator, NoAuth
from base_python.cdk.streams.core import Stream
from base_python.cdk.streams.exceptions import DefaultBackoffException, UserDefinedBackoffException
from base_python.cdk.streams.rate_limiting import default_backoff_handler, user_defined_backoff_handler
class HttpStream(Stream, ABC):

View File

@@ -28,7 +28,7 @@ import time
import backoff
from base_python.logger import AirbyteLogger
from base_python.sdk.streams.exceptions import DefaultBackoffException, UserDefinedBackoffException
from base_python.cdk.streams.exceptions import DefaultBackoffException, UserDefinedBackoffException
from requests import codes, exceptions
TRANSIENT_EXCEPTIONS = (DefaultBackoffException, exceptions.ConnectTimeout, exceptions.ReadTimeout, exceptions.ConnectionError)