From 1e8c7e2689d99926f79a6698d1490f17b619b070 Mon Sep 17 00:00:00 2001 From: wunder957 Date: Tue, 29 Aug 2023 14:44:07 +0800 Subject: [PATCH] Drop cancel_futures=True --- duetector/collectors/base.py | 2 +- duetector/monitors/base.py | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/duetector/collectors/base.py b/duetector/collectors/base.py index 9bae17f..a7ec5e8 100644 --- a/duetector/collectors/base.py +++ b/duetector/collectors/base.py @@ -57,7 +57,7 @@ def summary(self) -> Dict: raise NotImplementedError def shutdown(self): - self._backend.shutdown(cancel_futures=True) + self._backend.shutdown() class DequeCollector(Collector): diff --git a/duetector/monitors/base.py b/duetector/monitors/base.py index 767504b..a62489c 100644 --- a/duetector/monitors/base.py +++ b/duetector/monitors/base.py @@ -64,6 +64,6 @@ def start_polling(self): def shutdown(self): self.poller.shutdown() self.poller.wait() - self._backend.shutdown(cancel_futures=True) + self._backend.shutdown() for c in self.collectors: c.shutdown()