Skip to content

Commit 4550ac5

Browse files
authored
Merge pull request #49 from embik/engage-single-provider
🐛 Engage cluster in single provider start process
2 parents 05a6f78 + 69b4b89 commit 4550ac5

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

providers/single/provider.go

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -44,7 +44,10 @@ func New(name string, cl cluster.Cluster) *Provider {
4444
}
4545

4646
// Run starts the provider and blocks.
47-
func (p *Provider) Run(ctx context.Context, _ mcmanager.Manager) error {
47+
func (p *Provider) Run(ctx context.Context, mgr mcmanager.Manager) error {
48+
if err := mgr.Engage(ctx, p.name, p.cl); err != nil {
49+
return err
50+
}
4851
<-ctx.Done()
4952
return nil
5053
}

0 commit comments

Comments
 (0)