Skip to content

Commit

Permalink
Source Fauna: fix unit tests (#19534)
Browse files Browse the repository at this point in the history
* Source Fauna: fix unit tests

* Bump version in dockerfile

* Update fauna.md

* auto-bump connector version

Co-authored-by: Akash Kulkarni <113392464+akashkulk@users.noreply.github.com>
Co-authored-by: Octavia Squidington III <octavia-squidington-iii@users.noreply.github.com>
  • Loading branch information
3 people committed Nov 17, 2022
1 parent 174a740 commit 4f8545f
Show file tree
Hide file tree
Showing 6 changed files with 13 additions and 6 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -452,7 +452,7 @@
- name: Fauna
sourceDefinitionId: 3825db3e-c94b-42ac-bd53-b5a9507ace2b
dockerRepository: airbyte/source-fauna
dockerImageTag: dev
dockerImageTag: 0.1.0
documentationUrl: https://docs.airbyte.com/integrations/sources/fauna
icon: fauna.svg
sourceType: database
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -3774,7 +3774,7 @@
supportsNormalization: false
supportsDBT: false
supported_destination_sync_modes: []
- dockerImage: "airbyte/source-fauna:dev"
- dockerImage: "airbyte/source-fauna:0.1.0"
spec:
documentationUrl: "https://github.com/fauna/airbyte/blob/source-fauna/docs/integrations/sources/fauna.md"
connectionSpecification:
Expand Down
2 changes: 1 addition & 1 deletion airbyte-integrations/connectors/source-fauna/Dockerfile
Original file line number Diff line number Diff line change
Expand Up @@ -34,5 +34,5 @@ COPY source_fauna ./source_fauna
ENV AIRBYTE_ENTRYPOINT "python /airbyte/integration_code/main.py"
ENTRYPOINT ["python", "/airbyte/integration_code/main.py"]

LABEL io.airbyte.version=dev
LABEL io.airbyte.version=0.1.0
LABEL io.airbyte.name=airbyte/source-fauna
Original file line number Diff line number Diff line change
Expand Up @@ -228,7 +228,7 @@ def run_removes_order_test(source: SourceFauna, logger, stream: ConfiguredAirbyt

def run_general_remove_test(source: SourceFauna, logger):
stream = ConfiguredAirbyteStream(
stream=AirbyteStream(name="deletions_test", json_schema={}),
stream=AirbyteStream(name="deletions_test", json_schema={}, supported_sync_modes=[SyncMode.incremental, SyncMode.full_refresh]),
sync_mode=SyncMode.incremental,
destination_sync_mode=DestinationSyncMode.append_dedup,
)
Expand Down Expand Up @@ -478,7 +478,7 @@ def run_updates_test(db_data, source: SourceFauna, logger, catalog: ConfiguredAi
def run_test(db_data, source: SourceFauna):
logger = mock_logger()
stream = ConfiguredAirbyteStream(
stream=AirbyteStream(name="foo", json_schema={}),
stream=AirbyteStream(name="foo", json_schema={}, supported_sync_modes=[SyncMode.incremental, SyncMode.full_refresh]),
sync_mode=SyncMode.incremental,
destination_sync_mode=DestinationSyncMode.append_dedup,
)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -115,6 +115,7 @@ def read_removes_hardcoded(
stream=AirbyteStream(
name="my_stream_name",
json_schema={},
supported_sync_modes=[SyncMode.incremental, SyncMode.full_refresh]
),
)
]
Expand Down Expand Up @@ -226,6 +227,7 @@ def read_removes_hardcoded(
stream=AirbyteStream(
name="my_stream_name",
json_schema={},
supported_sync_modes=[SyncMode.incremental, SyncMode.full_refresh]
),
)
]
Expand Down Expand Up @@ -683,6 +685,7 @@ def query_hardcoded(expr):
stream=AirbyteStream(
name="my_stream_name",
json_schema={},
supported_sync_modes=[SyncMode.incremental, SyncMode.full_refresh]
),
),
CollectionConfig(page_size=PAGE_SIZE),
Expand Down Expand Up @@ -719,6 +722,7 @@ def query_hardcoded(expr):
stream=AirbyteStream(
name="my_stream_name",
json_schema={},
supported_sync_modes=[SyncMode.incremental, SyncMode.full_refresh]
),
),
CollectionConfig(page_size=PAGE_SIZE),
Expand All @@ -741,6 +745,7 @@ def query_hardcoded(expr):
stream=AirbyteStream(
name="my_stream_name",
json_schema={},
supported_sync_modes=[SyncMode.incremental, SyncMode.full_refresh]
),
),
CollectionConfig(page_size=PAGE_SIZE),
Expand Down Expand Up @@ -854,6 +859,7 @@ def query_hardcoded(expr):
stream=AirbyteStream(
name="my_stream_name",
json_schema={},
supported_sync_modes=[SyncMode.incremental, SyncMode.full_refresh]
),
),
CollectionConfig(page_size=PAGE_SIZE),
Expand Down Expand Up @@ -885,6 +891,7 @@ def query_hardcoded(expr):
stream=AirbyteStream(
name="my_stream_name",
json_schema={},
supported_sync_modes=[SyncMode.incremental, SyncMode.full_refresh]
),
),
CollectionConfig(page_size=PAGE_SIZE),
Expand Down
2 changes: 1 addition & 1 deletion docs/integrations/sources/fauna.md
Original file line number Diff line number Diff line change
Expand Up @@ -224,4 +224,4 @@ FQL [`Select`](https://docs.fauna.com/fauna/current/api/fql/functions/select) is

| Version | Date | Pull Request | Subject |
| ------- | ---------- | -------------------------------------------------------- | ---------------- |
| 0.1.0 | 2022-08-03 | [15274](https://github.com/airbytehq/airbyte/pull/15274) | Add Fauna Source |
| 0.1.0 | 2022-11-17 | [15274](https://github.com/airbytehq/airbyte/pull/15274) | Add Fauna Source |

0 comments on commit 4f8545f

Please sign in to comment.