Skip to content

Commit

Permalink
Change setting up triggers
Browse files Browse the repository at this point in the history
  • Loading branch information
leszko committed Jul 17, 2024
1 parent 6e6a11b commit baa4718
Showing 1 changed file with 1 addition and 3 deletions.
4 changes: 1 addition & 3 deletions main.go
Original file line number Diff line number Diff line change
Expand Up @@ -187,7 +187,6 @@ func main() {
vodEngine *pipeline.Coordinator
mapic mistapiconnector.IMac
bal balancer.Balancer
broker misttriggers.TriggerBroker
mist clients.MistAPIClient
c cluster.Cluster
mistBalancer balancer.Balancer
Expand All @@ -205,6 +204,7 @@ func main() {
OwnRegion: cli.OwnRegion,
OwnRegionTagAdjust: cli.OwnRegionTagAdjust,
}
broker := misttriggers.NewTriggerBroker()

if cli.IsApiMode() {
// TODO: I don't love the global variables for these
Expand Down Expand Up @@ -256,8 +256,6 @@ func main() {
glog.Fatalf("Error creating VOD pipeline coordinator: %v", err)
}

broker = misttriggers.NewTriggerBroker()

if cli.ShouldMapic() {
mapic = mistapiconnector.NewMapic(&cli, broker, mist)
group.Go(func() error {
Expand Down

0 comments on commit baa4718

Please sign in to comment.