add an config toggle for external connectors

This commit is contained in:
Mikhail Epifanov
2024-01-12 22:20:55 +01:00
parent d576394c99
commit 445e64c71e
6 changed files with 38 additions and 19 deletions

View File

@ -1,6 +1,7 @@
import asyncio
import logging
import multiprocessing
import queue
from asyncio import Task
from dataclasses import dataclass
from enum import Enum
@ -55,7 +56,10 @@ class ConnectorManager:
else:
return
self._queue.put_nowait(Payload(instance, action_type))
try:
self._queue.put_nowait(Payload(instance, action_type))
except queue.Full:
return
def stop(self):
self._queue.close()