diff --git a/backend/fluksio/flow/nodes/influx.py b/backend/fluksio/flow/nodes/influx.py index 08cb4b8..bf28b40 100644 --- a/backend/fluksio/flow/nodes/influx.py +++ b/backend/fluksio/flow/nodes/influx.py @@ -174,8 +174,6 @@ class InfluxDbNode(Node): "timeout", "writes", "queries", - "_write_client", - "_query_client", ) class Params(BaseModel): @@ -231,10 +229,6 @@ class InfluxDbNode(Node): self.writes = cfg.writes self.queries = cfg.queries - # Lazy-initialized clients - self._write_client = None - self._query_client = None - # Set default name if name is None: name = f"influxdb_{self.bucket}"