refactor: bec_dispatcher.py changed to Ivan's version

This commit is contained in:
wyzula-jan
2023-10-17 10:45:06 +02:00
parent 144e56cdd9
commit 6d6b1e9155
+6 -9
View File
@@ -1,7 +1,6 @@
import argparse import argparse
import itertools import itertools
import os import os
from dataclasses import dataclass
from typing import Callable from typing import Callable
from bec_lib import BECClient from bec_lib import BECClient
@@ -16,17 +15,15 @@ _signal_class_factory = (
) )
@dataclass
class _Connection: class _Connection:
"""Utility class to keep track of slots connected to a particular redis consumer""" """Utility class to keep track of slots connected to a particular redis consumer"""
consumer: RedisConsumerThreaded def __init__(self, consumer) -> None:
slots = set() self.consumer: RedisConsumerThreaded = consumer
# keep a reference to a new signal class, so it is not gc'ed self.slots = set()
_signal_container = next(_signal_class_factory)() # keep a reference to a new signal class, so it is not gc'ed
self._signal_container = next(_signal_class_factory)()
def __post_init__(self): self.signal: pyqtSignal = self._signal_container.signal
self.signal = self._signal_container.signal
class _BECDispatcher(QObject): class _BECDispatcher(QObject):