diff --git a/commons/human_feedback/dojo.py b/commons/human_feedback/dojo.py index bd3aca2..f049eb1 100644 --- a/commons/human_feedback/dojo.py +++ b/commons/human_feedback/dojo.py @@ -70,7 +70,7 @@ async def get_task_results_by_task_id(cls, task_id: str) -> List[Dict] | None: return task_results except Exception as e: if attempt < max_retries - 1: - delay = base_delay * 2**attempt + delay = base_delay * 2**attempt + random.uniform(0, 1) logger.warning( f"Error occurred while getting task results for task_id {task_id}: {e}. " f"Retrying in {delay:.2f} seconds..."