xuyue/OnlineJudge
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

add message to mq

Browse Source
This commit is contained in:
virusdefender
2015-08-22 12:31:28 +08:00
parent 2a55da23ec
commit fdf6b39c78
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
judge/judger_controller/tasks.py
View File

@@ -39,3 +39,4 @@ def judge(submission_id, time_limit, memory_limit, test_case_id):
conn.close() conn.close()
r = redis.Redis(host=redis_config["host"], port=redis_config["port"], db=redis_config["db"]) r = redis.Redis(host=redis_config["host"], port=redis_config["port"], db=redis_config["db"])
r.decr("judge_queue_length") r.decr("judge_queue_length")
r.lpush("queue", submission_id)