Skip to content
Open
Changes from 1 commit
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
8 changes: 6 additions & 2 deletions src/clusterfuzz/_internal/cron/schedule_fuzz.py
Original file line number Diff line number Diff line change
Expand Up @@ -300,9 +300,13 @@ def get_available_cpus(project: str, regions: List[str]) -> int:
region_target, region_usage = get_cpu_usage(creds, project, region)
target += region_target
usage += region_usage

# Deal with Chrome clusterfuzz having its pubsub in a different project.
pubsub_project = utils.get_application_id()
waiting_tasks = (
count_unacked(creds, project, 'preprocess') + count_unacked(
creds, project, 'utask_main'))
count_unacked(creds, pubsub_project, 'preprocess') + count_unacked(
creds, pubsub_project, 'utask_main'))


if usage + waiting_tasks * CPUS_PER_FUZZ_JOB > .95 * target:
# Only worry about queueing build up if we are above 95% utilization.
Expand Down
Loading