fix(playout): quote incompatible <py3.9 type hints

This commit is contained in:
jo 2023-03-21 19:40:56 +01:00 committed by Kyle Robbertze
parent dde1af70b2
commit 74af2112a6
6 changed files with 13 additions and 13 deletions

View File

@ -113,13 +113,13 @@ def cli(
)
wait_for_liquidsoap(liq_client)
fetch_queue: Queue[Dict[str, Any]] = Queue()
push_queue: Queue[Events] = Queue()
fetch_queue: "Queue[Dict[str, Any]]" = Queue()
push_queue: "Queue[Events]" = Queue()
# This queue is shared between pypo-fetch and pypo-file, where pypo-file
# is the consumer. Pypo-fetch will send every schedule it gets to pypo-file
# and pypo will parse this schedule to determine which file has the highest
# priority, and retrieve it.
file_queue: Queue[FileEvents] = Queue()
file_queue: "Queue[FileEvents]" = Queue()
pypo_liquidsoap = PypoLiquidsoap(liq_client)

View File

@ -20,7 +20,7 @@ class MessageHandler(ConsumerMixin):
def __init__(
self,
connection: Connection,
fetch_queue: ThreadQueue[Dict[str, Any]],
fetch_queue: "ThreadQueue[Dict[str, Any]]",
):
self.connection = connection
@ -71,7 +71,7 @@ class MessageListener:
def __init__(
self,
config: Config,
fetch_queue: ThreadQueue[Dict[str, Any]],
fetch_queue: "ThreadQueue[Dict[str, Any]]",
) -> None:
self.config = config
self.fetch_queue = fetch_queue

View File

@ -43,9 +43,9 @@ class PypoFetch(Thread):
# pylint: disable=too-many-arguments
def __init__(
self,
fetch_queue: Queue[Dict[str, Any]],
push_queue: Queue[Events],
file_queue: Queue[FileEvents],
fetch_queue: "Queue[Dict[str, Any]]",
push_queue: "Queue[Events]",
file_queue: "Queue[FileEvents]",
liq_client: LiquidsoapClient,
pypo_liquidsoap: PypoLiquidsoap,
config: Config,

View File

@ -19,12 +19,12 @@ class PypoFile(Thread):
name = "file"
daemon = True
file_events_queue: Queue[FileEvents]
file_events_queue: "Queue[FileEvents]"
file_events: FileEvents
def __init__(
self,
file_queue: Queue[FileEvents],
file_queue: "Queue[FileEvents]",
api_client: ApiClient,
):
Thread.__init__(self)

View File

@ -28,7 +28,7 @@ class PypoPush(Thread):
def __init__(
self,
push_queue: Queue[Events],
push_queue: "Queue[Events]",
pypo_liquidsoap: PypoLiquidsoap,
config: Config,
):
@ -37,7 +37,7 @@ class PypoPush(Thread):
self.config = config
self.future_scheduled_queue: Queue[Events] = Queue()
self.future_scheduled_queue: "Queue[Events]" = Queue()
self.pypo_liquidsoap = pypo_liquidsoap
self.plq = PypoLiqQueue(self.future_scheduled_queue, self.pypo_liquidsoap)

View File

@ -18,7 +18,7 @@ class PypoLiqQueue(Thread):
def __init__(
self,
future_queue: Queue[Dict[str, Any]],
future_queue: "Queue[Dict[str, Any]]",
pypo_liquidsoap: PypoLiquidsoap,
):
Thread.__init__(self)