mirror of
https://github.com/sprockets/sprockets-influxdb.git
synced 2024-11-15 03:00:24 +00:00
Replace deprecated TracebackFuture with Furture
TracebackFuture has been deprecated and aliased to Future since Tornado 4.0
8e07f3d865
This commit is contained in:
parent
e692468d9c
commit
09a203df47
1 changed files with 2 additions and 2 deletions
|
@ -222,7 +222,7 @@ def flush():
|
||||||
:rtype: :class:`~tornado.concurrent.Future`
|
:rtype: :class:`~tornado.concurrent.Future`
|
||||||
|
|
||||||
"""
|
"""
|
||||||
flush_future = concurrent.TracebackFuture()
|
flush_future = concurrent.Future()
|
||||||
if _batch_future and not _batch_future.done():
|
if _batch_future and not _batch_future.done():
|
||||||
LOGGER.debug('Flush waiting on incomplete _batch_future')
|
LOGGER.debug('Flush waiting on incomplete _batch_future')
|
||||||
_flush_wait(flush_future, _batch_future)
|
_flush_wait(flush_future, _batch_future)
|
||||||
|
@ -696,7 +696,7 @@ def _write_measurements():
|
||||||
"""
|
"""
|
||||||
global _timeout, _writing
|
global _timeout, _writing
|
||||||
|
|
||||||
future = concurrent.TracebackFuture()
|
future = concurrent.Future()
|
||||||
|
|
||||||
if _writing:
|
if _writing:
|
||||||
LOGGER.warning('Currently writing measurements, skipping write')
|
LOGGER.warning('Currently writing measurements, skipping write')
|
||||||
|
|
Loading…
Reference in a new issue