Extract functionality from k8s runner for reuse.

Author: jmchilton

lib/galaxy/jobs/runners/__init__.py

@@ -817,6 +817,13 @@ def register_cleanup_file_attribute(self, attribute):
         if attribute not in self.cleanup_file_attributes:
             self.cleanup_file_attributes.append(attribute)
 
+    def init_job_stream_files(self):
+        """For runners that don't create explicit job scripts - create job stream files."""
+        with open(self.output_file, "w"):
+            pass
+        with open(self.error_file, "w"):
+            pass
+
 
 class AsynchronousJobRunner(BaseJobRunner, Monitors):
     """Parent class for any job runner that runs jobs asynchronously (e.g. via

lib/galaxy/jobs/runners/kubernetes.py

@@ -172,12 +172,8 @@ def queue_job(self, job_wrapper):
             job_wrapper=job_wrapper,
             job_destination=job_wrapper.job_destination,
         )
-        # Kubernetes doesn't really produce meaningful "job stdout", but file needs to be present
-        with open(ajs.output_file, "w"):
-            pass
-        with open(ajs.error_file, "w"):
-            pass
-
+        # Kubernetes doesn't really produce a "job script", but job stream files needs to be present
+        ajs.init_job_stream_files()
         if not self.prepare_job(
             job_wrapper,
             include_metadata=False,