projects
/
arvados.git
/ blobdiff
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Pin the api server and workbench to the Arvados 2.1.3 gem.
[arvados.git]
/
services
/
ws
/
event_source_test.go
diff --git
a/services/ws/event_source_test.go
b/services/ws/event_source_test.go
index ac5d130d61bdd85dfc568bf91c37b983994ae40c..b7b8ac3006f3fa6af19de31737af82129dbf8642 100644
(file)
--- a/
services/ws/event_source_test.go
+++ b/
services/ws/event_source_test.go
@@
-2,17
+2,17
@@
//
// SPDX-License-Identifier: AGPL-3.0
//
// SPDX-License-Identifier: AGPL-3.0
-package
main
+package
ws
import (
"database/sql"
"fmt"
import (
"database/sql"
"fmt"
- "os"
- "path/filepath"
"sync"
"time"
"sync"
"time"
- "git.curoverse.com/arvados.git/sdk/go/arvados"
+ "git.arvados.org/arvados.git/sdk/go/arvados"
+ "git.arvados.org/arvados.git/sdk/go/ctxlog"
+ "github.com/prometheus/client_golang/prometheus"
check "gopkg.in/check.v1"
)
check "gopkg.in/check.v1"
)
@@
-21,7
+21,7
@@
var _ = check.Suite(&eventSourceSuite{})
type eventSourceSuite struct{}
func testDBConfig() arvados.PostgreSQLConnection {
type eventSourceSuite struct{}
func testDBConfig() arvados.PostgreSQLConnection {
- cfg, err := arvados.GetConfig(
filepath.Join(os.Getenv("WORKSPACE"), "tmp", "arvados.yml")
)
+ cfg, err := arvados.GetConfig(
arvados.DefaultConfigFile
)
if err != nil {
panic(err)
}
if err != nil {
panic(err)
}
@@
-46,6
+46,8
@@
func (*eventSourceSuite) TestEventSource(c *check.C) {
pges := &pgEventSource{
DataSource: cfg.String(),
QueueSize: 4,
pges := &pgEventSource{
DataSource: cfg.String(),
QueueSize: 4,
+ Logger: ctxlog.TestLogger(c),
+ Reg: prometheus.NewRegistry(),
}
go pges.Run()
sinks := make([]eventSink, 18)
}
go pges.Run()
sinks := make([]eventSink, 18)