diff options
| author | Valery Piashchynski <[email protected]> | 2021-01-26 10:27:13 +0300 |
|---|---|---|
| committer | Valery Piashchynski <[email protected]> | 2021-01-26 10:27:13 +0300 |
| commit | 800042d81fc9224ab05f01d1506df0d4b7ac4daa (patch) | |
| tree | 93eecce841db96e21c64f67986b73362aad1ee33 /plugins/temporal/workflow/plugin.go | |
| parent | 4638bdca80f75bc120b330022086d31c8b41be5b (diff) | |
Attempt to fix data race in the Test_WorkerError_DisasterRecovery_Heavy
test
Diffstat (limited to 'plugins/temporal/workflow/plugin.go')
| -rw-r--r-- | plugins/temporal/workflow/plugin.go | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/plugins/temporal/workflow/plugin.go b/plugins/temporal/workflow/plugin.go index 3a397364..572d9a3b 100644 --- a/plugins/temporal/workflow/plugin.go +++ b/plugins/temporal/workflow/plugin.go @@ -111,6 +111,8 @@ func (p *Plugin) Name() string { // Workers returns list of available workflow workers. func (p *Plugin) Workers() []worker.BaseProcess { + p.mu.Lock() + defer p.mu.Unlock() return p.pool.Workers() } |