Merge branch 'main' into edgarrmondragon/feat/signals

.github/workflows/constraints.txt

@@ -1,4 +1,4 @@
-griffe==1.1.0
+griffe==1.2.0
 pip==24.2
 poetry==1.8.3
 poetry-plugin-export==1.8.0

.pre-commit-config.yaml

@@ -43,14 +43,14 @@ repos:
         )$
 
 - repo: https://github.com/python-jsonschema/check-jsonschema
-  rev: 0.29.1
+  rev: 0.29.2
   hooks:
   - id: check-dependabot
   - id: check-github-workflows
   - id: check-readthedocs
 
 - repo: https://github.com/astral-sh/ruff-pre-commit
-  rev: v0.6.1
+  rev: v0.6.2
   hooks:
   - id: ruff
     args: [--fix, --exit-non-zero-on-fix, --show-fixes]

cookiecutter/mapper-template/{{cookiecutter.mapper_id}}/.github/workflows/test.yml

@@ -3,7 +3,26 @@
 
 name: Test {{cookiecutter.mapper_id}}
 
-on: [push]
+on:
+  push:
+    branches: [main]
+    paths:
+    - .github/workflows/test.yml
+    - {{ cookiecutter.library_name }}/**
+    - tests/**
+    - poetry.lock
+    - pyproject.toml
+    - tox.ini
+  pull_request:
+    branches: [main]
+    paths:
+    - .github/workflows/test.yml
+    - {{ cookiecutter.library_name }}/**
+    - tests/**
+    - poetry.lock
+    - pyproject.toml
+    - tox.ini
+  workflow_dispatch:
 
 jobs:
   pytest:
@@ -13,7 +32,12 @@ jobs:
     strategy:
       fail-fast: false
       matrix:
-        python-version: ["3.8", "3.9", "3.10", "3.11", "3.12"]
+        python-version:
+        - "3.8"
+        - "3.9"
+        - "3.10"
+        - "3.11"
+        - "3.12"
     steps:
     - uses: actions/checkout@v4
     - name: Set up Python {{ '${{ matrix.python-version }}' }}

cookiecutter/tap-template/{{cookiecutter.tap_id}}/.github/workflows/test.yml

@@ -3,7 +3,26 @@
 
 name: Test {{cookiecutter.tap_id}}
 
-on: [push]
+on:
+  push:
+    branches: [main]
+    paths:
+    - .github/workflows/test.yml
+    - {{ cookiecutter.library_name }}/**
+    - tests/**
+    - poetry.lock
+    - pyproject.toml
+    - tox.ini
+  pull_request:
+    branches: [main]
+    paths:
+    - .github/workflows/test.yml
+    - {{ cookiecutter.library_name }}/**
+    - tests/**
+    - poetry.lock
+    - pyproject.toml
+    - tox.ini
+  workflow_dispatch:
 
 jobs:
   pytest:
@@ -13,7 +32,12 @@ jobs:
     strategy:
       fail-fast: false
       matrix:
-        python-version: ["3.8", "3.9", "3.10", "3.11", "3.12"]
+        python-version:
+        - "3.8"
+        - "3.9"
+        - "3.10"
+        - "3.11"
+        - "3.12"
     steps:
     - uses: actions/checkout@v4
     - name: Set up Python {{ '${{ matrix.python-version }}' }}

cookiecutter/target-template/{{cookiecutter.target_id}}/.github/workflows/test.yml

@@ -3,7 +3,26 @@
 
 name: Test {{cookiecutter.target_id}}
 
-on: [push]
+on:
+  push:
+    branches: [main]
+    paths:
+    - .github/workflows/test.yml
+    - {{ cookiecutter.library_name }}/**
+    - tests/**
+    - poetry.lock
+    - pyproject.toml
+    - tox.ini
+  pull_request:
+    branches: [main]
+    paths:
+    - .github/workflows/test.yml
+    - {{ cookiecutter.library_name }}/**
+    - tests/**
+    - poetry.lock
+    - pyproject.toml
+    - tox.ini
+  workflow_dispatch:
 
 jobs:
   pytest:
@@ -13,7 +32,12 @@ jobs:
     strategy:
       fail-fast: false
       matrix:
-        python-version: ["3.8", "3.9", "3.10", "3.11", "3.12"]
+        python-version:
+        - "3.8"
+        - "3.9"
+        - "3.10"
+        - "3.11"
+        - "3.12"
     steps:
     - uses: actions/checkout@v4
     - name: Set up Python {{ '${{ matrix.python-version }}' }}

pyproject.toml

@@ -90,7 +90,7 @@ pyarrow = { version = ">=13", optional = true }
 pytest = {version=">=7.2.1", optional = true}
 
 # installed as optional 'faker' extra
-faker = {version = ">=22.5,<27.0", optional = true}
+faker = {version = ">=22.5,<29.0", optional = true}
 
 # Crypto extras
 cryptography = { version = ">=3.4.6", optional = true }

singer_sdk/sinks/core.py

@@ -611,7 +611,7 @@ def _after_process_record(self, context: dict) -> None:
 
     # SDK developer overrides:
 
-    def preprocess_record(self, record: dict, context: dict) -> dict:  # noqa: ARG002, PLR6301
+    def preprocess_record(self, record: dict, context: dict) -> dict:  # noqa: PLR6301, ARG002
         """Process incoming record and return a modified result.
 
         Args:
@@ -743,12 +743,15 @@ def process_batch_files(
                     tail,
                     mode="rb",
                 ) as file:
-                    context_file = (
-                        gzip_open(file) if encoding.compression == "gzip" else file
-                    )
-                    context = {
-                        "records": [deserialize_json(line) for line in context_file]  # type: ignore[attr-defined]
-                    }
+                    if encoding.compression == "gzip":
+                        with gzip_open(file) as context_file:
+                            context = {
+                                "records": [
+                                    deserialize_json(line) for line in context_file
+                                ]
+                            }
+                    else:
+                        context = {"records": [deserialize_json(line) for line in file]}
                     self.process_batch(context)
             elif (
                 importlib.util.find_spec("pyarrow")
@@ -760,8 +763,7 @@ def process_batch_files(
                     tail,
                     mode="rb",
                 ) as file:
-                    context_file = file
-                    table = pq.read_table(context_file)
+                    table = pq.read_table(file)
                     context = {"records": table.to_pylist()}
                     self.process_batch(context)
             else: