From 1a549d74f550198f83f12022249b1cee32231da2 Mon Sep 17 00:00:00 2001 From: Daniil Gusev Date: Wed, 2 Oct 2024 12:24:15 +0200 Subject: [PATCH 1/2] Remove InfluxDB3Sink import from core --- quixstreams/sinks/__init__.py | 2 -- 1 file changed, 2 deletions(-) diff --git a/quixstreams/sinks/__init__.py b/quixstreams/sinks/__init__.py index cf7a2000c..4f0eb1e37 100644 --- a/quixstreams/sinks/__init__.py +++ b/quixstreams/sinks/__init__.py @@ -1,6 +1,5 @@ from .base import BatchingSink, SinkBatch, BaseSink, SinkBackpressureError, SinkManager from .core.csv import CSVSink -from .core.influxdb3 import InfluxDB3Sink __all__ = [ "BaseSink", @@ -9,5 +8,4 @@ "SinkBatch", "SinkManager", "CSVSink", - "InfluxDB3Sink", ] From d95a3f2c27deea9ba6383dc1ea8b50343f019ffe Mon Sep 17 00:00:00 2001 From: Daniil Gusev Date: Wed, 2 Oct 2024 12:39:09 +0200 Subject: [PATCH 2/2] Remove CSVSink too for consistency --- quixstreams/sinks/__init__.py | 2 -- 1 file changed, 2 deletions(-) diff --git a/quixstreams/sinks/__init__.py b/quixstreams/sinks/__init__.py index 4f0eb1e37..3a7c46ed5 100644 --- a/quixstreams/sinks/__init__.py +++ b/quixstreams/sinks/__init__.py @@ -1,5 +1,4 @@ from .base import BatchingSink, SinkBatch, BaseSink, SinkBackpressureError, SinkManager -from .core.csv import CSVSink __all__ = [ "BaseSink", @@ -7,5 +6,4 @@ "SinkBackpressureError", "SinkBatch", "SinkManager", - "CSVSink", ]