This commit is contained in:
AKurakin 2024-08-06 17:12:54 +03:00
parent 517d67fed3
commit 8076bc22da

View file

@ -112,7 +112,7 @@ public class TradeImporterService {
log.debug("From DB {} STrades has loaded. Created {} new STrades, {} updated.",
rows.get(), created.get(), updated.get());
if (created.get() > 0 || updated.get() > 0) {
if (created.get() > 0 || (byCommand && updated.get() > 0)) {
if (byCommand) {
log.debug("Successfully import STrades from DB by command. Send to kafka command, topic={}", S_TRADES_IMPORTED);
} else {