[DataPipe] Unlimited buffer for Forker and Demultiplexer (#64994)
authorErjia Guan <erjia@fb.com>
Mon, 20 Sep 2021 15:54:36 +0000 (08:54 -0700)
committerFacebook GitHub Bot <facebook-github-bot@users.noreply.github.com>
Mon, 20 Sep 2021 16:30:39 +0000 (09:30 -0700)
commitcf60d24028320bff1aae192ac5caf14a72a1c20f
treef106506a054b126d8ccb93f36564ca43eff96b87
parent88032d894311e5c0aed8bbc21a4306bc6be4af82
[DataPipe] Unlimited buffer for Forker and Demultiplexer (#64994)

Summary: Pull Request resolved: https://github.com/pytorch/pytorch/pull/64994

Test Plan: Imported from OSS

Reviewed By: jbschlosser

Differential Revision: D30934362

Pulled By: ejguan

fbshipit-source-id: d3b774d7e28c0b9659e999511e5a68c3929857d4
test/test_datapipe.py
torch/utils/data/datapipes/iter/combining.py