@@ -160,18 +160,6 @@ def __create_task_data(self, rank: Rank):
160160 key = lambda x : x .get ("entity" ).get (
161161 "id" , x .get ("entity" ).get ("seq_id" )))
162162
163- @timer
164- def __find_object_rank (self , phase : Phase , obj : Object ):
165- """Determine which rank owns the object."""
166- for r in phase .get_ranks ():
167- if obj in r .get_objects ():
168- return r
169-
170- # If this point is reached the object could not be found
171- self .__logger .error (
172- f"Object id { object } cannot be located in any rank of phase { phase .get_id ()} " )
173- raise SystemExit (1 )
174-
175163 @timer
176164 def __get_communications (self , phase : Phase , rank : Rank ):
177165 """Create communication entries to be outputted to JSON."""
@@ -204,7 +192,6 @@ def __get_communications(self, phase: Phase, rank: Rank):
204192 # Retrieve communications with single sender
205193 sender_obj = sender_obj [0 ]
206194 sender_rank_id = sender_obj .get_rank_id ()
207- #sender_rank_id = self.__find_object_rank(phase, sender_obj).get_id()
208195 from_rank : Rank = [
209196 r for r in phase .get_ranks () if r .get_id () == sender_rank_id ][0 ]
210197 comm_entry ["from" ]["home" ] = sender_rank_id
@@ -225,7 +212,6 @@ def __get_communications(self, phase: Phase, rank: Rank):
225212 # Retrieve communications with single receiver
226213 receiver_obj = receiver_obj [0 ]
227214 receiver_rank_id = receiver_obj .get_rank_id ()
228- #receiver_rank_id = self.__find_object_rank(phase, receiver_obj).get_id()
229215 comm_entry ["to" ]["home" ] = receiver_rank_id
230216 to_rank : Rank = [
231217 r for r in phase .get_ranks () if receiver_obj in r .get_objects ()][0 ]
0 commit comments