fix: Make master hold a queue of task data

fe17aaf9f8aee749ba752f1362c400076b499fed · 2025-07-07 20:22:00 +0100 · Arbion Halili

Files touched

M shared/types/states/master.py

Diff

commit fe17aaf9f8aee749ba752f1362c400076b499fed
Author: Arbion Halili <99731180+ToxicPine@users.noreply.github.com>
Date:   Mon Jul 7 20:22:00 2025 +0100

    fix: Make master hold a queue of task data
---
 shared/types/states/master.py | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/shared/types/states/master.py b/shared/types/states/master.py
index 09a5d584..51659334 100644
--- a/shared/types/states/master.py
+++ b/shared/types/states/master.py
@@ -24,6 +24,7 @@ from shared.types.networking.topology import (
 )
 from shared.types.profiling.common import NodePerformanceProfile
 from shared.types.states.shared import SharedState
+from shared.types.tasks.common import TaskData, TaskType
 from shared.types.worker.instances import InstanceData, InstanceId
 
 
@@ -64,8 +65,8 @@ class ControlPlaneNetworkState(State[EventCategories.ControlPlaneEventTypes]):
 class MasterState(SharedState):
     data_plane_network_state: DataPlaneNetworkState
     control_plane_network_state: ControlPlaneNetworkState
-    job_inbox: Queue[ExternalCommand]
-    job_outbox: Queue[ExternalCommand]
+    job_inbox: Queue[TaskData[TaskType]]
+    job_outbox: Queue[TaskData[TaskType]]
     cache_policy: CachePolicy[CachePolicyType]

← e1894bc1 refactor: A Lot · back to Exo · fix: Improve naming 74d56e52 →