Skip to content

Commit

Permalink
Update run_observer to match mq connector default (#19)
Browse files Browse the repository at this point in the history
Update `run_sync` to `False` to match current LLM implementations
  • Loading branch information
NeonDaniel authored Feb 11, 2025
1 parent d78bd10 commit bd44ebe
Showing 1 changed file with 4 additions and 6 deletions.
10 changes: 4 additions & 6 deletions neon_llm_core/rmq.py
Original file line number Diff line number Diff line change
Expand Up @@ -279,12 +279,10 @@ def compose_opinion_prompt(respondent_nick: str, question: str,
"""
pass

def run(self, run_consumers: bool = True, run_sync: bool = True,
run_observer: bool = True, **kwargs):
super().run(run_consumers=run_consumers,
run_sync=run_sync,
run_observer=run_observer,
**kwargs)
def run(self, run_consumers: bool = True, run_sync: bool = False,
run_observer: Optional[bool] = None, **kwargs):
MQConnector.run(self, run_consumers=run_consumers, run_sync=run_sync,
run_observer=run_observer, **kwargs)
if not self.started:
raise RuntimeError(f'Failed to connect to MQ. config={self.config}')
self._personas_provider.start_sync()
Expand Down

0 comments on commit bd44ebe

Please sign in to comment.