Removed status check as db query performs it

This commit is contained in:
bskjon 2025-02-22 18:01:17 +01:00
parent eb6be405ef
commit d9d20a76c2

View File

@ -176,12 +176,6 @@ class EventsPullerThread(threading.Thread):
if (row is not None): if (row is not None):
try: try:
referenceId = row["referenceId"] referenceId = row["referenceId"]
status = row["status"]
if (status == "Failed" or status == "Skipped"):
logger.info(f"Skipping failed event referenceId: {referenceId}, eventId: {row['eventId']}")
continue
incomingEventType = row["event"] incomingEventType = row["event"]
logMessage = f""" logMessage = f"""
============================================================================ ============================================================================