diff --git a/client/src/api/schema/schema.ts b/client/src/api/schema/schema.ts
index 7eb951308e92..779417815453 100644
--- a/client/src/api/schema/schema.ts
+++ b/client/src/api/schema/schema.ts
@@ -2838,6 +2838,28 @@ export interface paths {
         patch?: never;
         trace?: never;
     };
+    "/api/jobs/{job_id}/console_output": {
+        parameters: {
+            query?: never;
+            header?: never;
+            path?: never;
+            cookie?: never;
+        };
+        /**
+         * Returns STDOUT and STDERR from the tool running in a specific job.
+         * @description Get the stdout and/or stderr from the tool running in a specific job. The position parameters are the index
+         *     of where to start reading stdout/stderr. The length parameters control how much
+         *     stdout/stderr is read.
+         */
+        get: operations["get_console_output_api_jobs__job_id__console_output_get"];
+        put?: never;
+        post?: never;
+        delete?: never;
+        options?: never;
+        head?: never;
+        patch?: never;
+        trace?: never;
+    };
     "/api/jobs/{job_id}/destination_params": {
         parameters: {
             query?: never;
@@ -12670,6 +12692,24 @@ export interface components {
              */
             update_time: string;
         };
+        /** JobConsoleOutput */
+        JobConsoleOutput: {
+            /**
+             * Job State
+             * @description The current job's state
+             */
+            state?: components["schemas"]["JobState"] | null;
+            /**
+             * STDERR
+             * @description Tool STDERR from job.
+             */
+            stderr?: string | null;
+            /**
+             * STDOUT
+             * @description Tool STDOUT from job.
+             */
+            stdout?: string | null;
+        };
         /** JobDestinationParams */
         JobDestinationParams: {
             /**
@@ -27887,6 +27927,54 @@ export interface operations {
             };
         };
     };
+    get_console_output_api_jobs__job_id__console_output_get: {
+        parameters: {
+            query: {
+                stdout_position: number;
+                stdout_length: number;
+                stderr_position: number;
+                stderr_length: number;
+            };
+            header?: {
+                /** @description The user ID that will be used to effectively make this API call. Only admins and designated users can make API calls on behalf of other users. */
+                "run-as"?: string | null;
+            };
+            path: {
+                job_id: string;
+            };
+            cookie?: never;
+        };
+        requestBody?: never;
+        responses: {
+            /** @description Successful Response */
+            200: {
+                headers: {
+                    [name: string]: unknown;
+                };
+                content: {
+                    "application/json": components["schemas"]["JobConsoleOutput"];
+                };
+            };
+            /** @description Request Error */
+            "4XX": {
+                headers: {
+                    [name: string]: unknown;
+                };
+                content: {
+                    "application/json": components["schemas"]["MessageExceptionModel"];
+                };
+            };
+            /** @description Server Error */
+            "5XX": {
+                headers: {
+                    [name: string]: unknown;
+                };
+                content: {
+                    "application/json": components["schemas"]["MessageExceptionModel"];
+                };
+            };
+        };
+    };
     destination_params_job_api_jobs__job_id__destination_params_get: {
         parameters: {
             query?: never;
diff --git a/client/src/components/JobInformation/CodeRow.vue b/client/src/components/JobInformation/CodeRow.vue
index 74d0376a429e..c016560301cc 100644
--- a/client/src/components/JobInformation/CodeRow.vue
+++ b/client/src/components/JobInformation/CodeRow.vue
@@ -1,10 +1,5 @@
 <template>
-    <tr
-        v-b-tooltip.hover
-        :title="`click to ${action}`"
-        @mousedown="mouseIsDown = true"
-        @mousemove="mouseIsDown ? (mouseMoved = true) : (mouseMoved = false)"
-        @mouseup="toggleExpanded()">
+    <tr>
         <td>
             <span v-if="helpUri">
                 <HelpText :uri="helpUri" :text="codeLabel" />
@@ -18,7 +13,13 @@
                 <b-col cols="11">
                     <pre :class="codeClass">{{ codeItem }}</pre>
                 </b-col>
-                <b-col class="nopadding pointer">
+                <b-col
+                    v-b-tooltip.hover
+                    class="nopadding pointer"
+                    :title="`click to ${action}`"
+                    @mousedown="mouseIsDown = true"
+                    @mousemove="mouseIsDown ? (mouseMoved = true) : (mouseMoved = false)"
+                    @mouseup="toggleExpanded()">
                     <FontAwesomeIcon :icon="iconClass" />
                 </b-col>
             </b-row>
@@ -48,6 +49,7 @@ export default {
             mouseIsDown: false,
             mouseMoved: false,
             expanded: false,
+            lastPos: 0,
         };
     },
     computed: {
@@ -61,6 +63,18 @@ export default {
             return this.expanded ? ["fas", "compress-alt"] : ["fas", "expand-alt"];
         },
     },
+    updated() {
+        try {
+            var codeDiv = this.$el.querySelector(".code");
+            if (codeDiv.scrollTop + codeDiv.offsetHeight >= this.lastPos - 5) {
+                // scroll is at the bottom
+                codeDiv.scrollTop = codeDiv.scrollHeight;
+            }
+            this.lastPos = codeDiv.scrollHeight;
+        } catch (exception) {
+            console.debug("Code div is not present");
+        }
+    },
     methods: {
         toggleExpanded() {
             this.mouseIsDown = false;
@@ -80,4 +94,8 @@ export default {
     padding: 0;
     margin: 0;
 }
+.code {
+    max-height: 50em;
+    overflow: auto;
+}
 </style>
diff --git a/client/src/components/JobInformation/JobInformation.test.js b/client/src/components/JobInformation/JobInformation.test.js
index 0508a6485825..68602a1b6ffd 100644
--- a/client/src/components/JobInformation/JobInformation.test.js
+++ b/client/src/components/JobInformation/JobInformation.test.js
@@ -30,6 +30,12 @@ describe("JobInformation/JobInformation.vue", () => {
             }),
             http.get("/api/invocations", ({ response }) => {
                 return response(200).json([]);
+            }),
+            http.get("/api/jobs/{job_id}/console_output", ({ response }) => {
+                return response(200).json({
+                    stdout: "stdout",
+                    stderr: "stderr",
+                });
             })
         );
     });
