We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 5a5f4f8 commit 6fa127aCopy full SHA for 6fa127a
1 file changed
aggregator/cmd/main.go
@@ -50,18 +50,13 @@ func aggregatorMain(ctx *cli.Context) error {
50
}
51
52
// Listen for new task created in the ServiceManager contract in a separate goroutine
53
+ // Both V1 and V2 subscriptions:
54
go func() {
55
listenErr := aggregator.SubscribeToNewTasks()
56
if listenErr != nil {
57
aggregatorConfig.BaseConfig.Logger.Fatal("Error subscribing for new tasks", "err", listenErr)
58
59
}()
- go func() {
60
- listenErr := aggregator.SubscribeToNewTasksV2()
61
- if listenErr != nil {
62
- aggregatorConfig.BaseConfig.Logger.Fatal("Error subscribing for new tasks V2", "err", listenErr)
63
- }
64
- }()
65
66
err = aggregator.Start(context.Background())
67
if err != nil {
0 commit comments