Skip to content

Commit da6dbc8

Browse files
justusschockawaelchliSeanNarenBordatchaton
authored
PoC: Accelerator refactor (#5743)
* restoring the result from subprocess * fix queue.get() order for results * add missing "block_backward_sync" context manager * add missing "block_backward_sync" context manager * fix sync_batchnorm * fix supported gpu-ids for tuple * fix clip gradients and inf recursion * accelerator selection: added cluster_environment plugin * fix torchelastic test * fix reduce early stopping decision for DDP * fix tests: callbacks, conversion to lightning optimizer * fix lightning optimizer does not pickle * fix setting benchmark and deterministic option * fix slurm amp test * fix prepare_data test and determine node_rank * fix retrieving last path when testing * remove obsolete plugin argument * fix test: test_trainer_config * fix torchscript tests * fix trainer.model access * move properties * fix test_transfer_batch_hook * fix auto_select_gpus * fix omegaconf test * fix test that needs to simulate slurm ddp * add horovod plugin * fix test with named arguments * clean up whitespace * fix datamodules test * remove old accelerators * fix naming * move old plugins * move to plugins * create precision subpackage * create training_type subpackage * fix all new import errors * fix wrong arguments order passed to test * fix LR finder * Added sharded training type and amp plugin * Move clip grad to precision plugin * Added sharded spawn, select accelerators based on distributed_backend + enable custom fp16 plugin automatically * Fix import issue, attempting to fix tests * Fix initial test * Reflect hook logic from master, should wrap model after move to device * Optional state consolidation, since master has optimizers not wrapped * change attribute for instance test * reset optimizers optimizers are not used in main process, so state would be wrong. * legacy * imports in accel * legacy2 * trainer imports * fix import errors after rebase * move hook to new setup location * provide unwrapping logic * fix trainer callback system * added ddp2 implementation * fix imports .legacy * move plugins * restore legacy * drop test.py from root * add tpu accelerator and plugins * fixes * fix lightning optimizer merge * reset bugreportmodel * unwrapping * step routing forward * model access * unwrap * opt * integrate distrib_type * sync changes * sync * fixes * add forgotten generators * add missing logic * update * import * missed imports * import fixes * isort * mv f * changelog * format * move helper to parallel plugin * d * add world size * clean up * duplicate * activate ddp_sharded and tpu * set nvidia flags * remove unused colab var * use_tpu <-> on_tpu attrs * make some ddp_cpu and clusterplugin tests pass * Ref/accelerator connector (#5742) * final cleanup Co-authored-by: Adrian Wälchli <[email protected]> * connector cleanup Co-authored-by: Adrian Wälchli <[email protected]> * trainer cleanup Co-authored-by: Adrian Wälchli <[email protected]> * accelerator cleanup + missing logic in accelerator connector Co-authored-by: Adrian Wälchli <[email protected]> * add missing changes to callbacks Co-authored-by: Adrian Wälchli <[email protected]> * reflect accelerator changes to lightning module Co-authored-by: Adrian Wälchli <[email protected]> * clean cluster envs Co-authored-by: Adrian Wälchli <[email protected]> * cleanup plugins Co-authored-by: Adrian Wälchli <[email protected]> * add broadcasting Co-authored-by: Adrian Wälchli <[email protected]> * yapf * remove plugin connector Co-authored-by: Adrian Wälchli <[email protected]> * plugins * manual optimization * update optimizer routing * add rank to torchelastic * fix memory mixed precision * setstate on trainer for pickling in ddp spawn * add predict method * add back commented accelerator code * adapt test for sync_batch_norm to new plugin * fix deprecated tests * fix ddp cpu choice when no num_processes are given * yapf format * skip a memory test that cannot pass anymore * fix pickle error in spawn plugin * x * avoid * x * fix cyclic import in docs build * add support for sharded * update typing * add sharded and sharded_spawn to distributed types * make unwrap model default * refactor LightningShardedDataParallel similar to LightningDistributedDataParallel * update sharded spawn to reflect changes * update sharded to reflect changes * Merge 1.1.5 changes * fix merge * fix merge * yapf isort * fix merge * yapf isort * fix indentation in test * copy over reinit scheduler implementation from dev1.2 * fix apex tracking calls with dev_debugger * reduce diff to dev1.2, clean up * fix trainer config test when gpus>0 and num_processes >0 and ddp_cpu * sort plugin tests legacy/new * fix error handling for amp on cpu * fix merge fix merge fix merge * [Feat] Resolve manual_backward (#5837) * resolve manual_backward * resolve flake8 * update * resolve for ddp_spawn * resolve flake8 * resolve flake8 * resolve flake8 Co-authored-by: Ubuntu <[email protected]> * fix tests/accelerator tests on cpu * [BugFix] Resolve manual optimization (#5852) * resolve manual_optimization * update * update Co-authored-by: Ubuntu <[email protected]> * Remove copy trainer parameters to happen earlier within the loop and add safe guard to get ref model (#5856) * resovle a bug * Accelerator refactor sharded rpc (#5854) * rpc branch * merge * update handling of rpc * make devices etc. Optional in RPC * set devices etc. later if necessary * remove devices from sequential * make devices optional in rpc * fix import * uncomment everything * fix cluster selection Co-authored-by: Ubuntu <[email protected]> * resolve bug * fix assert in rpc test * resolve a test * fix docs compilation * accelerator refactor - fix for sharded parity test (#5866) * fix memory issue with ddp_spawn * x x x x x x x x x * x * Remove DDP2 as this does not apply * Add missing pre optimizer hook to ensure lambda closure is called * fix apex docstring * [accelerator][BugFix] Resolve some test for 1 gpu (#5863) * update * revert init * resolve a bug * update * resolve flake8 * update * update * update * revert init * resolve a bug * update * resolve flake8 * update * update * update * update * update * revert init * resolve a bug * update * resolve flake8 * update * update * update * revert init * update * resolve flake8 * update * update * update * update * update * all_gather * update * make plugins work, add misconfig for RPC * update * update * remove breaking test * resolve some tests * resolve flake8 * revert to ddp_spawn Co-authored-by: root <[email protected]> Co-authored-by: Ubuntu <[email protected]> Co-authored-by: Justus Schock <[email protected]> * yapf isort * resolve flake8 * fix apex doctests * fix apex doctests 2 * resolve docs * update drone * clean env * update * update * update * update * merge * Fix RPC related tests, clean out old API, update for new accelerator API [skip ci] (#5881) * Fix RPC related tests, clean out old API, update for new accelerator API * Move tests out of legacy folder, update paths and names * Update test_remove_1-4.py * Expose properties for tpu cores/gpus/num_gpus * Add root GPU property * Move properties to properties.py * move tests that were previously in drone * Fix root GPU property (#5908) * Move root GPU to property, remove horovod set as this is handled in horovod plugin, ensure we mock correctly to set GPU accelerator * Add missing tests back * fix best model path transfer when no checkpoint callback available * Fix setup hook order [wip] (#5858) * Call trainer setup hook before accelerator setup * Add test case * add new test * typo * fix callback order in test Co-authored-by: tchaton <[email protected]> Co-authored-by: Adrian Wälchli <[email protected]> * rename ddp sequential -> rpc sequential for special test * revert * fix stupid merge problem * Use property in connector for sampler (#5913) * merge the import conflicts * fix spawning of processes in slurm * [wip] Fix some bugs for TPU [skip ci] (#5878) * fixed for single tpu * fixed spawn * fixed spawn * update * update * wip * resolve bugs * resolve bug * update on comment * removed decorator * resolve comments * set to 4 * update * update * need cleaning * update * update * update * resolve flake8 * resolve bugs * exclude broadcast * resolve bugs * change test * update * update * skip if meet fails * properly raise trace * update * add catch * wrap test * resolve typo * update * typo Co-authored-by: Lezwon Castelino <[email protected]> Co-authored-by: Your Name <[email protected]> * resolve some tests * update * fix imports * update * resolve flake8 * update azure pipeline * skip a sharded test on cpu that requires a gpu * resolve tpus * resolve bug * resolve flake8 * update * updat utils * revert permission change on files * suggestions from carlos Co-authored-by: Carlos Mocholí <[email protected]> * remove unrelated formatting changes * remove incomplete comment * Update pytorch_lightning/accelerators/__init__.py Co-authored-by: Carlos Mocholí <[email protected]> * remove unrelated formatting change * add types * warn 1.7 ddp manual backward only if ddp kwarg unset * yapf + isort * pep8 unused imports * fix cyclic import in docs * Apply suggestions from code review * typer in accelerator.py * typo * Apply suggestions from code review * formatting * update on comments * update typo * Update pytorch_lightning/trainer/properties.py Co-authored-by: Adrian Wälchli <[email protected]> * update * suggestion from code review * suggestion from code review Co-authored-by: Adrian Wälchli <[email protected]> Co-authored-by: SeanNaren <[email protected]> Co-authored-by: Jirka Borovec <[email protected]> Co-authored-by: chaton <[email protected]> Co-authored-by: Ubuntu <[email protected]> Co-authored-by: Sean Naren <[email protected]> Co-authored-by: root <[email protected]> Co-authored-by: Lezwon Castelino <[email protected]> Co-authored-by: Your Name <[email protected]> Co-authored-by: Carlos Mocholí <[email protected]> Co-authored-by: Jirka Borovec <[email protected]> Co-authored-by: mergify[bot] <37929162+mergify[bot]@users.noreply.github.com>
1 parent 309ce7a commit da6dbc8

File tree

92 files changed

+1685
-1678
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

92 files changed

+1685
-1678
lines changed

.gitignore

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -151,6 +151,6 @@ wandb
151151

152152
# dataset generated from bolts in examples.
153153
cifar-10-batches-py
154-
154+
*.pt
155155
# ctags
156-
tags
156+
tags

benchmarks/test_sharded_parity.py

Lines changed: 5 additions & 28 deletions
Original file line numberDiff line numberDiff line change
@@ -15,14 +15,13 @@
1515
import os
1616
import platform
1717
import time
18-
from typing import Type, Union
18+
from typing import Type
1919

2020
import pytest
2121
import torch
2222

2323
from pytorch_lightning import seed_everything, Trainer
24-
from pytorch_lightning.plugins.legacy.ddp_plugin import DDPPlugin
25-
from pytorch_lightning.plugins.legacy.sharded_plugin import DDPShardedPlugin
24+
from pytorch_lightning.plugins import DDPSpawnShardedPlugin
2625
from pytorch_lightning.utilities import _FAIRSCALE_AVAILABLE, _NATIVE_AMP_AVAILABLE
2726
from tests.accelerators.legacy import DDPLauncher
2827
from tests.helpers.boring_model import BoringModel, RandomDataset
@@ -34,8 +33,6 @@
3433
def test_ddp_sharded_plugin_correctness_one_gpu():
3534
plugin_parity_test(
3635
gpus=1,
37-
accelerator='ddp_spawn',
38-
plugin=DDPShardedPlugin(),
3936
model_cls=SeedTrainLoaderModel,
4037
)
4138

@@ -48,8 +45,6 @@ def test_ddp_sharded_plugin_correctness_amp_one_gpu():
4845
plugin_parity_test(
4946
gpus=1,
5047
precision=16,
51-
accelerator='ddp_spawn',
52-
plugin=DDPShardedPlugin(),
5348
model_cls=SeedTrainLoaderModel,
5449
)
5550

@@ -61,8 +56,6 @@ def test_ddp_sharded_plugin_correctness_amp_one_gpu():
6156
def test_ddp_sharded_plugin_correctness_multi_gpu():
6257
plugin_parity_test(
6358
gpus=2,
64-
accelerator='ddp_spawn',
65-
plugin=DDPShardedPlugin(),
6659
model_cls=SeedTrainLoaderModel,
6760
max_percent_speed_diff=0.25, # todo: Increase speed diff since only 2 GPUs sharding 2 optimizers
6861
)
@@ -76,8 +69,6 @@ def test_ddp_sharded_plugin_correctness_amp_multi_gpu():
7669
plugin_parity_test(
7770
gpus=2,
7871
precision=16,
79-
accelerator='ddp_spawn',
80-
plugin=DDPShardedPlugin(),
8172
model_cls=SeedTrainLoaderModel,
8273
max_percent_speed_diff=0.25, # todo: Increase speed diff since only 2 GPUs sharding 2 optimizers
8374
)
@@ -91,8 +82,6 @@ def test_ddp_string_sharded_plugin_correctness_amp_multi_gpu():
9182
plugin_parity_test(
9283
gpus=2,
9384
precision=16,
94-
accelerator='ddp_spawn',
95-
plugin='ddp_sharded',
9685
model_cls=SeedTrainLoaderModel,
9786
max_percent_speed_diff=0.25, # todo: Increase speed diff since only 2 GPUs sharding 2 optimizers
9887
)
@@ -108,8 +97,6 @@ def test_ddp_sharded_plugin_correctness_multi_gpu_ddp(tmpdir, args=None):
10897
plugin_parity_test(
10998
gpus=args.gpus,
11099
precision=args.precision,
111-
accelerator=args.accelerator,
112-
plugin=DDPShardedPlugin(),
113100
model_cls=SeedTrainLoaderModel,
114101
)
115102

@@ -124,8 +111,6 @@ def test_ddp_sharded_plugin_correctness_amp_multi_gpu_ddp(tmpdir, args=None):
124111
plugin_parity_test(
125112
gpus=args.gpus,
126113
precision=args.precision,
127-
accelerator=args.accelerator,
128-
plugin=DDPShardedPlugin(),
129114
model_cls=SeedTrainLoaderModel,
130115
)
131116

@@ -139,9 +124,7 @@ def test_ddp_sharded_plugin_correctness_multi_gpu_multi_optim():
139124
Ensures same results using multiple optimizers across multiple GPUs
140125
"""
141126
plugin_parity_test(
142-
plugin=DDPShardedPlugin(),
143127
gpus=2,
144-
accelerator='ddp_spawn',
145128
model_cls=SeedTrainLoaderMultipleOptimizersModel,
146129
max_percent_speed_diff=0.25, # todo: Increase speed diff since only 2 GPUs sharding 2 optimizers
147130
)
@@ -156,9 +139,7 @@ def test_ddp_sharded_plugin_correctness_multi_gpu_multi_optim_manual(tmpdir):
156139
Ensures using multiple optimizers across multiple GPUs with manual optimization
157140
"""
158141
plugin_parity_test(
159-
plugin=DDPShardedPlugin(),
160142
gpus=2,
161-
accelerator='ddp_spawn',
162143
model_cls=SeedTrainLoaderManualModel,
163144
max_percent_speed_diff=0.25, # todo: Increase speed diff since only 2 GPUs sharding 2 optimizers
164145
)
@@ -260,9 +241,7 @@ def record_ddp_fit_model_stats(trainer, model, use_cuda):
260241

261242
def plugin_parity_test(
262243
model_cls: Type[SeedTrainLoaderModel],
263-
plugin: Union[str, DDPPlugin],
264244
seed: int = 42,
265-
accelerator: str = 'ddp_spawn',
266245
gpus: int = 0,
267246
precision: int = 32,
268247
max_percent_speed_diff: float = 0.1,
@@ -273,9 +252,7 @@ def plugin_parity_test(
273252
274253
Args:
275254
model_cls: Model class to use for test.
276-
plugin: Plugin to parity test.
277255
seed: Seed for generators. Note that this does not handle the seed for data-loading on multi-process.
278-
accelerator: Accelerator type for test.
279256
gpus: Number of GPUS to enable.
280257
precision: Whether to use AMP or normal FP32 training.
281258
max_percent_speed_diff: The maximum speed difference compared to normal DDP training.
@@ -293,7 +270,7 @@ def plugin_parity_test(
293270
max_epochs=1,
294271
gpus=gpus,
295272
precision=precision,
296-
accelerator=accelerator,
273+
accelerator='ddp_spawn',
297274
)
298275

299276
max_memory_ddp, ddp_time = record_ddp_fit_model_stats(trainer=trainer, model=ddp_model, use_cuda=use_cuda)
@@ -307,9 +284,9 @@ def plugin_parity_test(
307284
max_epochs=1,
308285
gpus=gpus,
309286
precision=precision,
310-
accelerator=accelerator,
311-
plugins=[plugin],
287+
accelerator='ddp_sharded_spawn',
312288
)
289+
assert isinstance(trainer.training_type_plugin, DDPSpawnShardedPlugin)
313290

314291
max_memory_custom, custom_model_time = record_ddp_fit_model_stats(
315292
trainer=trainer, model=custom_plugin_model, use_cuda=use_cuda

dockers/tpu-tests/tpu_test_cases.jsonnet

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,7 @@ local tputests = base.BaseTest {
2121
command: utils.scriptCommand(
2222
|||
2323
cd pytorch-lightning
24-
coverage run --source=pytorch_lightning -m pytest -v \
24+
coverage run --source=pytorch_lightning -m pytest -v --capture=no \
2525
pytorch_lightning/utilities/xla_device_utils.py \
2626
tests/accelerators/legacy/test_tpu_backend.py \
2727
tests/models/test_tpu.py

docs/source/advanced/amp.rst

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -31,10 +31,10 @@ Native torch
3131
When using PyTorch 1.6+ Lightning uses the native amp implementation to support 16-bit.
3232

3333
.. testcode::
34-
:skipif: not _APEX_AVAILABLE and not _NATIVE_AMP_AVAILABLE
34+
:skipif: not _APEX_AVAILABLE and not _NATIVE_AMP_AVAILABLE or not torch.cuda.is_available()
3535

3636
# turn on 16-bit
37-
trainer = Trainer(precision=16)
37+
trainer = Trainer(precision=16, gpus=1)
3838

3939
Apex 16-bit
4040
^^^^^^^^^^^
@@ -73,7 +73,7 @@ Enable 16-bit
7373
^^^^^^^^^^^^^
7474

7575
.. testcode::
76-
:skipif: not _APEX_AVAILABLE and not _NATIVE_AMP_AVAILABLE
76+
:skipif: not _APEX_AVAILABLE and not _NATIVE_AMP_AVAILABLE or not torch.cuda.is_available()
7777

7878
# turn on 16-bit
7979
trainer = Trainer(amp_level='O2', precision=16)

docs/source/common/trainer.rst

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1178,13 +1178,13 @@ If used on TPU will use torch.bfloat16 but tensor printing
11781178
will still show torch.float32.
11791179
11801180
.. testcode::
1181-
:skipif: not _APEX_AVAILABLE and not _NATIVE_AMP_AVAILABLE
1181+
:skipif: not _APEX_AVAILABLE and not _NATIVE_AMP_AVAILABLE or not torch.cuda.is_available()
11821182
11831183
# default used by the Trainer
11841184
trainer = Trainer(precision=32)
11851185
11861186
# 16-bit precision
1187-
trainer = Trainer(precision=16)
1187+
trainer = Trainer(precision=16, gpus=1)
11881188
11891189
Example::
11901190
Lines changed: 4 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,4 @@
11
# Copyright The PyTorch Lightning team.
2-
#
32
# Licensed under the Apache License, Version 2.0 (the "License");
43
# you may not use this file except in compliance with the License.
54
# You may obtain a copy of the License at
@@ -11,15 +10,7 @@
1110
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
1211
# See the License for the specific language governing permissions and
1312
# limitations under the License.
14-
from pytorch_lightning.accelerators.legacy.accelerator import Accelerator # noqa: F401
15-
from pytorch_lightning.accelerators.legacy.cpu_accelerator import CPUAccelerator # noqa: F401
16-
from pytorch_lightning.accelerators.legacy.ddp2_accelerator import DDP2Accelerator # noqa: F401
17-
from pytorch_lightning.accelerators.legacy.ddp_accelerator import DDPAccelerator # noqa: F401
18-
from pytorch_lightning.accelerators.legacy.ddp_cpu_hpc_accelerator import DDPCPUHPCAccelerator # noqa: F401
19-
from pytorch_lightning.accelerators.legacy.ddp_cpu_spawn_accelerator import DDPCPUSpawnAccelerator # noqa: F401
20-
from pytorch_lightning.accelerators.legacy.ddp_hpc_accelerator import DDPHPCAccelerator # noqa: F401
21-
from pytorch_lightning.accelerators.legacy.ddp_spawn_accelerator import DDPSpawnAccelerator # noqa: F401
22-
from pytorch_lightning.accelerators.legacy.dp_accelerator import DataParallelAccelerator # noqa: F401
23-
from pytorch_lightning.accelerators.legacy.gpu_accelerator import GPUAccelerator # noqa: F401
24-
from pytorch_lightning.accelerators.legacy.horovod_accelerator import HorovodAccelerator # noqa: F401
25-
from pytorch_lightning.accelerators.legacy.tpu_accelerator import TPUAccelerator # noqa: F401
13+
from pytorch_lightning.accelerators.accelerator import Accelerator # noqa F401
14+
from pytorch_lightning.accelerators.cpu import CPUAccelerator # noqa F401
15+
from pytorch_lightning.accelerators.gpu import GPUAccelerator # noqa F401
16+
from pytorch_lightning.accelerators.tpu import TPUAccelerator # noqa F401

0 commit comments

Comments
 (0)