We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
SnowflakeSink
1 parent b68beb3 commit a7b8699Copy full SHA for a7b8699
target_snowflake/sinks.py
@@ -21,7 +21,7 @@
21
from target_snowflake.connector import SnowflakeConnector
22
23
if t.TYPE_CHECKING:
24
- from singer_sdk import PluginBase, SQLConnector
+ from singer_sdk import PluginBase
25
26
DEFAULT_BATCH_CONFIG = {
27
"encoding": {"format": "jsonl", "compression": "gzip"},
@@ -40,7 +40,7 @@ def __init__(
40
stream_name: str,
41
schema: dict,
42
key_properties: list[str] | None,
43
- connector: SQLConnector | None = None,
+ connector: SnowflakeConnector | None = None,
44
) -> None:
45
"""Initialize Snowflake Sink."""
46
self.target = target
0 commit comments