diff --git a/pkg/service/sync.go b/pkg/service/sync.go index e7f005daf..760c32e61 100644 --- a/pkg/service/sync.go +++ b/pkg/service/sync.go @@ -78,7 +78,9 @@ func (s *SyncService) SyncTrades(ctx context.Context, exchange types.Exchange, s return ctx.Err() case err := <-errC: - return err + if err != nil { + return err + } default: }