Skip to content

Commit

Permalink
Move ReadMode
Browse files Browse the repository at this point in the history
  • Loading branch information
edgarrmondragon committed Sep 26, 2024
1 parent cbf69c9 commit 9fd33fe
Show file tree
Hide file tree
Showing 2 changed files with 10 additions and 9 deletions.
8 changes: 0 additions & 8 deletions singer_sdk/contrib/filesystem/stream.py
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,6 @@
from __future__ import annotations

import abc
import enum
import functools
import typing as t

Expand All @@ -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."""

Expand Down
11 changes: 10 additions & 1 deletion singer_sdk/contrib/filesystem/tap.py
Original file line number Diff line number Diff line change
Expand Up @@ -2,6 +2,7 @@

from __future__ import annotations

import enum
import functools
import os
import typing as t
Expand All @@ -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",
Expand Down

0 comments on commit 9fd33fe

Please sign in to comment.