問題タブ [rq]

質問があります。RQ ワーカーを一時停止して、キューで待機しているジョブを取得する可能性はありますか? 私が見つけた唯一の方法はそれらを殺すことですが、ワーカーの状態を設定するより良い方法があると思います。

キュー タスクに django-rq と redis を使用しています。Timeout:6000 ですが、タイムアウト エラーが発生します。

初めてワーカーを起動したときにどういうわけか機能し、このコードもキューなしで機能します

ここに私のキューコード:

ここに私のエラーコード

Taskerクラスは、インスタンス化時に初期ジョブをセットアップします。基本的に私が望むのは、ジョブを「main_queue」に入れ、ジョブが実行されているかどうか、または「process_queue」にキューに入れられている同じジョブが既に存在するかどうかを判断し、現在の「main_queue」ジョブから戻ることです。それ以外の場合は、「process_queue」にジョブをキューに入れます。そのプロセス キューが終了したら、ジョブを「main_queue」に入れます。

ただし、「process_queue」には、出力の確認が終了しているはずであるにもかかわらず、その期間の id を持つ同じジョブがあります。したがって、新しいジョブが処理されることはありません。見ることができないデッドロックが発生していますか?

main_queue ワーカー

process_queue ワーカー

tasker.py

タスク.py