diff --git a/client/src/components/JobInformation/JobInformation.vue b/client/src/components/JobInformation/JobInformation.vue
index 4594f2b5e221..22871692e6fe 100644
--- a/client/src/components/JobInformation/JobInformation.vue
+++ b/client/src/components/JobInformation/JobInformation.vue
@@ -1,7 +1,7 @@
 <script setup>
 import CopyToClipboard from "components/CopyToClipboard";
 import HelpText from "components/Help/HelpText";
-import { JobDetailsProvider } from "components/providers/JobProvider";
+import { JobConsoleOutputProvider, JobDetailsProvider } from "components/providers/JobProvider";
 import UtcDate from "components/UtcDate";
 import { NON_TERMINAL_STATES } from "components/WorkflowInvocationState/util";
 import { computed, ref, watch } from "vue";
@@ -28,9 +28,21 @@ const props = defineProps({
     },
 });
 
+const stdout_length = ref(50000);
+const stdout_text = ref("");
+const stderr_length = ref(50000);
+const stderr_text = ref("");
+
+const stdout_position = computed(() => stdout_text.value.length);
+const stderr_position = computed(() => stderr_text.value.length);
+
 const runTime = computed(() => getJobDuration(job.value));
 
-const jobIsTerminal = computed(() => job.value && !NON_TERMINAL_STATES.includes(job.value.state));
+function jobStateIsTerminal(jobState) {
+    return jobState && !NON_TERMINAL_STATES.includes(job.value.state);
+}
+
+const jobIsTerminal = computed(() => jobStateIsTerminal(job?.value?.state));
 
 const routeToInvocation = computed(() => `/workflows/invocations/${invocationId.value}`);
 
