From 098986eb07edba215dd8d0398f66d7613d0397f6 Mon Sep 17 00:00:00 2001 From: Bel LaPointe <153096461+breel-render@users.noreply.github.com> Date: Tue, 16 Apr 2024 07:36:12 -0600 Subject: [PATCH] nil ptr in main test on pipeline spinup race --- README.md | 3 --- main_test.go | 3 +++ 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/README.md b/README.md index 2214509..33a2fb6 100644 --- a/README.md +++ b/README.md @@ -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 diff --git a/main_test.go b/main_test.go index 779c74e..1f19a47 100644 --- a/main_test.go +++ b/main_test.go @@ -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 {