1
diff --git a/src/maasserver/workflow/bootresource.py b/src/maasserver/workflow/bootresource.py
2
index 4097f7e..559d03b 100644
3
--- a/src/maasserver/workflow/bootresource.py
4
+++ b/src/maasserver/workflow/bootresource.py
5
@@ -2,14 +2,13 @@ import asyncio
6
2
from asyncio import gather
2
from asyncio import gather
7
3
from dataclasses import dataclass, field, replace
3
from dataclasses import dataclass, field, replace
8
4
from datetime import datetime, timedelta
4
from datetime import datetime, timedelta
9
5
import random
10
6
from typing import Coroutine, Sequence
5
from typing import Coroutine, Sequence
11
7
6
12
8
from aiohttp.client_exceptions import ClientError
7
from aiohttp.client_exceptions import ClientError
13
9
from temporalio import activity, workflow
8
from temporalio import activity, workflow
14
10
from temporalio.common import RetryPolicy, WorkflowIDReusePolicy
9
from temporalio.common import RetryPolicy, WorkflowIDReusePolicy
15
11
from temporalio.exceptions import ApplicationError
10
from temporalio.exceptions import ApplicationError
17
12
from temporalio.workflow import ActivityCancellationType
11
from temporalio.workflow import ActivityCancellationType, random
18
13
12
19
14
from maasserver.utils.bootresource import (
13
from maasserver.utils.bootresource import (
20
15
    get_bootresource_store_path,
14
    get_bootresource_store_path,
21
@@ -298,9 +297,12 @@ class SyncBootResourcesWorkflow:
22
298
                for reg in sources
297
                for reg in sources
23
299
                for ep in endpoints[reg]
298
                for ep in endpoints[reg]
24
300
            ]
299
            ]
25
300
            # In order to balance the workload on the regions we randomize the order of the source_list. We use the random
26
301
            # generator provided by Temporal to keep the workflow execution deterministic.
27
302
            generator = random()
28
301
            new_res = replace(
303
            new_res = replace(
29
302
                res,
304
                res,
31
303
                source_list=random.sample(eps, min(len(eps), MAX_SOURCES)),
305
                source_list=generator.sample(eps, min(len(eps), MAX_SOURCES)),
32
304
            )
306
            )
33
305
            for region in missing:
307
            for region in missing:
34
306
                sync_jobs.append(_schedule(new_res, region))
308
                sync_jobs.append(_schedule(new_res, region))
Reviewer	Date Requested	Status
MAAS Lander		Approve on 2024-03-18
MAAS Maintainers	2024-03-18	Pending
Review via email: mp+462615@code.launchpad.net