FOTA Master / Slave Patterns

import asyncio
from typing import Dict, List, Set

class Task:
    def __init__(self, ecu_id, version, deps):
        self.ecu_id=ecu_id; self.version=version; self.deps=set(deps); self.done=False

async def program(task, done_set):
    print(f"  ECU {task.ecu_id:#06x}: starting {task.version}")
    await asyncio.sleep(5)   # simulate 5s per ECU
    task.done=True; done_set.add(task.ecu_id)
    print(f"  ECU {task.ecu_id:#06x}: done")
    return True

async def orchestrate(tasks: Dict[int,"Task"]):
    done: Set[int] = set(); pending=list(tasks.values()); active={}
    while pending or active:
        for t in list(pending):
            if t.deps.issubset(done):
                pending.remove(t)
                active[t.ecu_id] = asyncio.create_task(program(t,done))
        if active:
            finished,_ = await asyncio.wait(active.values(), return_when=asyncio.FIRST_COMPLETED)
            for f in finished:
                eid=[k for k,v in active.items() if v==f][0]; del active[eid]
                if not f.result(): return False
    return True

tasks={0x10:Task(0x10,"v1.1",[]); 0x11:Task(0x11,"v1.1",[0x10]),
       0x20:Task(0x20,"v2.0",[]); 0x01:Task(0x01,"v1.5",[0x10,0x11,0x20])}
asyncio.run(orchestrate(tasks))