Add more batch logging

google · Dec 12, 2023 · 051ec7c · 051ec7c
1 parent e1a147c
commit 051ec7c
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/src/clusterfuzz/_internal/bot/tasks/task_creation.py b/src/clusterfuzz/_internal/bot/tasks/task_creation.py
@@ -327,5 +327,5 @@ def schedule_tasks(tasks: List[Task]):
       continue
     _preprocess(task)
     uworker_tasks.append(task)
-  logs.log('Starting utask_mains.')
+  logs.log(f'Starting utask_mains: {len(uworker_tasks)}.')
   start_utask_mains(uworker_tasks)
diff --git a/src/clusterfuzz/_internal/google_cloud_utils/batch.py b/src/clusterfuzz/_internal/google_cloud_utils/batch.py
@@ -104,6 +104,7 @@ def create_uworker_main_batch_jobs(batch_tasks):
     spec = get_spec_from_config(batch_task.command, batch_task.job_type)
     job_specs[spec].append(batch_task.input_download_url)
 
+  logs.log('Creating batch jobs', specs=job_specs)
   return [
       _create_job(spec, input_urls) for spec, input_urls in job_specs.items()
   ]