refactor: allow sending store messages in DAQJobRemote

ENRG-tr · Nov 1, 2024 · 66c349f · 66c349f
1 parent 60ac04b
commit 66c349f
Showing 1 changed file with 0 additions and 4 deletions.
diff --git a/src/daq/jobs/remote.py b/src/daq/jobs/remote.py
@@ -9,7 +9,6 @@
 from daq.base import DAQJob
 from daq.jobs.handle_stats import DAQJobMessageStats
 from daq.models import DAQJobConfig, DAQJobMessage
-from daq.store.models import DAQJobMessageStore
 
 DAQ_JOB_REMOTE_MAX_REMOTE_MESSAGE_ID_COUNT = 10000
 
@@ -69,9 +68,6 @@ def __init__(self, config: DAQJobRemoteConfig):
     def handle_message(self, message: DAQJobMessage) -> bool:
         if (
             isinstance(message, DAQJobMessageStats)
-            or isinstance(
-                message, DAQJobMessageStore
-            )  # TODO: we should be able to send store messages
             or message.id in self._remote_message_ids
             or not super().handle_message(message)
         ):