dev: scheduler fcfs made dynamic, added related tests

src/algo/fcfs.cpp

@@ -73,6 +73,8 @@ void FCFS::make_decisions(double date,
            {
                 _decision->add_execute_job(pending_job->id,
                     machines, date);
+                if (broker_enabled)
+                    broker->update_status_if_dyn_job(pending_job->id, RUNNING);
 
                 // Update data structures
                 _available_machines -= machines;
@@ -100,6 +102,8 @@ void FCFS::make_decisions(double date,
         {
             // Invalid!
             _decision->add_reject_job(new_job_id, date);
+            if (broker_enabled)
+                broker->update_status_if_dyn_job(new_job_id, KILLED);
             continue;
         }
 
@@ -119,6 +123,8 @@ void FCFS::make_decisions(double date,
                 IntervalSet machines = _available_machines.left(
                     new_job->nb_requested_resources);
                 _decision->add_execute_job(new_job_id, machines, date);
+                if (broker_enabled)
+                    broker->update_status_if_dyn_job(new_job->id, RUNNING);
 
                 // Update data structures
                 _available_machines -= machines;

test/test_broker.py

 from helper import *
 
 
-def test_broker_mono(platform_monoC, workload_static, sched_mono):
-    """Test the broker mode with monocore platform files and schedulers"""
+def test_broker_mono(platform_monoC, workload_static):
+    Scheduler = namedtuple('Scheduler', ['name', 'short_name'])
+    sched_mono = Scheduler("fcfs", "fcfs")
+
+# def test_broker_mono(platform_monoC, workload_static, sched_mono):
+#     """Test the broker mode with monocore platform files and schedulers"""
 
     test_name = f'broker-{sched_mono.short_name}-{platform_monoC.name}-{workload_static.name}'
     output_dir, robin_filename, _ = init_instance(test_name)