From 6ef077217c767450b97202c01cba4e31750d9937 Mon Sep 17 00:00:00 2001 From: caterryan Date: Tue, 14 Jul 2026 09:41:59 -0500 Subject: [PATCH] fix(plugin-utils): preserve empty database --- .../src/influxdata_plugin_utils/write.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/influxdata-plugin-utils/src/influxdata_plugin_utils/write.py b/influxdata-plugin-utils/src/influxdata_plugin_utils/write.py index cca62ab..fd42b31 100644 --- a/influxdata-plugin-utils/src/influxdata_plugin_utils/write.py +++ b/influxdata-plugin-utils/src/influxdata_plugin_utils/write.py @@ -192,11 +192,11 @@ def write_data( attempts = max(retries, 0) + 1 if no_sync is None: - if database: + if database is not None: write_fn = partial(influxdb3_local.write_to_db, database) else: write_fn = influxdb3_local.write - elif database: + elif database is not None: write_fn = partial(influxdb3_local.write_sync_to_db, database, no_sync=no_sync) else: write_fn = partial(influxdb3_local.write_sync, no_sync=no_sync) @@ -210,4 +210,4 @@ def write_data( if attempt == attempts - 1: raise delay = (2**attempt) * base_delay + random.uniform(0, base_delay) - time.sleep(delay) \ No newline at end of file + time.sleep(delay)