From 2f900e3a5f7614c9c6d34fd64801028ab347884b Mon Sep 17 00:00:00 2001 From: Eric Davis Date: Sun, 1 Dec 2024 11:14:05 -0800 Subject: [PATCH] feat: execute pipe every 2.5k ops --- cmd/bsky-activity/main.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/cmd/bsky-activity/main.go b/cmd/bsky-activity/main.go index 6501cdd..26cf601 100644 --- a/cmd/bsky-activity/main.go +++ b/cmd/bsky-activity/main.go @@ -141,7 +141,7 @@ eventLoop: // add one to the count, every 500 ops execute the piepline eventCount += 1 - if eventCount%500 == 0 { + if eventCount%2500 == 0 { if _, err := pipe.Exec(ctx); err != nil { log.Printf("failed to exec pipe\n") } -- 2.51.2