Instantiate new client for each spawned worker (#402)
This commit is contained in:
parent
2b4e3b6b01
commit
5a0e6ed1d6
|
|
@ -165,11 +165,6 @@ func runWorker(cmd *cobra.Command, args []string) (err error) {
|
|||
"in the bootstrap token", ErrRunFailed)
|
||||
}
|
||||
|
||||
controllerClient, err := client.New(clientOpts...)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
// Initialize the logger
|
||||
logger, err := createLogger()
|
||||
if err != nil {
|
||||
|
|
@ -226,6 +221,11 @@ func runWorker(cmd *cobra.Command, args []string) (err error) {
|
|||
workerOptsLocal = append(workerOptsLocal, worker.WithNameSuffix(fmt.Sprintf("-%d", i+1)))
|
||||
}
|
||||
|
||||
controllerClient, err := client.New(clientOpts...)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
workerInstance, err := worker.New(controllerClient, workerOptsLocal...)
|
||||
if err != nil {
|
||||
return err
|
||||
|
|
|
|||
Loading…
Reference in New Issue