Merge branch 'main' into ci/fix-gitlab-missing-pk

meltano · Sep 1, 2022 · d2b1ec0 · d2b1ec0
2 parents 9a81355 + b3efc47
commit d2b1ec0
Show file tree

Hide file tree

Showing 6 changed files with 29 additions and 39 deletions.
diff --git a/docs/classes/singer_sdk.exceptions.RecordsWithoutSchemaException.rst b/docs/classes/singer_sdk.exceptions.RecordsWithoutSchemaException.rst
@@ -0,0 +1,7 @@
+singer_sdk.exceptions.RecordsWithoutSchemaException
+==================================================
+
+.. currentmodule:: singer_sdk.exceptions
+
+.. autoclass:: RecordsWithoutSchemaException
+    :members:
diff --git a/docs/reference.rst b/docs/reference.rst
@@ -76,7 +76,7 @@ Exception Types
     exceptions.InvalidStreamSortException
     exceptions.MapExpressionError
     exceptions.MaxRecordsLimitException
-    exceptions.RecordsWitoutSchemaException
+    exceptions.RecordsWithoutSchemaException
     exceptions.RetriableAPIError
     exceptions.StreamMapConfigError
     exceptions.TapStreamConnectionFailure

diff --git a/poetry.lock b/poetry.lock
diff --git a/pyproject.toml b/pyproject.toml
@@ -81,7 +81,7 @@ pyarrow = "^9.0.0"
 freezegun = "^1.2.2"
 viztracer = "^0.15.4"
 requests-mock = "^1.10.0"
-sqlalchemy2-stubs = {version = "^0.0.2a26", allow-prereleases = true}
+sqlalchemy2-stubs = {version = "^0.0.2a27", allow-prereleases = true}
 types-python-dateutil = "^2.8.19"
 types-requests = "^2.28.9"
 coverage = {extras = ["toml"], version = "^6.4"}

diff --git a/singer_sdk/exceptions.py b/singer_sdk/exceptions.py
@@ -22,7 +22,7 @@ class MaxRecordsLimitException(Exception):
     """Exception to raise if the maximum number of allowable records is exceeded."""
 
 
-class RecordsWitoutSchemaException(Exception):
+class RecordsWithoutSchemaException(Exception):
     """Raised if a target receives RECORD messages prior to a SCHEMA message."""
 
 

diff --git a/singer_sdk/target_base.py b/singer_sdk/target_base.py
@@ -13,7 +13,7 @@
 from joblib import Parallel, delayed, parallel_backend
 
 from singer_sdk.cli import common_options
-from singer_sdk.exceptions import RecordsWitoutSchemaException
+from singer_sdk.exceptions import RecordsWithoutSchemaException
 from singer_sdk.helpers._classproperty import classproperty
 from singer_sdk.helpers._compat import final
 from singer_sdk.helpers.capabilities import CapabilitiesEnum, PluginCapabilities
@@ -135,7 +135,7 @@ def get_sink(
         sink depending on the values within the `record` object. Otherwise, please see
         `default_sink_class` property and/or the `get_sink_class()` method.
 
-        Raises :class:`singer_sdk.exceptions.RecordsWitoutSchemaException` if sink does
+        Raises :class:`singer_sdk.exceptions.RecordsWithoutSchemaException` if sink does
         not exist and schema is not sent.
 
         Args:
@@ -233,16 +233,17 @@ def add_sink(
         return result
 
     def _assert_sink_exists(self, stream_name: str) -> None:
-        """Raise a RecordsWitoutSchemaException exception if stream doesn't exist.
+        """Raise a RecordsWithoutSchemaException exception if stream doesn't exist.
 
         Args:
             stream_name: TODO
 
         Raises:
-            RecordsWitoutSchemaException: If sink does not exist and schema is not sent.
+            RecordsWithoutSchemaException: If sink does not exist and schema
+                is not sent.
         """
         if not self.sink_exists(stream_name):
-            raise RecordsWitoutSchemaException(
+            raise RecordsWithoutSchemaException(
                 f"A record for stream '{stream_name}' was encountered before a "
                 "corresponding schema."
             )