zenon/dse-assignment
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

added timestamp to target_velocity.py

Browse Source
This commit is contained in:
Marco Zeisler 2021-06-02 22:45:23 +02:00
parent 89db75f868
commit 6f27401882
2 changed files with 9 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
components/orchestration/orchestrator.py
View File

@ -1,3 +1,4 @@
import datetime
import pickle import pickle
import sys import sys
from random import randrange from random import randrange
@ -69,7 +70,8 @@ class Orchestrator:
target_vel = randrange(0, 130) target_vel = randrange(0, 130)
print('Target velocity: {}'.format(target_vel)) print('Target velocity: {}'.format(target_vel))
response_channel.send(pickle.dumps( response_channel.send(pickle.dumps(
TargetVelocity(vin=received_daf_object.vehicle_identification_number, target_velocity=target_vel))) TargetVelocity(vin=received_daf_object.vehicle_identification_number, target_velocity=target_vel,
timestamp=datetime.datetime.now())))
def handle_tl_state_receive(self, msg): def handle_tl_state_receive(self, msg):
""" """

7
components/shared/dse_shared_libs/target_velocity.py
View File

@ -1,10 +1,15 @@
from dataclasses import dataclass from dataclasses import dataclass
from datetime import datetime
@dataclass @dataclass
class TargetVelocity: class TargetVelocity:
vin: str vin: str
target_velocity: float target_velocity: float
timestamp: datetime
def to_dict(self): def to_dict(self):
return self.__dict__ return {'vin': self.vin,
'target_velocity': self.target_velocity,
'timestamp': self.timestamp.timestamp()
}