Lock task list properly.
Signed-off-by: Lantao Liu <lantaol@google.com>
This commit is contained in:
parent
fe4e30cbb7
commit
71e42bf65c
@ -49,6 +49,8 @@ func (l *TaskList) Get(ctx context.Context, id string) (Task, error) {
|
|||||||
|
|
||||||
// GetAll tasks under a namespace
|
// GetAll tasks under a namespace
|
||||||
func (l *TaskList) GetAll(ctx context.Context) ([]Task, error) {
|
func (l *TaskList) GetAll(ctx context.Context) ([]Task, error) {
|
||||||
|
l.mu.Lock()
|
||||||
|
defer l.mu.Unlock()
|
||||||
namespace, err := namespaces.NamespaceRequired(ctx)
|
namespace, err := namespaces.NamespaceRequired(ctx)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
|
Loading…
Reference in New Issue
Block a user