python - GAE 強制的にタスク キューをプッシュして次のタスクを実行する

Question

GAE にレート 1/s のプッシュ タスク キューがあります。そのキューのすべてのタスクを実行する必要はありませんが、呼び出されたときにのみ確認できます。したがって、タスクが呼び出されるたびに、「if (条件) execute else drop」ステートメントがあります。

今私の問題は、タスクが多すぎて、それらの多くが削除されることです。次の秒で別のタスクが呼び出されるのを待つのではなく、キューに次のタスクを強制的に呼び出して、その秒が無駄にならないようにしたいと思います。

質問したいのは、待機する代わりに、キューに別のタスクを強制的に取得させることは可能ですか? それとも自分で実装する必要がありますか？

明確でない場合は申し訳ありませんが、より良い言葉で表現してみます。

前もって感謝します！

Answer 1

プルタスクを操作する必要があります。すべてのプッシュタスクキューに対して、プルタスクもあります。プッシュタスクの実行時に、プルキューからタスクのバッチをリースし、それらの状態を確認します。
次のステップは、「有効」ではなくなったすべてのタスクを破棄し、単一の有効なタスクを実行することです。有効なタスクを実行すると、残りのすべてのタスクが返されます（時間をゼロにリースします）。

このフローは、有効なタスクが存在する場合に備えて、プッシュタスクごとに少なくとも1つのタスクを付与する必要があります。