The subclass of `dict` is not respected on `>=2024.11.0`
まだ誰も着手していません。
評価
- 難易度
- 3/5
- 見積もり時間
- 1〜2日
- 初心者へのやさしさ
- 48/100
- issue の種類
- バグ
- 明瞭さ
- おおむね明確
- 活発さ
- 停滞
- 技術スタック
- python
調査の方向性
提供された Client.submit と as_completed の例で問題を再現し、その後、dask.distributed が使用する送信およびシリアライズの経路を調査します。TestDict サブクラスが Dask 2024.11.0 で変更されずに test_subclass に到達し、例が属性値を正常に出力できれば完了です。
索引モデルが issue の本文から書いたものです。
説明
Describe the issue:
The subclass is not respected. I noticed the issue on subclass of dict, not sure if it's more general. See below for details.
Minimal Complete Verifiable Example:
from dask.distributed import Client, as_completed
class TestDict(dict):
def __init__(self, **kwargs):
super().__init__(**kwargs)
def __getattr__(self, key: str):
""" Allow access to items as attributes. """
v = self.get(key, self)
if v is self:
raise AttributeError("has no attribute '{}'".format(key))
return v
def __repr__(self) -> str:
return "(TestDict{})".format(super().__repr__())
def test_subclass(test_dict):
print(f'input type {type(test_dict)}')
print(f'get val {test_dict.a}')
return 0
def main():
client = Client()
test_dict = TestDict(a=1)
futures = [client.submit(test_subclass, test_dict)]
for f in as_completed(futures):
res = f.result()
print(f"result {res}")
if __name__ == "__main__":
main()
Anything else we need to know?:
The test code works as expected on <2024.11.0, which outputs
input type <class '__main__.TestDict'>
get val 1
result 0
on >=2024.11.0 outputs
input type <class 'dict'>
2024-11-13 05:01:36,954 - distributed.worker - ERROR - Compute Failed
Key: test_subclass-e8dd185fef44ec112f057d9b352f913f
State: executing
Task: <Task 'test_subclass-e8dd185fef44ec112f057d9b352f913f' test_subclass(...)>
Exception: 'AttributeError("\'dict\' object has no attribute \'a\'")'
Traceback: ' File "/home/ubuntu/data/home/ubuntu/test_dask.py", line 20, in test_subclass\n print(f\'get val {test_dict.a}\')\n'
Traceback (most recent call last):
File "/home/ubuntu/data/home/ubuntu/test_dask.py", line 34, in <module>
main()
File "/home/ubuntu/data/home/ubuntu/test_dask.py", line 29, in main
res = f.result()
File "/home/ubuntu/.local/lib/python3.10/site-packages/distributed/client.py", line 402, in result
return self.client.sync(self._result, callback_timeout=timeout)
File "/home/ubuntu/data/home/ubuntu/test_dask.py", line 20, in test_subclass
print(f'get val {test_dict.a}')
Environment:
- Dask version:
2024.11.0 - Python version:
3.10 - Operating System:
ubuntu 22.04 - Install method (conda, pip, source):
pip
- 主要言語
- Python
- スター
- 1.7k
- フォーク
- 778
- PR マージ指標
- 30日以内にマージされた PR はありません
環境構築
はじめの一歩
- issue を最後まで読み、次にプロジェクトのコントリビューションガイドを読みます。
- 着手することを issue にコメントします — 二人が同じ作業をするのを防げます。
- リポジトリをフォークし、ブランチを切って変更します。
- issue 番号を参照したプルリクエストを送ります。
dask/distributed のほかの issue
-
needs triage
難易度 2/5 1〜3時間 初心者へのやさしさ 72/100
dask/distributed#9366 ·
-
needs triage
難易度 2/5 1〜3時間 初心者へのやさしさ 84/100
dask/distributed#9353 ·
-
documentation
難易度 1/5 1〜3時間 初心者へのやさしさ 82/100
dask/distributed#8304 ·
-
難易度 2/5 1〜3時間 初心者へのやさしさ 74/100
dask/distributed#4816 · コメント 2 件 ·
-
documentation good first issue
難易度 2/5 1〜3時間 初心者へのやさしさ 74/100
dask/distributed#2378 · コメント 2 件 ·
dask/distributed の issue をすべて見る
似ている issue
-
ACK_WAITING HELP_WANTED UPDATE_CS
難易度 2/5 1〜3時間 初心者へのやさしさ 78/100
OWASP/CheatSheetSeries#2458 ·
メンテナーはふだん 1 日以内に返信
-
難易度 2/5 1〜3時間 初心者へのやさしさ 82/100
メンテナーはふだん 1 日以内に返信
-
難易度 2/5 1〜3時間 初心者へのやさしさ 90/100
BasedHardware/omi#19711 ·
メンテナーはふだん 1 日以内に返信
-
Qwen3_5MoeModel no longer returns router_logits, breaking aux loss with output_router_logits=Trueオープン
難易度 2/5 1〜3時間 初心者へのやさしさ 78/100
huggingface/transformers#49172 ·
メンテナーはふだん 1 日以内に返信
-
難易度 2/5 1〜3時間 初心者へのやさしさ 82/100
vllm-project/vllm-metal#885 ·
メンテナーはふだん 1 日以内に返信