Merge pull request #95 from OpenSTEF/fix-batch-write-errors

Fix batch write errors
OpenSTEF · Mar 30, 2023 · f84bfef · f84bfef
2 parents 7ee62d8 + b4c5054
commit f84bfef
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/openstef_dbc/data_interface.py b/openstef_dbc/data_interface.py
@@ -4,6 +4,7 @@
 
 import geopy
 from influxdb_client import InfluxDBClient
+from influxdb_client.client.write_api import SYNCHRONOUS
 import pandas as pd
 import requests
 import sqlalchemy
@@ -61,7 +62,7 @@ def __init__(self, config):
         )
 
         self.influx_query_api = self.influx_client.query_api()
-        self.influx_write_api = self.influx_client.write_api()
+        self.influx_write_api = self.influx_client.write_api(write_options=SYNCHRONOUS)
 
         self.mysql_engine = self._create_mysql_engine(
             username=config.mysql_username,

diff --git a/setup.py b/setup.py
@@ -29,7 +29,7 @@ def read_long_description_from_readme():
 
 setup(
     name="openstef_dbc",
-    version="3.6.0",
+    version="3.6.1",
     packages=find_packages(include=["openstef_dbc", "openstef_dbc.*"]),
     description="Database Connection for OpenSTEF",
     long_description=read_long_description_from_readme(),