Compare commits
8 Commits
57a370ad69
...
23a11ec102
| Author | SHA1 | Date | |
|---|---|---|---|
| 23a11ec102 | |||
| ad3c336ecf | |||
| 5c3010dcfe | |||
| 712691f3d2 | |||
| f5486f0469 | |||
| 51fca8436a | |||
| c5f6fbf7af | |||
|
|
7b02884b10 |
@@ -53,7 +53,7 @@ class Datasource:
|
|||||||
Logger.debug("CONNECT TO SERVER")
|
Logger.debug("CONNECT TO SERVER")
|
||||||
async with websockets.connect(uri) as websocket:
|
async with websockets.connect(uri) as websocket:
|
||||||
self.connection_status = "Connected"
|
self.connection_status = "Connected"
|
||||||
self.websocket = websocket
|
self.websocket = websocket
|
||||||
try:
|
try:
|
||||||
while True:
|
while True:
|
||||||
data = await websocket.recv()
|
data = await websocket.recv()
|
||||||
|
|||||||
@@ -15,7 +15,7 @@ def test_create_processed_agent_data():
|
|||||||
"user_id": 123,
|
"user_id": 123,
|
||||||
"data": [
|
"data": [
|
||||||
{
|
{
|
||||||
"road_state": "normal",
|
"road_state": "good",
|
||||||
"agent_data": {
|
"agent_data": {
|
||||||
"user_id": 999,
|
"user_id": 999,
|
||||||
"accelerometer": {
|
"accelerometer": {
|
||||||
|
|||||||
Reference in New Issue
Block a user