|
35 | 35 | from crazyflow.sim.data import SimControls, SimCore, SimData, SimParams, SimState, SimStateDeriv |
36 | 36 | from crazyflow.sim.integration import Integrator, euler, rk4, symplectic_euler |
37 | 37 | from crazyflow.sim.pipeline import append_fn |
38 | | -from crazyflow.sim.sharding import build_sharded, placement |
| 38 | +from crazyflow.sim.sharding import build_sharded_data, placement |
39 | 39 | from crazyflow.utils import grid_2d, pytree_replace, world_mask |
40 | 40 |
|
41 | 41 | if TYPE_CHECKING: |
@@ -143,7 +143,7 @@ def __init__( |
143 | 143 | if mesh is None: |
144 | 144 | self.data = self.init_data(*freqs, rng_key) |
145 | 145 | else: |
146 | | - self.data = build_sharded(partial(self.init_data, *freqs), rng_key, mesh) |
| 146 | + self.data = build_sharded_data(partial(self.init_data, *freqs), rng_key, mesh) |
147 | 147 | self.default_data: SimData = self.build_default_data() |
148 | 148 |
|
149 | 149 | # Build the simulation pipeline and overwrite the default _step implementation with it |
@@ -454,7 +454,7 @@ def build_data(self) -> SimData: |
454 | 454 | if self.mesh is None: |
455 | 455 | self.data = self.init_data(*freqs, rng_key) |
456 | 456 | else: |
457 | | - self.data = build_sharded(partial(self.init_data, *freqs), rng_key, self.mesh) |
| 457 | + self.data = build_sharded_data(partial(self.init_data, *freqs), rng_key, self.mesh) |
458 | 458 | return self.data |
459 | 459 |
|
460 | 460 | def shard(self, mesh: Mesh) -> SimData: |
|
0 commit comments