gitea_admin/sientia-dataops-orchestrator_temporal
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: update server_name to server_id in predictions batch test

Browse Source
This commit is contained in:
vitor-aignosi
2025-06-10 13:06:13 -03:00
parent 5e2634f062
commit 0a612f6a5b
2 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
tests/orchestrator/activities/test_slot_manager.py
View File

@@ -76,7 +76,7 @@ async def test_load_opc_slots_no_decode(slot_manager):
@mark.asyncio
async def test_load_active_ingestors(slot_manager):
slot_manager.redis_client.keys.return_value = [
b"heartbeat:ingestor:1", b"heartbeat:ingestor:2", b"heartbeat:ingestor:3"]
b"heartbeat:ingestor:1", b"heartbeat:ingestor:2", "heartbeat:ingestor:3"]
response = await slot_manager.load_active_ingestors()

6
tests/orchestrator/utils/test_orchestrator_functions.py
View File

@@ -139,12 +139,12 @@ def test_predictions_batch(mock_process_path_priority,
"query": "test_query",
"write_tags": [
{
"server_name": "test_server_name",
"server_id": "test_server_id",
"type": "prediction",
"addr": "test_addr"
},
{
"server_name": "test_server_name",
"server_id": "test_server_id",
"type": "confidence",
"addr": "test_addr"
}
@@ -210,7 +210,7 @@ def test_predictions_batch(mock_process_path_priority,
"table_name": "predictions",
"retention_time": 60 * 60,
"opc_output_config": {
"test_server_name": {
"test_server_id": {
"prediction_tags": {
"test_addr": {
"data_type": "float"