Skip to content

Commit

Permalink
fix: remove restriction on sending stats messages to the remote in DA…
Browse files Browse the repository at this point in the history
…QJobRemote
  • Loading branch information
furkan-bilgin committed Dec 4, 2024
1 parent d49a702 commit b26cb36
Showing 1 changed file with 1 addition and 4 deletions.
5 changes: 1 addition & 4 deletions src/enrgdaq/daq/jobs/remote.py
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,6 @@
import zmq

from enrgdaq.daq.base import DAQJob
from enrgdaq.daq.jobs.handle_stats import DAQJobMessageStats
from enrgdaq.daq.models import (
DEFAULT_REMOTE_TOPIC,
DAQJobConfig,
Expand Down Expand Up @@ -87,10 +86,8 @@ def __init__(self, config: DAQJobRemoteConfig, **kwargs):

def handle_message(self, message: DAQJobMessage) -> bool:
if (
# Do not send stats messages to the remote
isinstance(message, DAQJobMessageStats)
# Ignore if we already received the message
or message.id in self._remote_message_ids
message.id in self._remote_message_ids
# Ignore if the message is not allowed by the DAQ Job
or not super().handle_message(message)
# Ignore if the message is remote, meaning it was sent by another Supervisor
Expand Down

0 comments on commit b26cb36

Please sign in to comment.