UMS-Agenten/Agenten-Plattform
3
0
Fork 0
Code Issues Actions Packages Releases Activity

Basic MGMT should work

Browse Source
This commit is contained in:
Magnus Bender 2024-10-29 18:09:27 +01:00
parent 98198f105b
commit 17d96cd069
Signed by: bender
GPG Key ID: 5149A211831F2BD7
1 changed files with 9 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
ums/management/process.py
View File

@ -80,11 +80,17 @@ class MessageProcessor():
# check which step/ state the message requires the management to do
if db_message.message.status.extract.required and not db_message.message.status.extract.finished:
self._do_extract(db_message.message)
# send to extract agents
self._send_messages(self.AGENTS_PROCESS, db_message.message)
elif db_message.message.status.solve.required and not db_message.message.status.solve.finished:
self._do_solve(db_message.message)
# send to solve agents
self._send_messages(self.AGENTS_SOLVE, db_message.message)
elif db_message.message.status.validate.required and not db_message.message.status.validate.finished:
self._do_validate(db_message.message)
# send to solve agents
self._send_messages(self.AGENTS_GATEKEEPER, db_message.message)
else: # all steps "done"
if db_message.message.status.solved:
# yay, message is solved
@ -99,18 +105,6 @@ class MessageProcessor():
# now message processed!
self.db.set_processed(count=count, processed=True)
def _do_extract(self, message:AgentMessage):
# TODO
pass
def _do_solve(self, message:AgentMessage):
# TODO
pass
def _do_validate(self, message:AgentMessage):
# TODO
pass
def _do_again(self, message:AgentMessage):
if message.status.trial < self.SOLUTION_MAX_TRIALS:
# try again, recycle message