Fix paths to system config files in run_federation.py

from multiprocessing import Process, Queue

from typing import Dict, List

from .types import AmSCJob

from .types import FedJob

from .site_worker import site_worker_main

class MetaScheduler:

            p.join(timeout=5)

    # ---- policies ----

    def choose_site(self, job: AmSCJob) -> str:

    def choose_site(self, job: FedJob) -> str:

        """

        Simplest policy: choose the site with the shortest inbound queue length.

        Queue.qsize() is approximate on some platforms, but adequate for a first pass.

        self._rr += 1

        return site

    def submit(self, job: AmSCJob) -> str:

    def submit(self, job: FedJob) -> str:

        site = self.choose_site(job)

        if site is None:

            raise RuntimeError(f"choose_site() returned None; _site_list={getattr(self,'_site_list',None)}")

import uuid

@dataclass

class AmSCJob:

class FedJob:

    nodes_required: int

    wall_time_s: int

    submit_time_s: int = field(default_factory=lambda: int(time.time()))

import time

from raps.metasched.metascheduler import MetaScheduler

from raps.metasched.types import AmSCJob

from raps.metasched.types import FedJob

def main():

    sites = {

        "frontier": "configs/frontier/sim.yaml",

        "aurora": "configs/aurora/sim.yaml",

        "perlmutter": "configs/perlmutter/sim.yaml",

        "frontier": "config/frontier.yaml",

        "aurora": "config/aurora.yaml",

        "perlmutter": "config/perlmutter.yaml",

    }

    ms = MetaScheduler(sites)

    # Submit a few jobs (arrival stream)

    for i in range(10):

        job = AmSCJob(nodes_required=64, wall_time_s=3600, name=f"fed-{i}")

        job = FedJob(nodes_required=64, wall_time_s=3600, name=f"fed-{i}")

        site = ms.submit(job)

        print(f"submitted {job.job_id} -> {site}")

        time.sleep(0.2)