projects
/
osm
/
RO.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Disable the check of the release notes
[osm/RO.git]
/
NG-RO
/
osm_ng_ro
/
vim_admin.py
diff --git
a/NG-RO/osm_ng_ro/vim_admin.py
b/NG-RO/osm_ng_ro/vim_admin.py
index
21e6281
..
e34cce4
100644
(file)
--- a/
NG-RO/osm_ng_ro/vim_admin.py
+++ b/
NG-RO/osm_ng_ro/vim_admin.py
@@
-380,7
+380,7
@@
class VimAdminThread(threading.Thread):
self.logger.info("Starting")
while not self.to_terminate:
try:
self.logger.info("Starting")
while not self.to_terminate:
try:
- asyncio.run
_coroutine_threadsafe(self.main_task(), self.loop
)
+ asyncio.run
(self.main_task()
)
except Exception as e:
if not self.to_terminate:
self.logger.exception(
except Exception as e:
if not self.to_terminate:
self.logger.exception(
@@
-458,12
+458,12
@@
class VimAdminThread(threading.Thread):
self.lock_renew.to_terminate = True
if self.aiomain_task_kafka:
self.lock_renew.to_terminate = True
if self.aiomain_task_kafka:
- self.
aiomain_task_kafka.cancel(
)
+ self.
loop.call_soon_threadsafe(self.aiomain_task_kafka.cancel()
)
if self.aiomain_task_vim:
if self.aiomain_task_vim:
- self.
aiomain_task_vim.cancel(
)
+ self.
loop.call_soon_threadsafe(self.aiomain_task_vim.cancel()
)
if self.aiomain_task_renew_lock:
if self.aiomain_task_renew_lock:
- self.
aiomain_task_renew_lock.cancel(
)
+ self.
loop.call_soon_threadsafe(self.aiomain_task_renew_lock.cancel()
)
self.lock_renew.stop()
self.lock_renew.stop()