diff --git a/cmd/caplin-phase1/caplin1/run.go b/cmd/caplin-phase1/caplin1/run.go index 6585a6a93..b7a877de3 100644 --- a/cmd/caplin-phase1/caplin1/run.go +++ b/cmd/caplin-phase1/caplin1/run.go @@ -3,6 +3,7 @@ package caplin1 import ( "context" "database/sql" + "fmt" "os" "path" "time" @@ -107,7 +108,7 @@ func RunCaplinPhase1(ctx context.Context, sentinel sentinel.SentinelClient, engi return true }) gossipManager := network.NewGossipReceiver(sentinel, forkChoice, beaconConfig, genesisConfig, caplinFreezer) - + fmt.Println("A") { // start ticking forkChoice go func() { tickInterval := time.NewTicker(2 * time.Millisecond) diff --git a/eth/backend.go b/eth/backend.go index 7d32ca258..c409ee3cf 100644 --- a/eth/backend.go +++ b/eth/backend.go @@ -798,7 +798,12 @@ func New(ctx context.Context, stack *node.Node, config *ethconfig.Config, logger if err != nil { return nil, err } - go caplin1.RunCaplinPhase1(ctx, client, engine, beaconCfg, genesisCfg, state, nil, dirs, beacon.RouterConfiguration{Active: false}) + go func() { + if err := caplin1.RunCaplinPhase1(ctx, client, engine, beaconCfg, genesisCfg, state, nil, dirs, beacon.RouterConfiguration{Active: false}); err != nil { + logger.Error("could not start caplin", "err", err) + } + ctxCancel() + }() } return backend, nil