Clean up legacy batcher code
@@ -22,7 +22,6 @@ package batcher
import (
"context"
- "time"
"github.com/opentracing/opentracing-go"
"github.com/uber-go/tally"
@@ -37,16 +36,6 @@ import (
"go.uber.org/cadence/worker"
)
-const (
- // maximum time waiting for this batcher to start before giving up
- maxStartupTime = time.Minute * 3
- backOffInitialInterval = time.Second
- backOffMaxInterval = time.Minute
- rpcTimeout = time.Second
-
- waitingForGlobalDomainCreationRacingCondition = time.Second * 20
-)
-
type (
// Config defines the configuration for batcher
Config struct {
@@ -105,13 +94,6 @@ func (s *Batcher) Start() error {
BackgroundActivityContext: ctx,
Tracer: opentracing.GlobalTracer(),
}
- // TODO https://github.com/uber/cadence/issues/2309
- // Remove it in next release
- legacyWorker := worker.New(s.svcClient, common.SystemGlobalDomainName, BatcherTaskListName, workerOpts)
- err := legacyWorker.Start()
- if err != nil {
- return err
- }
batchWorker := worker.New(s.svcClient, common.SystemLocalDomainName, BatcherTaskListName, workerOpts)
return batchWorker.Start()
}
