influx-version-check-before-close.patch - mgr - Ceph

Bug #40151 » influx-version-check-before-close.patch

Soenke Schippmann, 06/05/2019 08:37 AM

     import errno
     import six
     import time
     from distutils.version import StrictVersion
     from mgr_module import MgrModule
     try:
         import influxdb
         from influxdb import InfluxDBClient
         from influxdb.exceptions import InfluxDBClientError
         from requests.exceptions import RequestException
-...
                     start = time.time()
                     client = self.get_influx_client()
                     client.write_points(points, time_precision='ms')
                     client.close()
                     if StrictVersion(influxdb.__version__) >= StrictVersion("5.0.0"):
                         client.close()
                     runtime = time.time() - start
                     self.log.debug('Writing points %d to Influx took %.3f seconds',
                                    len(points), runtime)
-...
                                                    replication='1',
                                                    default=True,
                                                    database=self.config['database'])
                 client.close()
                 if StrictVersion(influxdb.__version__) >= StrictVersion("5.0.0"):
                     client.close()
                 self.log.debug('Gathering statistics')
                 points = self.gather_statistics()

(2-2/2)