Merge branch 'main' into http-connector

noxfile.py

@@ -43,11 +43,10 @@
     "duckdb",
     "duckdb-engine",
     "pytest",
+    "pytest-benchmark",
     "pytest-durations",
     "pytest-httpserver",
     "pytest-snapshot",
-    "freezegun",
-    "pandas",
     "pyarrow",
     "requests-mock",
     "time-machine",

pyproject.toml

@@ -120,17 +120,30 @@ coverage = [
     {extras = ["toml"], version = ">=7.2,<7.3", python = "<3.8"},
     {extras = ["toml"], version = ">=7.2", python = ">=3.8"},
 ]
-requests-mock = "^1.10.0"
-types-jsonschema = "^4.17.0.6"
-types-python-dateutil = "^2.8.19"
-types-pytz = ">=2022.7.1.2,<2024.0.0.0"
-types-requests = "^2.28.11"
-types-simplejson = "^3.18.0"
-types-PyYAML = "^6.0.12"
-coverage = {extras = ["toml"], version = "^7.2"}
-pyarrow = ">=11,<13"
-pytest-httpserver = "^1.0.6"
-pytest-snapshot = "^0.9.0"
+duckdb = ">=0.8.0"
+duckdb-engine = ">=0.9.2"
+mypy = [
+    { version = ">=1.0,<1.5", python = "<3.8" },
+    { version = ">=1.0", python = ">=3.8" },
+]
+pytest-benchmark = ">=4.0.0"
+pytest-httpserver = { version = ">=1.0.6", python = "<4" }
+pytest-snapshot = ">=0.9.0"
+requests-mock = ">=1.10.0"
+time-machine = [
+    { version = ">=2.10.0,<2.11", python = "<3.8" },
+    { version = ">=2.10.0", python = ">=3.8" },
+]
+types-jsonschema = [
+    { version = ">=4.17.0.6,<4.18", python = "<3.8" },
+    { version = ">=4.17.0.6", python = ">=3.8" },
+]
+types-python-dateutil = ">=2.8.19"
+types-pytz = ">=2022.7.1.2"
+types-requests = ">=2.28.11"
+types-simplejson = ">=3.18.0"
+types-PyYAML = ">=6.0.12"
+xdoctest = ">=1.1.1"
 
 [tool.poetry.group.benchmark.dependencies]
 pytest-codspeed = ">=2.2.0"

singer_sdk/connectors/sql.py

@@ -686,7 +686,7 @@ def create_schema(self, schema_name: str) -> None:
         Args:
             schema_name: The target schema to create.
         """
-        with self.connect() as conn:
+        with self.connect() as conn, conn.begin():
             conn.execute(sqlalchemy.schema.CreateSchema(schema_name))
 
     def create_empty_table(
@@ -867,7 +867,7 @@ def rename_column(self, full_table_name: str, old_name: str, new_name: str) -> N
             column_name=old_name,
             new_column_name=new_name,
         )
-        with self.connect() as conn:
+        with self.connect() as conn, conn.begin():
             conn.execute(column_rename_ddl)
 
     def merge_sql_types(
@@ -1173,7 +1173,7 @@ def _adapt_column_type(
             column_name=column_name,
             column_type=compatible_sql_type,
         )
-        with self.connect() as conn:
+        with self.connect() as conn, conn.begin():
             conn.execute(alter_column_ddl)
 
     def serialize_json(self, obj: object) -> str:

singer_sdk/helpers/_compat.py

@@ -22,4 +22,22 @@
 else:
     from importlib import resources
 
-__all__ = ["metadata", "final", "resources", "Protocol"]
+if sys.version_info < (3, 11):
+    from backports.datetime_fromisoformat import MonkeyPatch
+
+    MonkeyPatch.patch_fromisoformat()
+
+datetime_fromisoformat = datetime.datetime.fromisoformat
+date_fromisoformat = datetime.date.fromisoformat
+time_fromisoformat = datetime.time.fromisoformat
+
+__all__ = [
+    "metadata",
+    "final",
+    "resources",
+    "entry_points",
+    "datetime_fromisoformat",
+    "date_fromisoformat",
+    "time_fromisoformat",
+    "Protocol",
+]

tests/core/test_streams.py

@@ -526,9 +526,10 @@ def discover_streams(self):
             return [SelectedStream(self), UnselectedStream(self)]
 
     # Check that the selected stream is selected
-    tap = MyTap(config=None, catalog=input_catalog)
-    for stream in selection:
-        assert tap.streams[stream].selected is selection[stream]
+    tap = MyTap(config=None, catalog=input_catalog, validate_config=False)
+    assert all(
+        tap.streams[stream].selected is selection[stream] for stream in selection
+    )
 
 
 def test_deprecations(tap: SimpleTestTap):