|
|
@ -129,7 +129,7 @@ def cleanup(subclass, references):
|
|
|
|
for tx, reference in get_ref_map().items():
|
|
|
|
for tx, reference in get_ref_map().items():
|
|
|
|
if reference not in references:
|
|
|
|
if reference not in references:
|
|
|
|
if get_subclass(reference) == subclass:
|
|
|
|
if get_subclass(reference) == subclass:
|
|
|
|
logmessage = f"{reference}: Archiving trade reference. TX: {tx}"
|
|
|
|
logmessage = f"[{reference}] ({subclass}): Archiving trade reference. TX: {tx}"
|
|
|
|
messages.append(logmessage)
|
|
|
|
messages.append(logmessage)
|
|
|
|
log.info(logmessage)
|
|
|
|
log.info(logmessage)
|
|
|
|
r.rename(f"trade.{tx}.reference", f"archive.trade.{tx}.reference")
|
|
|
|
r.rename(f"trade.{tx}.reference", f"archive.trade.{tx}.reference")
|
|
|
|