Merge pull request #116 from johnseekins/bucket-fix

InfluxDB bucket fix

openstates/utils/instrument.py

@@ -42,6 +42,7 @@ def __init__(self) -> None:
         self._batch: List[Dict] = list()
         self.prefix: str = os.environ.get("STATS_PREFIX", "openstates_")
         self.endpoint: str = os.environ.get("STATS_ENDPOINT", "")
+        self.bucket: str = os.environ.get("STATS_BUCKET", "openstates")
         if self.endpoint.endswith("/"):
             self.endpoint = self.endpoint.strip("/")
         client = InfluxDBClient(
@@ -88,7 +89,7 @@ def _send_stats(self, force: bool = False) -> None:
                 points.append(p)
             self.logger.debug(f"Sending stats batch: {self._batch}")
             try:
-                self.write_api.write("", record=points)
+                self.write_api.write(self.bucket, record=points)
                 self._batch = list()
             except Exception as e:
                 self.logger.warning(

pyproject.toml

@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "openstates"
-version = "6.17.6"
+version = "6.17.7"
 description = "core infrastructure for the openstates project"
 authors = ["James Turk <[email protected]>"]
 license = "MIT"