Search headless (#8)

* Fix

* Final fix to headless

* test

* Fix

* Ready for deployment
This commit is contained in:
2024-04-24 17:31:52 +02:00
committed by GitHub
parent 9d00e40b41
commit 430b4de995
3 changed files with 13 additions and 11 deletions
+8 -7
View File
@@ -102,18 +102,19 @@ def scan_incoming(_logger):
try:
answer = incoming_q.get(block=False)
_logger.info("DATA FOUND")
record_stored = False
for record in awaiting_q:
if record.uuid in answer.keys():
record_stored = True
record.stop = True
record.entries = answer[record.uuid]
IN_COMM_Q.put(record)
if not record_stored:
for key in answer.keys():
record = QueryControl("Orphaned", key, "Orphan", _logger, None)
record.stop = True
record.entries = answer[record.uuid]
IN_COMM_Q.put(record)
else:
for key in answer.keys():
record = QueryControl("Orphaned", key, "Orphan", _logger, None)
record.stop = True
record.entries = answer[record.uuid]
record.uuid = "000000"
IN_COMM_Q.put(record)
except Empty:
time.sleep(1)