added query_api and write_api to the bucket(db) code in backends/infl…

…uxdb2/client.py
AbhigyaShridhar · Apr 13, 2022 · 70289c2 · 70289c2
1 parent d88fe65
commit 70289c2
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/openwisp_monitoring/db/backends/influxdb2/client.py b/openwisp_monitoring/db/backends/influxdb2/client.py
@@ -48,6 +48,8 @@ def create_database(self):
             logger.debug(f'Created InfluxDB2 bucket "{self.db_name}"')
         else:
             logger.debug(f'Bucket named "{self.db_name}" found')
+        self.write_api = self.db.write_api(write_options=SYNCHRONOUS)
+        self.query_api = self.db.query_api()
 
     @retry
     def drop_database(self):