@@ -63,14 +63,14 @@ func TestChainWorker(t *testing.T) {
6363 sch := New (pge , log .Init (config.LoggingOpts {LogLevel : "error" }))
6464 chains := make (chan Chain , 16 )
6565
66- t .Run ("Check chainWorker if context cancelled" , func (t * testing.T ) {
66+ t .Run ("Check chainWorker if context cancelled" , func (* testing.T ) {
6767 ctx , cancel := context .WithCancel (context .Background ())
6868 cancel ()
6969 chains <- Chain {}
7070 sch .chainWorker (ctx , chains )
7171 })
7272
73- t .Run ("Check chainWorker if everything fine" , func (t * testing.T ) {
73+ t .Run ("Check chainWorker if everything fine" , func (* testing.T ) {
7474 ctx , cancel := context .WithTimeout (context .Background (), 5 * time .Second )
7575 defer cancel ()
7676 mock .ExpectQuery ("SELECT count" ).WillReturnError (pgx .ErrNoRows )
@@ -82,7 +82,7 @@ func TestChainWorker(t *testing.T) {
8282 sch .chainWorker (ctx , chains )
8383 })
8484
85- t .Run ("Check chainWorker if cannot proceed with chain execution" , func (t * testing.T ) {
85+ t .Run ("Check chainWorker if cannot proceed with chain execution" , func (* testing.T ) {
8686 ctx , cancel := context .WithTimeout (context .Background (), pgengine .WaitTime + 2 )
8787 defer cancel ()
8888 mock .ExpectQuery ("SELECT count" ).WillReturnError (errors .New ("expected" ))
@@ -130,13 +130,13 @@ func TestExecuteOnErrorHandler(t *testing.T) {
130130 assert .NoError (t , mock .ExpectationsWereMet ())
131131 })
132132
133- t .Run ("check error handler if context cancelled" , func (t * testing.T ) {
133+ t .Run ("check error handler if context cancelled" , func (* testing.T ) {
134134 ctx , cancel := context .WithCancel (context .Background ())
135135 cancel ()
136136 sch .executeOnErrorHandler (ctx , c )
137137 })
138138
139- t .Run ("check error handler if error" , func (t * testing.T ) {
139+ t .Run ("check error handler if error" , func (* testing.T ) {
140140 mock .ExpectExec ("FOO" ).WillReturnError (errors .New ("Syntax error near FOO" ))
141141 sch .executeOnErrorHandler (context .Background (), c )
142142 })
0 commit comments