diff --git a/clearing-parent/trade-importer/src/main/java/ru/spcex/clearing/trade/importer/services/TradeImporterService.java b/clearing-parent/trade-importer/src/main/java/ru/spcex/clearing/trade/importer/services/TradeImporterService.java
index 1141631b8..83182926c 100644
--- a/clearing-parent/trade-importer/src/main/java/ru/spcex/clearing/trade/importer/services/TradeImporterService.java
+++ b/clearing-parent/trade-importer/src/main/java/ru/spcex/clearing/trade/importer/services/TradeImporterService.java
@@ -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 {