diff --git a/singer_sdk/contrib/filesystem/stream.py b/singer_sdk/contrib/filesystem/stream.py index 1d8920472..a1b71da16 100644 --- a/singer_sdk/contrib/filesystem/stream.py +++ b/singer_sdk/contrib/filesystem/stream.py @@ -3,7 +3,6 @@ from __future__ import annotations import abc -import enum import functools import typing as t @@ -24,13 +23,6 @@ SDC_META_MODIFIED_AT = "_sdc_modified_at" -class ReadMode(str, enum.Enum): - """Sync mode for the tap.""" - - one_stream_per_file = "one_stream_per_file" - merge = "merge" - - class FileStream(Stream, metaclass=abc.ABCMeta): """Abstract base class for file streams.""" diff --git a/singer_sdk/contrib/filesystem/tap.py b/singer_sdk/contrib/filesystem/tap.py index 19d14c211..b028faa3f 100644 --- a/singer_sdk/contrib/filesystem/tap.py +++ b/singer_sdk/contrib/filesystem/tap.py @@ -2,6 +2,7 @@ from __future__ import annotations +import enum import functools import os import typing as t @@ -11,10 +12,18 @@ import singer_sdk.typing as th from singer_sdk import Tap -from singer_sdk.contrib.filesystem.stream import FileStream, ReadMode +from singer_sdk.contrib.filesystem.stream import FileStream DEFAULT_MERGE_STREAM_NAME = "files" + +class ReadMode(str, enum.Enum): + """Sync mode for the tap.""" + + one_stream_per_file = "one_stream_per_file" + merge = "merge" + + BASE_CONFIG_SCHEMA = th.PropertiesList( th.Property( "filesystem",