WorkerProcess passes None poll intervals to the backend, breaking acquire in the consumer thread

オープン 初心者向け
#53 コメント 0 件 リアクション 0 件 担当者 0 名 GitHub で見る

まだ誰も着手していません。

評価

難易度
2/5
見積もり時間
1〜3時間
初心者へのやさしさ
82/100
issue の種類
バグ
明瞭さ
明確に書かれている
活発さ
活発
技術スタック
python, redis
領域
backend, databases, testing-qa

調査の方向性

tests/test_executor.py:_make_worker() と WorkerProcess.run() から始め、次に poll 間隔が使用されている RedisTaskBackend.acquire() を調べます。関連する executor テストを実行し、デフォルトの polling で acquire に None として到達しなくなったこと、および consumer thread が未処理の TypeError なしに完了することを確認します。

索引モデルが issue の本文から書いたものです。

説明

Found by testJoe while adding coverage for the fair multi-queue rotation (codingjoe-fair-multi-queue-scheduling), and confirmed pre-existing (untouched by that diff):

defer: WorkerProcess.run() lets None poll overrides reach RedisTaskBackend.acquire, raising TypeError in the consumer thread. Pre-existing, untouched L297. [tests/test_executor.py]

QED

  1. tests/test_executor.py:_make_worker() defaults poll_interval and poll_max_interval to None and passes them into WorkerProcess.
  2. WorkerProcess.run() assigns them to the backend (backend.poll_interval = self.poll_interval), so the backend's poll options become None.
  3. RedisTaskBackend.acquire() computes int(self.poll_max_interval / self.poll_interval), which raises TypeError: unsupported operand type(s) inside the consumer thread.

The suite only reports PytestUnhandledThreadExceptionWarning, so the failure is invisible today. Either treat None as "keep the backend default" in WorkerProcess, or make the test helper pass the real defaults.

主要言語
Python
スター
12
フォーク
1
平均マージ
1日 1時間
マージ済み PR（30日）
10

コントリビューションガイド

コントリビューションガイドを開く

はじめの一歩

  1. issue を最後まで読み、次にプロジェクトのコントリビューションガイドを読みます。
  2. 着手することを issue にコメントします — 二人が同じ作業をするのを防げます。
  3. リポジトリをフォークし、ブランチを切って変更します。
  4. issue 番号を参照したプルリクエストを送ります。

codingjoe/threadmill のほかの issue

codingjoe/threadmill の issue をすべて見る

似ている issue

Python の issue をもっと見る

新しい issue をメールで受け取る

初心者向けの GitHub issue を短くまとめたダイジェスト。