From 3f1226de3e49b7eae595b5768c0343ff1ec46b25 Mon Sep 17 00:00:00 2001 From: Aaron Steers Date: Fri, 20 Dec 2024 13:54:33 -0800 Subject: [PATCH 1/5] ci: move ruff rules to ruff.toml --- pyproject.toml | 12 ------------ ruff.toml | 17 +++++++++++++++++ 2 files changed, 17 insertions(+), 12 deletions(-) create mode 100644 ruff.toml diff --git a/pyproject.toml b/pyproject.toml index eab81bb7f..1d5b43dfb 100644 --- a/pyproject.toml +++ b/pyproject.toml @@ -112,18 +112,6 @@ sql = ["sqlalchemy"] source-declarative-manifest = "airbyte_cdk.cli.source_declarative_manifest:run" -[tool.isort] -skip = ["__init__.py"] # TODO: Remove after this is fixed: https://github.com/airbytehq/airbyte-python-cdk/issues/12 - -[tool.ruff] -exclude = ["__init__.py"] # TODO: Remove after this is fixed: https://github.com/airbytehq/airbyte-python-cdk/issues/12 - -target-version = "py310" -line-length = 100 - -[tool.ruff.lint] -select = ["I"] - [tool.poe.tasks] # Installation install = { shell = "poetry install --all-extras" } diff --git a/ruff.toml b/ruff.toml new file mode 100644 index 000000000..c75ff6750 --- /dev/null +++ b/ruff.toml @@ -0,0 +1,17 @@ +# Ruff linting and formatting config file +# +# We keep this in a dedicated file: +# 1. To keep pyproject.toml clean and focused on Python dependencies. +# 2. To streamline migration of rules and config options across our various Python projects. +# +# Ruff docs for quick reference: +# - https://docs.astral.sh/ruff/configuration/ +# - https://docs.astral.sh/ruff/rules/ + +exclude = ["__init__.py"] # TODO: Remove after this is fixed: https://github.com/airbytehq/airbyte-python-cdk/issues/12 + +target-version = "py310" +line-length = 100 + +[lint] +select = ["I"] From ac81f465ca96a1246118918265e149db2f3c2cab Mon Sep 17 00:00:00 2001 From: Aaron Steers Date: Fri, 20 Dec 2024 13:57:30 -0800 Subject: [PATCH 2/5] ci: add pre-commit config --- .pre-commit-config.yaml | 39 +++++++++++++++++++++++++++++++++++++++ 1 file changed, 39 insertions(+) create mode 100644 .pre-commit-config.yaml diff --git a/.pre-commit-config.yaml b/.pre-commit-config.yaml new file mode 100644 index 000000000..96f8bfc84 --- /dev/null +++ b/.pre-commit-config.yaml @@ -0,0 +1,39 @@ +exclude: | + (?x)( + # Python/system files + ^.*?/\.venv/.*$| + ^.*?/node_modules/.*$| + + # Generated files + ^.*?/generated/.*$| + ) + +repos: + - repo: https://github.com/astral-sh/ruff-pre-commit + rev: v0.8.3 + hooks: + # Run the linter. + - id: ruff + args: + - --fix + - --select=I + + # Run the formatter. + - id: ruff-format + + - repo: https://github.com/pre-commit/mirrors-prettier + rev: v3.0.3 + hooks: + - id: prettier + types_or: [json, yaml] + additional_dependencies: + - prettier@3.0.3 + + - repo: local + hooks: + - id: addlicense + name: Add license headers + entry: addlicense -c "Airbyte, Inc." -l apache -v -f LICENSE_SHORT + language: golang + additional_dependencies: [github.com/google/addlicense@v1.1.1] + files: \.py$ From ded304b2951d0989a9732cff8d6aed2907b5b0f3 Mon Sep 17 00:00:00 2001 From: Aaron Steers Date: Fri, 20 Dec 2024 14:06:57 -0800 Subject: [PATCH 3/5] ci: update pre-commit config and add license_short file --- .pre-commit-config.yaml | 22 ++++++++++++---------- LICENSE_SHORT | 1 + 2 files changed, 13 insertions(+), 10 deletions(-) create mode 100644 LICENSE_SHORT diff --git a/.pre-commit-config.yaml b/.pre-commit-config.yaml index 96f8bfc84..a8a3b6180 100644 --- a/.pre-commit-config.yaml +++ b/.pre-commit-config.yaml @@ -1,13 +1,15 @@ -exclude: | - (?x)( - # Python/system files - ^.*?/\.venv/.*$| - ^.*?/node_modules/.*$| - - # Generated files - ^.*?/generated/.*$| - ) - +# Pre-commit configuration file. +# +# Usage: +# pre-commit # Run pre-commit checks on modified files. +# pre-commit run --all-files # Run pre-commit on all files in the repo. +# +# You do not need to install pre-commit as a git hook. The pre-commit +# tool can be called directly (or in CI). You can also lean on your IDE +# or CLI of the individual tools to run them directly. +# +# If direct execution differs from the pre-commit execution, this is a bug +# and should be raised as an issue. repos: - repo: https://github.com/astral-sh/ruff-pre-commit rev: v0.8.3 diff --git a/LICENSE_SHORT b/LICENSE_SHORT new file mode 100644 index 000000000..ad0158e9b --- /dev/null +++ b/LICENSE_SHORT @@ -0,0 +1 @@ +Copyright (c) 2024 Airbyte, Inc., all rights reserved. From 265e2bc62b6c5ca5d2aa25c71a73b70c326570ae Mon Sep 17 00:00:00 2001 From: Aaron Steers Date: Fri, 20 Dec 2024 16:21:59 -0800 Subject: [PATCH 4/5] fix extra newline --- LICENSE_SHORT | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/LICENSE_SHORT b/LICENSE_SHORT index ad0158e9b..5f5ef93be 100644 --- a/LICENSE_SHORT +++ b/LICENSE_SHORT @@ -1 +1 @@ -Copyright (c) 2024 Airbyte, Inc., all rights reserved. +Copyright (c) 2024 Airbyte, Inc., all rights reserved. \ No newline at end of file From dd58b61c8200b34302027e65ac54b58a15d2e400 Mon Sep 17 00:00:00 2001 From: Aaron Steers Date: Fri, 20 Dec 2024 16:22:14 -0800 Subject: [PATCH 5/5] chore: apply auto-formatting for license and yaml --- .github/workflows/pypi_publish.yml | 2 +- airbyte_cdk/cli/source_declarative_manifest/__init__.py | 2 ++ airbyte_cdk/models/__init__.py | 4 +++- airbyte_cdk/sources/declarative/async_job/__init__.py | 1 + airbyte_cdk/sources/declarative/migrations/__init__.py | 1 + airbyte_cdk/sources/declarative/models/__init__.py | 2 ++ .../declarative/models/declarative_component_schema.py | 2 ++ airbyte_cdk/sources/file_based/__init__.py | 1 + .../sources/file_based/availability_strategy/__init__.py | 1 + airbyte_cdk/sources/file_based/config/__init__.py | 1 + airbyte_cdk/sources/file_based/discovery_policy/__init__.py | 1 + airbyte_cdk/sources/file_based/file_types/__init__.py | 1 + .../sources/file_based/schema_validation_policies/__init__.py | 1 + airbyte_cdk/sources/file_based/stream/__init__.py | 1 + airbyte_cdk/sources/file_based/stream/concurrent/__init__.py | 1 + .../sources/file_based/stream/concurrent/cursor/__init__.py | 1 + airbyte_cdk/sources/file_based/stream/cursor/__init__.py | 1 + .../sources/streams/concurrent/state_converters/__init__.py | 1 + airbyte_cdk/sql/__init__.py | 1 + airbyte_cdk/sql/_util/__init__.py | 1 + airbyte_cdk/test/mock_http/__init__.py | 1 + airbyte_cdk/utils/slice_hasher.py | 1 + unit_tests/__init__.py | 1 + unit_tests/destinations/__init__.py | 1 + unit_tests/source_declarative_manifest/__init__.py | 1 + unit_tests/source_declarative_manifest/resources/__init__.py | 1 + unit_tests/sources/__init__.py | 1 + unit_tests/sources/declarative/async_job/__init__.py | 1 + unit_tests/sources/declarative/concurrency_level/__init__.py | 1 + unit_tests/sources/declarative/decoders/__init__.py | 1 + unit_tests/sources/declarative/incremental/__init__.py | 1 + unit_tests/sources/declarative/migrations/__init__.py | 1 + .../stream_slicers/test_declarative_partition_generator.py | 1 + unit_tests/sources/file_based/__init__.py | 1 + .../sources/file_based/availability_strategy/__init__.py | 1 + unit_tests/sources/file_based/config/__init__.py | 1 + unit_tests/sources/file_based/discovery_policy/__init__.py | 1 + unit_tests/sources/file_based/file_types/__init__.py | 1 + unit_tests/sources/file_based/scenarios/__init__.py | 1 + unit_tests/sources/file_based/stream/__init__.py | 1 + unit_tests/sources/file_based/stream/concurrent/__init__.py | 1 + unit_tests/sources/message/__init__.py | 1 + unit_tests/sources/streams/__init__.py | 1 + unit_tests/sources/streams/checkpoint/__init__.py | 1 + unit_tests/sources/streams/concurrent/test_helpers.py | 1 + unit_tests/sources/streams/http/__init__.py | 1 + unit_tests/sources/streams/http/error_handlers/__init__.py | 1 + .../sources/streams/http/requests_native_auth/__init__.py | 1 + unit_tests/test/__init__.py | 1 + unit_tests/test/mock_http/__init__.py | 1 + unit_tests/test_counter.py | 3 --- unit_tests/utils/__init__.py | 1 + 52 files changed, 56 insertions(+), 5 deletions(-) diff --git a/.github/workflows/pypi_publish.yml b/.github/workflows/pypi_publish.yml index 4df1018b2..302532051 100644 --- a/.github/workflows/pypi_publish.yml +++ b/.github/workflows/pypi_publish.yml @@ -10,7 +10,7 @@ name: Packaging and Publishing on: push: tags: - - 'v*' + - "v*" workflow_dispatch: inputs: version: diff --git a/airbyte_cdk/cli/source_declarative_manifest/__init__.py b/airbyte_cdk/cli/source_declarative_manifest/__init__.py index 8a8d225eb..aac2c498d 100644 --- a/airbyte_cdk/cli/source_declarative_manifest/__init__.py +++ b/airbyte_cdk/cli/source_declarative_manifest/__init__.py @@ -1,3 +1,5 @@ +# Copyright (c) 2024 Airbyte, Inc., all rights reserved. + from airbyte_cdk.cli.source_declarative_manifest._run import run diff --git a/airbyte_cdk/models/__init__.py b/airbyte_cdk/models/__init__.py index 1105cbeda..d7bf0ba7d 100644 --- a/airbyte_cdk/models/__init__.py +++ b/airbyte_cdk/models/__init__.py @@ -1,3 +1,5 @@ +# Copyright (c) 2024 Airbyte, Inc., all rights reserved. +# # The earlier versions of airbyte-cdk (0.28.0<=) had the airbyte_protocol python classes # declared inline in the airbyte-cdk code. However, somewhere around Feb 2023 the # Airbyte Protocol moved to its own repo/PyPi package, called airbyte-protocol-models. @@ -69,4 +71,4 @@ ConfiguredAirbyteCatalogSerializer, ConfiguredAirbyteStreamSerializer, ConnectorSpecificationSerializer, -) \ No newline at end of file +) diff --git a/airbyte_cdk/sources/declarative/async_job/__init__.py b/airbyte_cdk/sources/declarative/async_job/__init__.py index e69de29bb..7f66676b8 100644 --- a/airbyte_cdk/sources/declarative/async_job/__init__.py +++ b/airbyte_cdk/sources/declarative/async_job/__init__.py @@ -0,0 +1 @@ +# Copyright (c) 2024 Airbyte, Inc., all rights reserved. diff --git a/airbyte_cdk/sources/declarative/migrations/__init__.py b/airbyte_cdk/sources/declarative/migrations/__init__.py index e69de29bb..7f66676b8 100644 --- a/airbyte_cdk/sources/declarative/migrations/__init__.py +++ b/airbyte_cdk/sources/declarative/migrations/__init__.py @@ -0,0 +1 @@ +# Copyright (c) 2024 Airbyte, Inc., all rights reserved. diff --git a/airbyte_cdk/sources/declarative/models/__init__.py b/airbyte_cdk/sources/declarative/models/__init__.py index 81f2e2f33..bbfcca789 100644 --- a/airbyte_cdk/sources/declarative/models/__init__.py +++ b/airbyte_cdk/sources/declarative/models/__init__.py @@ -1,2 +1,4 @@ +# Copyright (c) 2024 Airbyte, Inc., all rights reserved. +# # generated by bin/generate_component_manifest_files.py from .declarative_component_schema import * diff --git a/airbyte_cdk/sources/declarative/models/declarative_component_schema.py b/airbyte_cdk/sources/declarative/models/declarative_component_schema.py index 66b90c5d2..d0c7b032f 100644 --- a/airbyte_cdk/sources/declarative/models/declarative_component_schema.py +++ b/airbyte_cdk/sources/declarative/models/declarative_component_schema.py @@ -1,3 +1,5 @@ +# Copyright (c) 2024 Airbyte, Inc., all rights reserved. +# # generated by datamodel-codegen: # filename: declarative_component_schema.yaml diff --git a/airbyte_cdk/sources/file_based/__init__.py b/airbyte_cdk/sources/file_based/__init__.py index 6ea0ca31e..4cd8e89e3 100644 --- a/airbyte_cdk/sources/file_based/__init__.py +++ b/airbyte_cdk/sources/file_based/__init__.py @@ -1,3 +1,4 @@ +# Copyright (c) 2024 Airbyte, Inc., all rights reserved. from .config.abstract_file_based_spec import AbstractFileBasedSpec from .config.csv_format import CsvFormat from .config.file_based_stream_config import FileBasedStreamConfig diff --git a/airbyte_cdk/sources/file_based/availability_strategy/__init__.py b/airbyte_cdk/sources/file_based/availability_strategy/__init__.py index a05e54210..698c088da 100644 --- a/airbyte_cdk/sources/file_based/availability_strategy/__init__.py +++ b/airbyte_cdk/sources/file_based/availability_strategy/__init__.py @@ -1,3 +1,4 @@ +# Copyright (c) 2024 Airbyte, Inc., all rights reserved. from .abstract_file_based_availability_strategy import AbstractFileBasedAvailabilityStrategy, AbstractFileBasedAvailabilityStrategyWrapper from .default_file_based_availability_strategy import DefaultFileBasedAvailabilityStrategy diff --git a/airbyte_cdk/sources/file_based/config/__init__.py b/airbyte_cdk/sources/file_based/config/__init__.py index e69de29bb..7f66676b8 100644 --- a/airbyte_cdk/sources/file_based/config/__init__.py +++ b/airbyte_cdk/sources/file_based/config/__init__.py @@ -0,0 +1 @@ +# Copyright (c) 2024 Airbyte, Inc., all rights reserved. diff --git a/airbyte_cdk/sources/file_based/discovery_policy/__init__.py b/airbyte_cdk/sources/file_based/discovery_policy/__init__.py index c50aa1a4e..65f06317d 100644 --- a/airbyte_cdk/sources/file_based/discovery_policy/__init__.py +++ b/airbyte_cdk/sources/file_based/discovery_policy/__init__.py @@ -1,3 +1,4 @@ +# Copyright (c) 2024 Airbyte, Inc., all rights reserved. from airbyte_cdk.sources.file_based.discovery_policy.abstract_discovery_policy import AbstractDiscoveryPolicy from airbyte_cdk.sources.file_based.discovery_policy.default_discovery_policy import DefaultDiscoveryPolicy diff --git a/airbyte_cdk/sources/file_based/file_types/__init__.py b/airbyte_cdk/sources/file_based/file_types/__init__.py index 083df8f17..0550445f3 100644 --- a/airbyte_cdk/sources/file_based/file_types/__init__.py +++ b/airbyte_cdk/sources/file_based/file_types/__init__.py @@ -1,3 +1,4 @@ +# Copyright (c) 2024 Airbyte, Inc., all rights reserved. from typing import Any, Mapping, Type from airbyte_cdk.sources.file_based.config.avro_format import AvroFormat diff --git a/airbyte_cdk/sources/file_based/schema_validation_policies/__init__.py b/airbyte_cdk/sources/file_based/schema_validation_policies/__init__.py index d2cc0e63b..28e40804e 100644 --- a/airbyte_cdk/sources/file_based/schema_validation_policies/__init__.py +++ b/airbyte_cdk/sources/file_based/schema_validation_policies/__init__.py @@ -1,3 +1,4 @@ +# Copyright (c) 2024 Airbyte, Inc., all rights reserved. from airbyte_cdk.sources.file_based.schema_validation_policies.abstract_schema_validation_policy import AbstractSchemaValidationPolicy from airbyte_cdk.sources.file_based.schema_validation_policies.default_schema_validation_policies import ( DEFAULT_SCHEMA_VALIDATION_POLICIES, diff --git a/airbyte_cdk/sources/file_based/stream/__init__.py b/airbyte_cdk/sources/file_based/stream/__init__.py index 4b5c4bc2e..1d937c26b 100644 --- a/airbyte_cdk/sources/file_based/stream/__init__.py +++ b/airbyte_cdk/sources/file_based/stream/__init__.py @@ -1,3 +1,4 @@ +# Copyright (c) 2024 Airbyte, Inc., all rights reserved. from airbyte_cdk.sources.file_based.stream.abstract_file_based_stream import AbstractFileBasedStream from airbyte_cdk.sources.file_based.stream.default_file_based_stream import DefaultFileBasedStream diff --git a/airbyte_cdk/sources/file_based/stream/concurrent/__init__.py b/airbyte_cdk/sources/file_based/stream/concurrent/__init__.py index e69de29bb..7f66676b8 100644 --- a/airbyte_cdk/sources/file_based/stream/concurrent/__init__.py +++ b/airbyte_cdk/sources/file_based/stream/concurrent/__init__.py @@ -0,0 +1 @@ +# Copyright (c) 2024 Airbyte, Inc., all rights reserved. diff --git a/airbyte_cdk/sources/file_based/stream/concurrent/cursor/__init__.py b/airbyte_cdk/sources/file_based/stream/concurrent/cursor/__init__.py index 590f37bb6..437efa079 100644 --- a/airbyte_cdk/sources/file_based/stream/concurrent/cursor/__init__.py +++ b/airbyte_cdk/sources/file_based/stream/concurrent/cursor/__init__.py @@ -1,3 +1,4 @@ +# Copyright (c) 2024 Airbyte, Inc., all rights reserved. from .abstract_concurrent_file_based_cursor import AbstractConcurrentFileBasedCursor from .file_based_concurrent_cursor import FileBasedConcurrentCursor from .file_based_final_state_cursor import FileBasedFinalStateCursor diff --git a/airbyte_cdk/sources/file_based/stream/cursor/__init__.py b/airbyte_cdk/sources/file_based/stream/cursor/__init__.py index c1bf15a5d..6f801f511 100644 --- a/airbyte_cdk/sources/file_based/stream/cursor/__init__.py +++ b/airbyte_cdk/sources/file_based/stream/cursor/__init__.py @@ -1,3 +1,4 @@ +# Copyright (c) 2024 Airbyte, Inc., all rights reserved. from .abstract_file_based_cursor import AbstractFileBasedCursor from .default_file_based_cursor import DefaultFileBasedCursor diff --git a/airbyte_cdk/sources/streams/concurrent/state_converters/__init__.py b/airbyte_cdk/sources/streams/concurrent/state_converters/__init__.py index e69de29bb..7f66676b8 100644 --- a/airbyte_cdk/sources/streams/concurrent/state_converters/__init__.py +++ b/airbyte_cdk/sources/streams/concurrent/state_converters/__init__.py @@ -0,0 +1 @@ +# Copyright (c) 2024 Airbyte, Inc., all rights reserved. diff --git a/airbyte_cdk/sql/__init__.py b/airbyte_cdk/sql/__init__.py index e69de29bb..7f66676b8 100644 --- a/airbyte_cdk/sql/__init__.py +++ b/airbyte_cdk/sql/__init__.py @@ -0,0 +1 @@ +# Copyright (c) 2024 Airbyte, Inc., all rights reserved. diff --git a/airbyte_cdk/sql/_util/__init__.py b/airbyte_cdk/sql/_util/__init__.py index e69de29bb..7f66676b8 100644 --- a/airbyte_cdk/sql/_util/__init__.py +++ b/airbyte_cdk/sql/_util/__init__.py @@ -0,0 +1 @@ +# Copyright (c) 2024 Airbyte, Inc., all rights reserved. diff --git a/airbyte_cdk/test/mock_http/__init__.py b/airbyte_cdk/test/mock_http/__init__.py index 88b28b022..cc6c75a81 100644 --- a/airbyte_cdk/test/mock_http/__init__.py +++ b/airbyte_cdk/test/mock_http/__init__.py @@ -1,3 +1,4 @@ +# Copyright (c) 2024 Airbyte, Inc., all rights reserved. from airbyte_cdk.test.mock_http.matcher import HttpRequestMatcher from airbyte_cdk.test.mock_http.request import HttpRequest from airbyte_cdk.test.mock_http.response import HttpResponse diff --git a/airbyte_cdk/utils/slice_hasher.py b/airbyte_cdk/utils/slice_hasher.py index 7f46dd768..520a988c5 100644 --- a/airbyte_cdk/utils/slice_hasher.py +++ b/airbyte_cdk/utils/slice_hasher.py @@ -1,3 +1,4 @@ +# Copyright (c) 2024 Airbyte, Inc., all rights reserved. import hashlib import json from typing import Any, Final, Mapping, Optional diff --git a/unit_tests/__init__.py b/unit_tests/__init__.py index 51e56f3ad..037ec65eb 100644 --- a/unit_tests/__init__.py +++ b/unit_tests/__init__.py @@ -1,3 +1,4 @@ +# Copyright (c) 2024 Airbyte, Inc., all rights reserved. # THIS STOPS SOME MODELS TESTS FROM FALLING OVER. IT'S A HACK, WE SHOULD PIN DOWN WHAT'S ACTUALLY GOING ON HERE # Import the thing that needs to be imported to stop the tests from falling over diff --git a/unit_tests/destinations/__init__.py b/unit_tests/destinations/__init__.py index e69de29bb..7f66676b8 100644 --- a/unit_tests/destinations/__init__.py +++ b/unit_tests/destinations/__init__.py @@ -0,0 +1 @@ +# Copyright (c) 2024 Airbyte, Inc., all rights reserved. diff --git a/unit_tests/source_declarative_manifest/__init__.py b/unit_tests/source_declarative_manifest/__init__.py index e69de29bb..7f66676b8 100644 --- a/unit_tests/source_declarative_manifest/__init__.py +++ b/unit_tests/source_declarative_manifest/__init__.py @@ -0,0 +1 @@ +# Copyright (c) 2024 Airbyte, Inc., all rights reserved. diff --git a/unit_tests/source_declarative_manifest/resources/__init__.py b/unit_tests/source_declarative_manifest/resources/__init__.py index e69de29bb..7f66676b8 100644 --- a/unit_tests/source_declarative_manifest/resources/__init__.py +++ b/unit_tests/source_declarative_manifest/resources/__init__.py @@ -0,0 +1 @@ +# Copyright (c) 2024 Airbyte, Inc., all rights reserved. diff --git a/unit_tests/sources/__init__.py b/unit_tests/sources/__init__.py index e69de29bb..7f66676b8 100644 --- a/unit_tests/sources/__init__.py +++ b/unit_tests/sources/__init__.py @@ -0,0 +1 @@ +# Copyright (c) 2024 Airbyte, Inc., all rights reserved. diff --git a/unit_tests/sources/declarative/async_job/__init__.py b/unit_tests/sources/declarative/async_job/__init__.py index e69de29bb..7f66676b8 100644 --- a/unit_tests/sources/declarative/async_job/__init__.py +++ b/unit_tests/sources/declarative/async_job/__init__.py @@ -0,0 +1 @@ +# Copyright (c) 2024 Airbyte, Inc., all rights reserved. diff --git a/unit_tests/sources/declarative/concurrency_level/__init__.py b/unit_tests/sources/declarative/concurrency_level/__init__.py index e69de29bb..7f66676b8 100644 --- a/unit_tests/sources/declarative/concurrency_level/__init__.py +++ b/unit_tests/sources/declarative/concurrency_level/__init__.py @@ -0,0 +1 @@ +# Copyright (c) 2024 Airbyte, Inc., all rights reserved. diff --git a/unit_tests/sources/declarative/decoders/__init__.py b/unit_tests/sources/declarative/decoders/__init__.py index e69de29bb..7f66676b8 100644 --- a/unit_tests/sources/declarative/decoders/__init__.py +++ b/unit_tests/sources/declarative/decoders/__init__.py @@ -0,0 +1 @@ +# Copyright (c) 2024 Airbyte, Inc., all rights reserved. diff --git a/unit_tests/sources/declarative/incremental/__init__.py b/unit_tests/sources/declarative/incremental/__init__.py index e69de29bb..7f66676b8 100644 --- a/unit_tests/sources/declarative/incremental/__init__.py +++ b/unit_tests/sources/declarative/incremental/__init__.py @@ -0,0 +1 @@ +# Copyright (c) 2024 Airbyte, Inc., all rights reserved. diff --git a/unit_tests/sources/declarative/migrations/__init__.py b/unit_tests/sources/declarative/migrations/__init__.py index e69de29bb..7f66676b8 100644 --- a/unit_tests/sources/declarative/migrations/__init__.py +++ b/unit_tests/sources/declarative/migrations/__init__.py @@ -0,0 +1 @@ +# Copyright (c) 2024 Airbyte, Inc., all rights reserved. diff --git a/unit_tests/sources/declarative/stream_slicers/test_declarative_partition_generator.py b/unit_tests/sources/declarative/stream_slicers/test_declarative_partition_generator.py index 1a4f07212..57faabd80 100644 --- a/unit_tests/sources/declarative/stream_slicers/test_declarative_partition_generator.py +++ b/unit_tests/sources/declarative/stream_slicers/test_declarative_partition_generator.py @@ -1,3 +1,4 @@ +# Copyright (c) 2024 Airbyte, Inc., all rights reserved. from typing import List from unittest import TestCase from unittest.mock import Mock diff --git a/unit_tests/sources/file_based/__init__.py b/unit_tests/sources/file_based/__init__.py index e69de29bb..7f66676b8 100644 --- a/unit_tests/sources/file_based/__init__.py +++ b/unit_tests/sources/file_based/__init__.py @@ -0,0 +1 @@ +# Copyright (c) 2024 Airbyte, Inc., all rights reserved. diff --git a/unit_tests/sources/file_based/availability_strategy/__init__.py b/unit_tests/sources/file_based/availability_strategy/__init__.py index e69de29bb..7f66676b8 100644 --- a/unit_tests/sources/file_based/availability_strategy/__init__.py +++ b/unit_tests/sources/file_based/availability_strategy/__init__.py @@ -0,0 +1 @@ +# Copyright (c) 2024 Airbyte, Inc., all rights reserved. diff --git a/unit_tests/sources/file_based/config/__init__.py b/unit_tests/sources/file_based/config/__init__.py index e69de29bb..7f66676b8 100644 --- a/unit_tests/sources/file_based/config/__init__.py +++ b/unit_tests/sources/file_based/config/__init__.py @@ -0,0 +1 @@ +# Copyright (c) 2024 Airbyte, Inc., all rights reserved. diff --git a/unit_tests/sources/file_based/discovery_policy/__init__.py b/unit_tests/sources/file_based/discovery_policy/__init__.py index e69de29bb..7f66676b8 100644 --- a/unit_tests/sources/file_based/discovery_policy/__init__.py +++ b/unit_tests/sources/file_based/discovery_policy/__init__.py @@ -0,0 +1 @@ +# Copyright (c) 2024 Airbyte, Inc., all rights reserved. diff --git a/unit_tests/sources/file_based/file_types/__init__.py b/unit_tests/sources/file_based/file_types/__init__.py index e69de29bb..7f66676b8 100644 --- a/unit_tests/sources/file_based/file_types/__init__.py +++ b/unit_tests/sources/file_based/file_types/__init__.py @@ -0,0 +1 @@ +# Copyright (c) 2024 Airbyte, Inc., all rights reserved. diff --git a/unit_tests/sources/file_based/scenarios/__init__.py b/unit_tests/sources/file_based/scenarios/__init__.py index e69de29bb..7f66676b8 100644 --- a/unit_tests/sources/file_based/scenarios/__init__.py +++ b/unit_tests/sources/file_based/scenarios/__init__.py @@ -0,0 +1 @@ +# Copyright (c) 2024 Airbyte, Inc., all rights reserved. diff --git a/unit_tests/sources/file_based/stream/__init__.py b/unit_tests/sources/file_based/stream/__init__.py index e69de29bb..7f66676b8 100644 --- a/unit_tests/sources/file_based/stream/__init__.py +++ b/unit_tests/sources/file_based/stream/__init__.py @@ -0,0 +1 @@ +# Copyright (c) 2024 Airbyte, Inc., all rights reserved. diff --git a/unit_tests/sources/file_based/stream/concurrent/__init__.py b/unit_tests/sources/file_based/stream/concurrent/__init__.py index e69de29bb..7f66676b8 100644 --- a/unit_tests/sources/file_based/stream/concurrent/__init__.py +++ b/unit_tests/sources/file_based/stream/concurrent/__init__.py @@ -0,0 +1 @@ +# Copyright (c) 2024 Airbyte, Inc., all rights reserved. diff --git a/unit_tests/sources/message/__init__.py b/unit_tests/sources/message/__init__.py index e69de29bb..7f66676b8 100644 --- a/unit_tests/sources/message/__init__.py +++ b/unit_tests/sources/message/__init__.py @@ -0,0 +1 @@ +# Copyright (c) 2024 Airbyte, Inc., all rights reserved. diff --git a/unit_tests/sources/streams/__init__.py b/unit_tests/sources/streams/__init__.py index e69de29bb..7f66676b8 100644 --- a/unit_tests/sources/streams/__init__.py +++ b/unit_tests/sources/streams/__init__.py @@ -0,0 +1 @@ +# Copyright (c) 2024 Airbyte, Inc., all rights reserved. diff --git a/unit_tests/sources/streams/checkpoint/__init__.py b/unit_tests/sources/streams/checkpoint/__init__.py index e69de29bb..7f66676b8 100644 --- a/unit_tests/sources/streams/checkpoint/__init__.py +++ b/unit_tests/sources/streams/checkpoint/__init__.py @@ -0,0 +1 @@ +# Copyright (c) 2024 Airbyte, Inc., all rights reserved. diff --git a/unit_tests/sources/streams/concurrent/test_helpers.py b/unit_tests/sources/streams/concurrent/test_helpers.py index 8f067eda9..434e399ad 100644 --- a/unit_tests/sources/streams/concurrent/test_helpers.py +++ b/unit_tests/sources/streams/concurrent/test_helpers.py @@ -1,3 +1,4 @@ +# Copyright (c) 2024 Airbyte, Inc., all rights reserved. import pytest from airbyte_cdk.sources.streams.concurrent.helpers import get_primary_key_from_stream diff --git a/unit_tests/sources/streams/http/__init__.py b/unit_tests/sources/streams/http/__init__.py index e69de29bb..7f66676b8 100644 --- a/unit_tests/sources/streams/http/__init__.py +++ b/unit_tests/sources/streams/http/__init__.py @@ -0,0 +1 @@ +# Copyright (c) 2024 Airbyte, Inc., all rights reserved. diff --git a/unit_tests/sources/streams/http/error_handlers/__init__.py b/unit_tests/sources/streams/http/error_handlers/__init__.py index e69de29bb..7f66676b8 100644 --- a/unit_tests/sources/streams/http/error_handlers/__init__.py +++ b/unit_tests/sources/streams/http/error_handlers/__init__.py @@ -0,0 +1 @@ +# Copyright (c) 2024 Airbyte, Inc., all rights reserved. diff --git a/unit_tests/sources/streams/http/requests_native_auth/__init__.py b/unit_tests/sources/streams/http/requests_native_auth/__init__.py index e69de29bb..7f66676b8 100644 --- a/unit_tests/sources/streams/http/requests_native_auth/__init__.py +++ b/unit_tests/sources/streams/http/requests_native_auth/__init__.py @@ -0,0 +1 @@ +# Copyright (c) 2024 Airbyte, Inc., all rights reserved. diff --git a/unit_tests/test/__init__.py b/unit_tests/test/__init__.py index e69de29bb..7f66676b8 100644 --- a/unit_tests/test/__init__.py +++ b/unit_tests/test/__init__.py @@ -0,0 +1 @@ +# Copyright (c) 2024 Airbyte, Inc., all rights reserved. diff --git a/unit_tests/test/mock_http/__init__.py b/unit_tests/test/mock_http/__init__.py index e69de29bb..7f66676b8 100644 --- a/unit_tests/test/mock_http/__init__.py +++ b/unit_tests/test/mock_http/__init__.py @@ -0,0 +1 @@ +# Copyright (c) 2024 Airbyte, Inc., all rights reserved. diff --git a/unit_tests/test_counter.py b/unit_tests/test_counter.py index f6d2c22b3..b04d15cfb 100644 --- a/unit_tests/test_counter.py +++ b/unit_tests/test_counter.py @@ -1,7 +1,4 @@ -# # Copyright (c) 2023 Airbyte, Inc., all rights reserved. -# - from unittest import mock diff --git a/unit_tests/utils/__init__.py b/unit_tests/utils/__init__.py index e69de29bb..7f66676b8 100644 --- a/unit_tests/utils/__init__.py +++ b/unit_tests/utils/__init__.py @@ -0,0 +1 @@ +# Copyright (c) 2024 Airbyte, Inc., all rights reserved.