nil ptr in main test on pipeline spinup race
parent
5bc068451f
commit
098986eb07
|
|
@ -4,10 +4,7 @@ Thank you, [Sean](https://www.linkedin.com/in/sean-moore-1755a619/)
|
|||
|
||||
## TODO
|
||||
|
||||
- to class design for joins and external tables
|
||||
- dedupe multi channels
|
||||
- add Team to Message
|
||||
- from sync ingest to ingestQueue that retries a few times so user messages can find parent
|
||||
- limit queue retries
|
||||
- share postgres with Grafana
|
||||
- new dash in Grafana
|
||||
|
|
|
|||
|
|
@ -45,8 +45,11 @@ func TestRun(t *testing.T) {
|
|||
cfg.EventNamePattern = renderEventNamePattern
|
||||
cfg.Port = port
|
||||
cfg.driver = NewTestDriver(t)
|
||||
cfg.storage, _ = NewStorage(ctx, cfg.driver)
|
||||
cfg.SlackToken = "redacted"
|
||||
cfg.SlackChannels = []string{"C06U1DDBBU4"}
|
||||
cfg.slackToModelPipeline, _ = NewSlackToModelPipeline(ctx, cfg)
|
||||
cfg.modelToPersistencePipeline, _ = NewModelToPersistencePipeline(ctx, cfg)
|
||||
|
||||
go func() {
|
||||
if err := run(ctx, cfg); err != nil && ctx.Err() == nil {
|
||||
|
|
|
|||
Loading…
Reference in New Issue