Skip to content
GitLab
Menu
Projects
Groups
Snippets
Loading...
Help
Help
Support
Community forum
Keyboard shortcuts
?
Submit feedback
Contribute to GitLab
Sign in / Register
Toggle navigation
Menu
Open sidebar
OpenDAS
Megatron-LM
Commits
56934a2d
Commit
56934a2d
authored
Oct 06, 2022
by
shanmugamr
Browse files
Adding some basic unit tests
parent
423623cb
Changes
3
Hide whitespace changes
Inline
Side-by-side
Showing
3 changed files
with
4 additions
and
7 deletions
+4
-7
.coverage
.coverage
+0
-0
.gitlab-ci.yml
.gitlab-ci.yml
+3
-0
tests/test_parallel_state.py
tests/test_parallel_state.py
+1
-7
No files found.
.coverage
View file @
56934a2d
No preview for this file type
.gitlab-ci.yml
View file @
56934a2d
image
:
gitlab-master.nvidia.com/dl/dgx/pytorch:21.12-py3-devel
image
:
gitlab-master.nvidia.com/dl/dgx/pytorch:21.12-py3-devel
[
runners.docker
]
gpus = "all"
test
:
test
:
tags
:
tags
:
-
docker
-
docker
...
...
tests/test_parallel_state.py
View file @
56934a2d
...
@@ -29,7 +29,7 @@ def test_initialize_model_parallel():
...
@@ -29,7 +29,7 @@ def test_initialize_model_parallel():
with
pytest
.
raises
(
RuntimeError
):
with
pytest
.
raises
(
RuntimeError
):
assert
(
ps
.
initialize_model_parallel
(
pipeline_model_parallel_size
=
world_size
,
tensor_model_parallel_size
=
world_size
))
assert
(
ps
.
initialize_model_parallel
(
pipeline_model_parallel_size
=
world_size
,
tensor_model_parallel_size
=
world_size
))
with
pytest
.
raises
(
RuntimeError
):
with
pytest
.
raises
(
RuntimeError
):
assert
(
ps
.
initialize_model_parallel
(
virtual_pipeline_model_parallel_size
=
2
))
assert
(
ps
.
initialize_model_parallel
(
virtual_pipeline_model_parallel_size
=
world_size
))
ps
.
initialize_model_parallel
()
ps
.
initialize_model_parallel
()
assert
(
ps
.
model_parallel_is_initialized
())
assert
(
ps
.
model_parallel_is_initialized
())
...
@@ -112,12 +112,6 @@ def test_get_tensor_model_parallel_src_rank():
...
@@ -112,12 +112,6 @@ def test_get_tensor_model_parallel_src_rank():
assert
(
ps
.
get_tensor_model_parallel_src_rank
()
==
((
rank
//
world_size
)
*
world_size
))
assert
(
ps
.
get_tensor_model_parallel_src_rank
()
==
((
rank
//
world_size
)
*
world_size
))
ps
.
destroy_model_parallel
()
ps
.
destroy_model_parallel
()
def
test_global_memory_buffer
():
ps
.
_GLOBAL_MEMORY_BUFFER
=
None
ps
.
_set_global_memory_buffer
()
assert
(
ps
.
get_global_memory_buffer
()
is
not
None
)
"""
"""
def test_get_virtual_pipeline_model_parallel_world_size():
def test_get_virtual_pipeline_model_parallel_world_size():
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
.
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment