我使用python flask+redis,并使用以下代码在redis queue中将作业排队:
with Connection(redis.from_url("redis://localhost:6379")):
queue = Queue()
task = queue.enqueue(self.redis_method, job_timeout=86400, result_ttl=604800, failure_ttl=604800)
response_object = {"status": "success", "data": {"task_id": task.get_id()}}
return response_object
作业正在排队并开始执行,我获取排队作业的作业id。并使用下面的代码终止作业,但即使在执行下面的代码后,执行也不会停止
cancel_job(job_id=job_id,connection= redis.from_url("redis://localhost:6379"))
谢谢你的帮助。提前谢谢~
暂无答案!
目前还没有任何答案,快来回答吧!