File tree Expand file tree Collapse file tree 2 files changed +4
-5
lines changed
rolling-shutter/keyperimpl/gnosis Expand file tree Collapse file tree 2 files changed +4
-5
lines changed Original file line number Diff line number Diff line change @@ -2,9 +2,9 @@ package gnosis
2
2
3
3
import (
4
4
"context"
5
- "github.com/jackc/pgx/v4"
6
5
"time"
7
6
7
+ "github.com/jackc/pgx/v4"
8
8
"github.com/jackc/pgx/v4/pgxpool"
9
9
"github.com/pkg/errors"
10
10
"github.com/rs/zerolog/log"
@@ -36,7 +36,6 @@ func (s *SyncMonitor) runMonitor(ctx context.Context) error {
36
36
select {
37
37
case <- time .After (s .CheckInterval ):
38
38
record , err := db .GetTransactionSubmittedEventsSyncedUntil (ctx )
39
-
40
39
if err != nil {
41
40
if errors .Is (err , pgx .ErrNoRows ) {
42
41
log .Warn ().Err (err ).Msg ("no rows found in table transaction_submitted_events_synced_until" )
@@ -62,4 +61,4 @@ func (s *SyncMonitor) runMonitor(ctx context.Context) error {
62
61
return ctx .Err ()
63
62
}
64
63
}
65
- }
64
+ }
Original file line number Diff line number Diff line change @@ -2,13 +2,13 @@ package gnosis_test
2
2
3
3
import (
4
4
"context"
5
- "github.com/shutter-network/rolling-shutter/rolling-shutter/keyperimpl/gnosis/database"
6
5
"testing"
7
6
"time"
8
7
9
8
"gotest.tools/assert"
10
9
11
10
"github.com/shutter-network/rolling-shutter/rolling-shutter/keyperimpl/gnosis"
11
+ "github.com/shutter-network/rolling-shutter/rolling-shutter/keyperimpl/gnosis/database"
12
12
"github.com/shutter-network/rolling-shutter/rolling-shutter/medley/service"
13
13
"github.com/shutter-network/rolling-shutter/rolling-shutter/medley/testsetup"
14
14
)
@@ -143,4 +143,4 @@ func TestSyncMonitor_ContinuesWhenNoRows(t *testing.T) {
143
143
t .Fatalf ("expected monitor to continue without error, but got: %v" , err )
144
144
case <- time .After (1 * time .Second ):
145
145
}
146
- }
146
+ }
You can’t perform that action at this time.
0 commit comments