SSH scheduler AttributeError

[joasode]

I have a setup where we have two workstations where the host have ReFrame installed and the test executes on the remote using --system remote and this ReFrame config.py

site_configuration = {
  "systems": [
    {
      "name": "host",
      "descr": "Host system",
      "hostnames": [".*"],
      "partitions": [
        {
          "name": "default",
          "scheduler": "local",
          "launcher": "local",
          "environs": ["builtin"]
        }
      ]
    },
    {
      "name": "remote",
      "descr": "Remote system",
      "hostnames": [".*"],
      "partitions": [
        {
          "name": "default",
          "scheduler": "ssh",
          "sched_options": {"ssh_hosts": ['remote.host']},
          "launcher": "local",
          "access": [''],
          "environs": ["builtin"]
        }
      ]
    }  
  ],
...

The test is a RunOnlyRegressionTest that activates a Python venv and runs an executable with a file input and extracts performance from the stdout.
The Error:

  File "/home/joaso/reframe-tests/.venv/lib/python3.12/site-packages/reframe/core/schedulers/ssh.py", line 214, in _poll_job
    ferr.write(exec_proc.stderr().read())
               ^^^^^^^^^^^^^^^^^^^^^^^
AttributeError: 'str' object has no attribute 'read'

and similarly for exec_proc.stdout().read() on line 211.
Temporary fix:
Remove the .read() results in the expected behavior.

[vkarak]

Hi @joasode, thanks for reporting this! Which version of ReFrame are you on?

[joasode]

Hello, I am using ReFrame version 4.9.0. I have ended up applying this patch locally

diff --git a/reframe/core/schedulers/ssh.py b/reframe/core/schedulers/ssh.py
index 6004b0da9..7fbeef5c3 100644
--- a/reframe/core/schedulers/ssh.py
+++ b/reframe/core/schedulers/ssh.py
@@ -208,10 +208,18 @@ class SSHJobScheduler(JobScheduler):
         if exec_proc.started():
             with osext.change_dir(job.localdir):
                 with open(job.stdout, 'w+') as fout:
-                    fout.write(exec_proc.stdout().read())
+                    stdout = exec_proc.stdout()
+                    if isinstance(stdout, str):
+                        fout.write(stdout)
+                    else:
+                        fout.write(stdout.read())
 
                 with open(job.stderr, 'w+') as ferr:
-                    ferr.write(exec_proc.stderr().read())
+                    stderr = exec_proc.stderr()
+                    if isinstance(stderr, str):
+                        ferr.write(stderr)
+                    else:
+                        ferr.write(stderr.read())
 
         return True