Skip to content

Commit ef7be65

Browse files
authored
do not create sender at close (#208)
1 parent 1e58a7e commit ef7be65

File tree

2 files changed

+3
-17
lines changed

2 files changed

+3
-17
lines changed

fluent/asynchandler.py

-16
Original file line numberDiff line numberDiff line change
@@ -8,19 +8,3 @@ class FluentHandler(handler.FluentHandler):
88

99
def getSenderClass(self):
1010
return asyncsender.FluentSender
11-
12-
def close(self):
13-
self.acquire()
14-
try:
15-
try:
16-
self.sender.close()
17-
finally:
18-
super().close()
19-
finally:
20-
self.release()
21-
22-
def __enter__(self):
23-
return self
24-
25-
def __exit__(self, exc_type, exc_val, exc_tb):
26-
self.close()

fluent/handler.py

+3-1
Original file line numberDiff line numberDiff line change
@@ -264,7 +264,9 @@ def close(self):
264264
self.acquire()
265265
try:
266266
try:
267-
self.sender.close()
267+
if self._sender is not None:
268+
self._sender.close()
269+
self._sender = None
268270
finally:
269271
super().close()
270272
finally:

0 commit comments

Comments
 (0)