15
15
import pybamm
16
16
17
17
18
- class generic_actor :
18
+ class GenericActor :
19
19
def __init__ (self ):
20
20
pass
21
21
@@ -121,12 +121,12 @@ def output(self):
121
121
122
122
123
123
@ray .remote (num_cpus = 1 )
124
- class ray_actor ( generic_actor ):
124
+ class RayActor ( GenericActor ):
125
125
def __init__ (self , ** kwargs ):
126
126
super ().__init__ (** kwargs )
127
127
128
128
129
- class generic_manager :
129
+ class GenericManager :
130
130
def __init__ (
131
131
self ,
132
132
):
@@ -504,7 +504,7 @@ def cleanup(self):
504
504
pass
505
505
506
506
507
- class ray_manager ( generic_manager ):
507
+ class RayManager ( GenericManager ):
508
508
def __init__ (self , ** kwargs ):
509
509
super ().__init__ (** kwargs )
510
510
lp .logger .notice ("Ray initialization started" )
@@ -526,7 +526,7 @@ def setup_actors(self, nproc, inputs, initial_soc):
526
526
# Ray setup an actor for each worker
527
527
self .actors = []
528
528
for i in range (nproc ):
529
- self .actors .append (lp .ray_actor .remote ())
529
+ self .actors .append (lp .RayActor .remote ())
530
530
setup_futures = []
531
531
for i , a in enumerate (self .actors ):
532
532
# Create actor on each worker containing a simulation
@@ -608,7 +608,7 @@ def cleanup(self):
608
608
ray .shutdown ()
609
609
610
610
611
- class casadi_manager ( generic_manager ):
611
+ class CasadiManager ( GenericManager ):
612
612
def __init__ (self , ** kwargs ):
613
613
super ().__init__ (** kwargs )
614
614
@@ -626,7 +626,7 @@ def setup_actors(self, nproc, inputs, initial_soc):
626
626
# the scenes
627
627
tic = ticker .time ()
628
628
629
- self .actors = [generic_actor ()]
629
+ self .actors = [GenericActor ()]
630
630
for a in self .actors :
631
631
a .setup (
632
632
Nspm = self .spm_per_worker ,
@@ -685,7 +685,7 @@ def cleanup(self):
685
685
pass
686
686
687
687
688
- class dask_manager ( generic_manager ):
688
+ class DaskManager ( GenericManager ):
689
689
def __init__ (self , ** kwargs ):
690
690
super ().__init__ (** kwargs )
691
691
@@ -708,7 +708,7 @@ def setup_actors(self, nproc, inputs, initial_soc):
708
708
futures = []
709
709
for i in range (nproc ):
710
710
# Create actor on each worker containing a simulation
711
- futures .append (self .client .submit (generic_actor , actor = True , pure = False ))
711
+ futures .append (self .client .submit (GenericActor , actor = True , pure = False ))
712
712
self .actors = [af .result () for af in futures ]
713
713
futures = []
714
714
for i , a in enumerate (self .actors ):
0 commit comments