Skip to content

Commit f34b1a3

Browse files
committed
feat: initial implementation
1 parent 9d52020 commit f34b1a3

2 files changed

Lines changed: 330 additions & 611 deletions

File tree

src/MaxText/layers/decoders.py

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -36,6 +36,7 @@
3636
from MaxText.inference import page_manager
3737
from MaxText.layers import linears
3838
from MaxText.layers import normalizations
39+
from MaxText.layers import nnx_wrappers
3940
from MaxText.layers import quantizations
4041
from MaxText.layers import pipeline
4142
from MaxText import maxtext_utils
@@ -276,9 +277,10 @@ def setup(self):
276277
self.decoder_layer = self.get_decoder_layers()
277278
self.norm_layer = self.get_norm_layer(num_features=self.config.emb_dim)
278279
if self.config.using_pipeline_parallelism:
279-
pipeline_stage_module = self.get_pipeline_stage_module(self.decoder_layer)
280+
rngs = nnx.Rngs(params=jax.random.PRNGKey(self.config.init_weights_seed), dropout=1)
281+
pipeline_stage_module = nnx_wrappers.ToNNX(self.get_pipeline_stage_module(self.decoder_layer),rngs)
280282
remat_policy = self.get_remat_policy()
281-
self.pipeline_module = pipeline.Pipeline(
283+
self.pipeline_module = pipeline.pipeline_as_linen(
282284
config=self.config, mesh=self.mesh, layers=pipeline_stage_module, remat_policy=remat_policy
283285
)
284286

0 commit comments

Comments
 (0)