diff --git a/scripts/data/client2.py b/scripts/data/client2.py index 3503ea45..2a96e2d6 100644 --- a/scripts/data/client2.py +++ b/scripts/data/client2.py @@ -160,6 +160,8 @@ def job_consumer(process_job): # If queue is empty for too long, exit the consumer thread print("Queue is empty, consumer is exiting.") break + except Exception as e: + print(f"Error processing job: {e}") def main(start, blocks, step, mode, strategy):