Skip to content

Commit 69701a9

Browse files
Make tworkers pull from postprocess or preprocess
There won't be any other workers to postproces anymore.
1 parent db280ad commit 69701a9

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

src/clusterfuzz/_internal/base/tasks/__init__.py

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -324,6 +324,8 @@ def tworker_get_task():
324324
# queue that is probably empty) to do a single preprocess. Investigate
325325
# combining preprocess and postprocess queues and allowing pulling of
326326
# multiple messages.
327+
if random.random() < .5:
328+
return get_postprocess_task()
327329
return get_preprocess_task()
328330

329331

0 commit comments

Comments
 (0)