Skip to content

Commit

Permalink
Remove.
Browse files Browse the repository at this point in the history
  • Loading branch information
Tang8330 committed Aug 20, 2024
1 parent ee7f6cb commit a5f3ae8
Showing 1 changed file with 0 additions and 2 deletions.
2 changes: 0 additions & 2 deletions processes/consumer/flush.go
Original file line number Diff line number Diff line change
Expand Up @@ -75,13 +75,11 @@ func Flush(ctx context.Context, inMemDB *models.DatabaseData, dest destination.B

_tableData.Lock()
defer _tableData.Unlock()

if _tableData.Empty() {
return
}

start := time.Now()

tags := map[string]string{
"what": "success",
"mode": _tableData.Mode().String(),
Expand Down

0 comments on commit a5f3ae8

Please sign in to comment.