From: Kyr Shatskyy <kyrylo.shatskyy@clyso.com>
Date: Fri, 21 Nov 2025 17:08:05 +0000 (+0100)
Subject: supervisor: reuse provided config path to run a job
X-Git-Tag: 1.3.0~5^2~3
X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=b5ea94e5fc6816b418a7dc6f8a68c79b20bec748;p=teuthology.git

supervisor: reuse provided config path to run a job

The supervisor just ignored --job-config argument when
it came to run a job and provided hard coded 'orig.config.yaml'

Signed-off-by: Kyr Shatskyy <kyrylo.shatskyy@clyso.com>
---

diff --git a/teuthology/dispatcher/supervisor.py b/teuthology/dispatcher/supervisor.py
index f3a4cb214..7f5b33eee 100644
--- a/teuthology/dispatcher/supervisor.py
+++ b/teuthology/dispatcher/supervisor.py
@@ -70,6 +70,7 @@ def main(args):
         with exporter.JobTime().time(suite=suite):
             return run_job(
                 job_config,
+                args.job_config,
                 args.bin_path,
                 args.archive_dir,
                 args.verbose
@@ -77,13 +78,18 @@ def main(args):
     else:
         return run_job(
             job_config,
+            args.job_config,
             args.bin_path,
             args.archive_dir,
             args.verbose
         )
 
 
-def run_job(job_config, teuth_bin_path, archive_dir, verbose):
+def run_job(job_config: dict,
+            job_config_path: str,
+            teuth_bin_path: str,
+            archive_dir: str,
+            verbose: bool) -> int:
     safe_archive = safepath.munge(job_config['name'])
     if job_config.get('first_in_suite') or job_config.get('last_in_suite'):
         job_archive = os.path.join(archive_dir, safe_archive)
@@ -145,8 +151,7 @@ def run_job(job_config, teuth_bin_path, archive_dir, verbose):
     ])
     if job_config['description'] is not None:
         arg.extend(['--description', job_config['description']])
-    job_archive = os.path.join(job_config['archive_path'], 'orig.config.yaml')
-    arg.extend(['--', job_archive])
+    arg.extend(['--', job_config_path])
 
     log.debug("Running: %s" % ' '.join(arg))
     p = subprocess.Popen(