From 3db1d3626ae1149607ba9afd4a14bd5ccb435c2a Mon Sep 17 00:00:00 2001 From: Ilia Shabanov Date: Tue, 8 Jul 2025 00:11:50 +0400 Subject: [PATCH] fix: worker initialization --- cmd/watcher/main.go | 12 ++---------- docker-compose.yml | 2 ++ 2 files changed, 4 insertions(+), 10 deletions(-) diff --git a/cmd/watcher/main.go b/cmd/watcher/main.go index 2ec0cb1..994dfc8 100644 --- a/cmd/watcher/main.go +++ b/cmd/watcher/main.go @@ -147,16 +147,8 @@ func main() { //nolint:funlen blockTicker.Run, mempoolTicker.Run, // - func(ctx context.Context) error { - defer close(txIDChan) - - return txIDWorker.Run(ctx) - }, - func(ctx context.Context) error { - defer close(blockChan) - - return blockTransactionWorker.Run(ctx) - }, + txIDWorker.Run, + blockTransactionWorker.Run, ) } diff --git a/docker-compose.yml b/docker-compose.yml index 7c442d6..25b84ad 100644 --- a/docker-compose.yml +++ b/docker-compose.yml @@ -2,6 +2,8 @@ x-app-env: &app-env GOMAXPROCS: 1 WATCHER_APP_LOG_LEVEL: debug + WATCHER_METRICS_PORT: 9090 + WATCHER_DB_HOST: postgres WATCHER_DB_PORT: 5432 WATCHER_DB_USER: watcher_db_user