Remove session leak
This commit is contained in:
parent
af6951f1f7
commit
8b2652e551
@ -132,6 +132,7 @@ class DispatchSyncer:
|
|||||||
s_check.link(s_send)
|
s_check.link(s_send)
|
||||||
t = s_check.apply_async()
|
t = s_check.apply_async()
|
||||||
logg.info('processed {}'.format(k))
|
logg.info('processed {}'.format(k))
|
||||||
|
session.close()
|
||||||
|
|
||||||
|
|
||||||
def loop(self, interval):
|
def loop(self, interval):
|
||||||
|
Loading…
Reference in New Issue
Block a user