@@ -72,7 +72,7 @@ def _interpolate_jumpy_start(leader_jumpy, follower_jumpy):
72
72
follower_synced .iloc [1 :], follower_synced .iloc [:- 1 ])
73
73
free_follower = (set (leader_synced ["trackId" ])
74
74
== set (follower_synced ["trackId" ]))
75
- columns = ["xCenter" , "yCenter" , "speed" , "lon" , "lat" , "accel " ]
75
+ columns = ["xCenter" , "yCenter" , "speed" , "lon" , "lat" , "acc " ]
76
76
jumpy_points = []
77
77
if np .any (np .abs (covered_distance_l ) > 1 ):
78
78
jumpy_points .extend (np .where (np .abs (covered_distance_l ) > 1 )[0 ])
@@ -481,9 +481,10 @@ def _process_chunk(self, selection_data, chunk):
481
481
follower_synced .reset_index (drop = True , inplace = True )
482
482
follower_synced ["time" ] = new_time
483
483
follower_speed = np .clip (follower_synced ["speed" ].values , 0 , np .inf )
484
- follower_synced ["accel" ] = np .insert (
485
- (follower_speed [1 :] - follower_speed [:- 1 ]) / self ._timestep ,
486
- 0 , 0 , axis = 0 )
484
+ if not "acc" in follower_synced :
485
+ follower_synced ["acc" ] = np .insert (
486
+ (follower_speed [1 :] - follower_speed [:- 1 ]) / self ._timestep ,
487
+ 0 , 0 , axis = 0 )
487
488
488
489
# covered distance per vehicle
489
490
distance = (_get_distance_df (leader_synced , follower_synced )
@@ -505,9 +506,10 @@ def _process_chunk(self, selection_data, chunk):
505
506
new_speed_smooth = np .convolve (new_speed_padded , np .ones ((5 ,))/ 5 ,
506
507
mode = "valid" )
507
508
leader_synced ["speed" ] = np .clip (new_speed_smooth , 0 , np .inf )
508
- leader_synced ["accel" ] = np .insert (
509
- (new_speed_smooth [1 :] - new_speed_smooth [:- 1 ]) / self ._timestep ,
510
- 0 , 0 , axis = 0 )
509
+ if not "acc" in leader_synced :
510
+ leader_synced ["acc" ] = np .insert (
511
+ (new_speed_smooth [1 :] - new_speed_smooth [:- 1 ]) / self ._timestep ,
512
+ 0 , 0 , axis = 0 )
511
513
512
514
if leader != "" :
513
515
# distance = (_get_distance_df(leader_synced, follower_synced)
@@ -533,8 +535,8 @@ def _process_chunk(self, selection_data, chunk):
533
535
"distance" : distance ,
534
536
"speedLeader" : leader_synced ["speed" ],
535
537
"speedFollower" : follower_synced ["speed" ],
536
- "accelLeader " : leader_synced ["accel " ],
537
- "accelFollower " : follower_synced ["accel " ]})
538
+ "accLeader " : leader_synced ["acc " ],
539
+ "accFollower " : follower_synced ["acc " ]})
538
540
ground_truth ["counter" ] = counter
539
541
ground_truth ["leader" ] = leader
540
542
ground_truth ["follower" ] = follower
@@ -616,7 +618,7 @@ def _create_simulation_dataframe(self, ground_truth):
616
618
condition = prediction ["trackId" ].str .contains ("_leader" )
617
619
prediction_followers = (
618
620
prediction [~ condition ].sort_values (["time" , "counter" ])
619
- .rename (columns = {"acc" : "accelFollower " }))
621
+ .rename (columns = {"acc" : "accFollower " }))
620
622
prediction_followers = prediction_followers .rename (
621
623
columns = {"speed" : "speedFollower" })
622
624
prediction_leaders = (
@@ -627,9 +629,9 @@ def _create_simulation_dataframe(self, ground_truth):
627
629
{"coveredDistanceFollower" : "coveredDistanceLeader" ,
628
630
"LocalXFollower" : "LocalXLeader" ,
629
631
"LocalYFollower" : "LocalYLeader" ,
630
- "acc" : "accelLeader " })
632
+ "acc" : "accLeader " })
631
633
.sort_values (["time" , "counter" ])
632
- [["accelLeader " , "coveredDistanceLeader" ]]
634
+ [["accLeader " , "coveredDistanceLeader" ]]
633
635
)
634
636
prediction_followers [["accLeader" , "coveredDistanceLeader" ]] = (
635
637
prediction_leaders .values )
0 commit comments