@@ -41,6 +53,26 @@ const metadataDetail = ref({
 
 function updateJob(newJob) {
     job.value = newJob;
+    if (jobStateIsTerminal(newJob?.state)) {
+        if (newJob.tool_stdout) {
+            stdout_text.value = newJob.tool_stdout;
+        }
+        if (newJob.tool_stderr) {
+            stderr_text.value = newJob.tool_stderr;
+        }
+    }
+}
+
+function updateConsoleOutputs(output) {
+    // Keep stdout in memory and only fetch new text via JobProvider
+    if (output) {
+        if (output.stdout != null) {
+            stdout_text.value += output.stdout;
+        }
+        if (output.stderr != null) {
+            stderr_text.value += output.stderr;
+        }
+    }
 }
 
 function filterMetadata(jobMessages) {
@@ -94,6 +126,14 @@ watch(
 <template>
     <div>
         <JobDetailsProvider auto-refresh :job-id="props.job_id" @update:result="updateJob" />
+        <JobConsoleOutputProvider
+            auto-refresh
+            :job-id="props.job_id"
+            :stdout_position="stdout_position"
+            :stdout_length="stdout_length"
+            :stderr_position="stderr_position"
+            :stderr_length="stderr_length"
+            @update:result="updateConsoleOutputs" />
         <h2 class="h-md">Job Information</h2>
         <table id="job-information" class="tabletip info_data_table">
             <tbody>
@@ -146,13 +186,13 @@ watch(
                     id="stdout"
                     help-uri="unix.stdout"
                     :code-label="'Tool Standard Output'"
-                    :code-item="job.tool_stdout" />
+                    :code-item="stdout_text" />
                 <CodeRow
                     v-if="job"
                     id="stderr"
                     help-uri="unix.stderr"
                     :code-label="'Tool Standard Error'"
-                    :code-item="job.tool_stderr" />
+                    :code-item="stderr_text" />
                 <CodeRow
                     v-if="job && job.traceback"
                     id="traceback"
@@ -211,7 +251,6 @@ watch(
         </table>
     </div>
 </template>
-
 <style scoped>
 .tooltipJobInfo {
     text-decoration-line: underline;
diff --git a/client/src/components/providers/JobProvider.js b/client/src/components/providers/JobProvider.js
index a17b32ae24fa..0cc077d83f10 100644
--- a/client/src/components/providers/JobProvider.js
+++ b/client/src/components/providers/JobProvider.js
@@ -15,7 +15,37 @@ async function jobDetails({ jobId }) {
     }
 }
 
+async function jobConsoleOutput({
+    jobId,
+    stdout_position = 0,
+    stdout_length = 0,
+    stderr_position = 0,
+    stderr_length = 0,
+}) {
+    const url =
+        `${getAppRoot()}api/jobs/${jobId}/console_output?stdout_position=${stdout_position}&stdout_length=${stdout_length}` +
+        `&stderr_position=${stderr_position}&stderr_length=${stderr_length}`;
+    try {
+        const { status, data } = await axios.get(url, {
+            validateStatus: function (status) {
+                return status == 200 || status == 403;
+            },
+        });
+        if (status == 403) {
+            if (data.err_code == 403004) {
+                console.log("This job destination does not support console output");
+                return { state: "ok" };
+            }
+            throw Error("Problem fetching state");
+        }
+        return data;
+    } catch (e) {
+        rethrowSimple(e);
+    }
+}
+
 export const JobDetailsProvider = SingleQueryProvider(jobDetails, stateIsTerminal);
+export const JobConsoleOutputProvider = SingleQueryProvider(jobConsoleOutput, stateIsTerminal);
 
 export function jobsProvider(ctx, callback, extraParams = {}) {
     const { root, ...requestParams } = ctx;
diff --git a/lib/galaxy/jobs/runners/pulsar.py b/lib/galaxy/jobs/runners/pulsar.py
index 9cb71ab44ea4..a2bb8ff6c76b 100644
--- a/lib/galaxy/jobs/runners/pulsar.py
+++ b/lib/galaxy/jobs/runners/pulsar.py
@@ -652,6 +652,18 @@ def finish_job(self, job_state: JobState):
             remote_metadata_directory = run_results.get("metadata_directory", None)
             tool_stdout = unicodify(run_results.get("stdout", ""), strip_null=True)
             tool_stderr = unicodify(run_results.get("stderr", ""), strip_null=True)
+            for file in ("tool_stdout", "tool_stderr"):
+                if tool_stdout and tool_stderr:
+                    pass
+                try:
+                    file_path = os.path.join(job_wrapper.working_directory, "outputs", file)
+                    file_content = open(file_path)
+                    if tool_stdout is None and file == "tool_stdout":
+                        tool_stdout = file_content.read()
+                    elif tool_stderr is None and file == "tool_stderr":
+                        tool_stderr = file_content.read()
+                except Exception:
+                    pass
             job_stdout = run_results.get("job_stdout")
             job_stderr = run_results.get("job_stderr")
             exit_code = run_results.get("returncode")
diff --git a/lib/galaxy/managers/jobs.py b/lib/galaxy/managers/jobs.py
index 7031e42f1099..1ef47ff34f46 100644
--- a/lib/galaxy/managers/jobs.py
+++ b/lib/galaxy/managers/jobs.py
@@ -4,6 +4,7 @@
     date,
     datetime,
 )
+from pathlib import Path
 from typing import (
     Any,
     cast,
@@ -33,6 +34,7 @@
 
 from galaxy import model
 from galaxy.exceptions import (
+    ConfigDoesNotAllowException,
     ItemAccessibilityException,
     ObjectNotFound,
     RequestParameterInvalidException,
@@ -83,6 +85,7 @@
     defaultdict,
     ExecutionTimer,
     listify,
+    string_as_bool_or_none,
 )
 from galaxy.util.search import (
     FilteredTerm,
@@ -96,6 +99,10 @@
 JobStatesT = Union[JobStateT, List[JobStateT]]
 
 
+STDOUT_LOCATION = "outputs/tool_stdout"
+STDERR_LOCATION = "outputs/tool_stderr"
+
+
 class JobLock(BaseModel):
     active: bool = Field(title="Job lock status", description="If active, jobs will not dispatch")
 
@@ -296,6 +303,47 @@ def get_accessible_job(self, trans: ProvidesUserContext, decoded_job_id) -> Job:
         trans.sa_session.refresh(job)
         return job
 
+    def get_job_console_output(
+        self, trans, job, stdout_position=-1, stdout_length=0, stderr_position=-1, stderr_length=0
+    ):
+        if job is None:
+            raise ObjectNotFound()
+
+        # Check job destination params to see if stdout reporting is enabled
+        dest_params = job.destination_params
+        if not string_as_bool_or_none(dest_params.get("live_tool_output_reporting", False)):
+            raise ConfigDoesNotAllowException()
+
+        # If stdout_length and stdout_position are good values, then load standard out and add it to status
+        console_output = {}
+        console_output["state"] = job.state
+        if job.state == job.states.RUNNING:
+            working_directory = trans.app.object_store.get_filename(
+                job, base_dir="job_work", dir_only=True, obj_dir=True
+            )
+            if stdout_length > -1 and stdout_position > -1:
+                try:
+                    stdout_path = Path(working_directory) / STDOUT_LOCATION
+                    stdout_file = open(stdout_path)
+                    stdout_file.seek(stdout_position)
+                    console_output["stdout"] = stdout_file.read(stdout_length)
+                except Exception as e:
+                    log.error("Could not read STDOUT: %s", e)
+                    console_output["stdout"] = ""
+            if stderr_length > -1 and stderr_position > -1:
+                try:
+                    stderr_path = Path(working_directory) / STDERR_LOCATION
+                    stderr_file = open(stderr_path)
+                    stderr_file.seek(stderr_position)
+                    console_output["stderr"] = stderr_file.read(stderr_length)
+                except Exception as e:
+                    log.error("Could not read STDERR: %s", e)
+                    console_output["stderr"] = ""
+        else:
+            console_output["stdout"] = job.tool_stdout
+            console_output["stderr"] = job.tool_stderr
+        return console_output
+
     def stop(self, job, message=None):
         if not job.finished:
             job.mark_deleted(self.app.config.track_jobs_in_database)
diff --git a/lib/galaxy/schema/jobs.py b/lib/galaxy/schema/jobs.py
index 44cc5061619c..fbca9e281a2d 100644
--- a/lib/galaxy/schema/jobs.py
+++ b/lib/galaxy/schema/jobs.py
@@ -213,6 +213,12 @@ class JobOutput(Model):
     value: EncodedDataItemSourceId = Field(default=..., title="Dataset", description="The associated dataset.")
 
 
+class JobConsoleOutput(Model):
+    state: Optional[JobState] = Field(None, title="Job State", description="The current job's state")
+    stdout: Optional[str] = Field(None, title="STDOUT", description="Tool STDOUT from job.")
+    stderr: Optional[str] = Field(None, title="STDERR", description="Tool STDERR from job.")
+
+
 class JobParameter(Model):
     text: str = Field(
         default=...,
diff --git a/lib/galaxy/webapps/galaxy/api/job_files.py b/lib/galaxy/webapps/galaxy/api/job_files.py
index 3bae6d62d137..3d02ccfcf7be 100644
--- a/lib/galaxy/webapps/galaxy/api/job_files.py
+++ b/lib/galaxy/webapps/galaxy/api/job_files.py
@@ -133,7 +133,11 @@ def create(self, trans, job_id, payload, **kwargs):
         target_dir = os.path.dirname(path)
         util.safe_makedirs(target_dir)
         try:
-            shutil.move(input_file.name, path)
+            if os.path.exists(path) and (path.endswith("tool_stdout") or path.endswith("tool_stderr")):
+                with open(path, "ab") as destination:
+                    shutil.copyfileobj(open(input_file.name, "rb"), destination)
+            else:
+                shutil.move(input_file.name, path)
         finally:
             try:
                 input_file.close()
diff --git a/lib/galaxy/webapps/galaxy/api/jobs.py b/lib/galaxy/webapps/galaxy/api/jobs.py
index 9eb5efb40938..4c0c27169459 100644
--- a/lib/galaxy/webapps/galaxy/api/jobs.py
+++ b/lib/galaxy/webapps/galaxy/api/jobs.py
@@ -38,6 +38,7 @@
 from galaxy.schema.jobs import (
     DeleteJobPayload,
     EncodedJobDetails,
+    JobConsoleOutput,
     JobDestinationParams,
     JobDisplayParametersSummary,
     JobErrorSummary,
@@ -369,6 +370,36 @@ def outputs(
             output_associations.append(JobOutputAssociation(name=association.name, dataset=association.dataset))
         return output_associations
 
+    @router.get(
+        "/api/jobs/{job_id}/console_output",
+        name="get_console_output",
+        summary="Returns STDOUT and STDERR from the tool running in a specific job.",
+    )
+    def console_output(
+        self,
+        job_id: Annotated[DecodedDatabaseIdField, JobIdPathParam],
+        stdout_position: int,
+        stdout_length: int,
+        stderr_position: int,
+        stderr_length: int,
+        trans: ProvidesUserContext = DependsOnTrans,
+    ) -> JobConsoleOutput:
+        """
+        Get the stdout and/or stderr from the tool running in a specific job. The position parameters are the index
+        of where to start reading stdout/stderr. The length parameters control how much
+        stdout/stderr is read.
+        """
+        job = self.service.get_job(trans, job_id)
+        output = self.service.job_manager.get_job_console_output(
+            trans,
+            job,
+            int(stdout_position),
+            int(stdout_length),
+            int(stderr_position),
+            int(stderr_length),
+        )
+        return JobConsoleOutput(state=output["state"], stdout=output["stdout"], stderr=output["stderr"])
+
     @router.get(
         "/api/jobs/{job_id}/parameters_display",
         name="resolve_parameters_display",
diff --git a/lib/galaxy/webapps/galaxy/services/jobs.py b/lib/galaxy/webapps/galaxy/services/jobs.py
index 5c39175567bf..c90b50068cc2 100644
--- a/lib/galaxy/webapps/galaxy/services/jobs.py
+++ b/lib/galaxy/webapps/galaxy/services/jobs.py
@@ -58,7 +58,10 @@ def show(
         id: DecodedDatabaseIdField,
         full: bool = False,
     ) -> Dict[str, Any]:
-        job = self.job_manager.get_accessible_job(trans, id)
+        job = self.job_manager.get_accessible_job(
+            trans,
+            id,
+        )
         return view_show_job(trans, job, bool(full))
 
     def index(