diff --git a/client/src/api/schema/schema.ts b/client/src/api/schema/schema.ts
index da570d61fdf5..02a3c86bc6fd 100644
--- a/client/src/api/schema/schema.ts
+++ b/client/src/api/schema/schema.ts
@@ -8394,6 +8394,11 @@ export interface components {
              * @default false
              */
             use_cached_job?: boolean | null;
+            /**
+             * Version
+             * @description The version of the workflow to invoke.
+             */
+            version?: number | null;
         };
         /**
          * ItemTagsCreatePayload
diff --git a/client/src/components/Workflow/Editor/Index.vue b/client/src/components/Workflow/Editor/Index.vue
index a3ffdf9873a0..ffb07080dc1f 100644
--- a/client/src/components/Workflow/Editor/Index.vue
+++ b/client/src/components/Workflow/Editor/Index.vue
@@ -774,7 +774,9 @@ export default {
             this.report.markdown = markdown;
         },
         onRun() {
-            const runUrl = `/workflows/run?id=${this.id}`;
+            const runUrl = `/workflows/run?id=${this.id}${
+                this.version !== undefined ? `&version=${this.version}` : ""
+            }`;
             this.onNavigate(runUrl);
         },
         async onNavigate(url, forceSave = false, ignoreChanges = false) {
diff --git a/client/src/components/Workflow/Run/WorkflowRun.vue b/client/src/components/Workflow/Run/WorkflowRun.vue
index 91b338323ad9..fbf47ec93a9d 100644
--- a/client/src/components/Workflow/Run/WorkflowRun.vue
+++ b/client/src/components/Workflow/Run/WorkflowRun.vue
@@ -27,12 +27,14 @@ const router = useRouter();
 
 interface Props {
     workflowId: string;
+    version?: string;
     preferSimpleForm?: boolean;
     simpleFormTargetHistory?: string;
     simpleFormUseJobCache?: boolean;
 }
 
 const props = withDefaults(defineProps<Props>(), {
+    version: undefined,
     preferSimpleForm: false,
     simpleFormTargetHistory: "current",
     simpleFormUseJobCache: false,
@@ -49,7 +51,9 @@ const workflowName = ref("");
 const workflowModel: any = ref(null);
 
 const currentHistoryId = computed(() => historyStore.currentHistoryId);
-const editorLink = computed(() => `/workflows/edit?id=${props.workflowId}`);
+const editorLink = computed(
+    () => `/workflows/edit?id=${props.workflowId}${props.version ? `&version=${props.version}` : ""}`
+);
 const historyStatusKey = computed(() => `${currentHistoryId.value}_${lastUpdateTime.value}`);
 const isOwner = computed(() => currentUser.value?.username === workflowModel.value.runData.owner);
 const lastUpdateTime = computed(() => historyItemsStore.lastUpdateTime);
@@ -74,7 +78,7 @@ function handleSubmissionError(error: string) {
 }
 
 function loadRun() {
-    getRunData(props.workflowId)
+    getRunData(props.workflowId, props.version || undefined)
         .then((runData) => {
             const incomingModel = new WorkflowRunModel(runData);
             simpleForm.value = props.preferSimpleForm;
@@ -116,7 +120,7 @@ function loadRun() {
 }
 
 async function onImport() {
-    const response = await copyWorkflow(props.workflowId, workflowModel.value.runData.owner);
+    const response = await copyWorkflow(props.workflowId, workflowModel.value.runData.owner, props.version);
     router.push(`/workflows/edit?id=${response.id}`);
 }
 
diff --git a/client/src/components/Workflow/Run/WorkflowRunForm.vue b/client/src/components/Workflow/Run/WorkflowRunForm.vue
index 2627554e526f..6b23e8895ea0 100644
--- a/client/src/components/Workflow/Run/WorkflowRunForm.vue
+++ b/client/src/components/Workflow/Run/WorkflowRunForm.vue
@@ -7,7 +7,7 @@
             </span>
         </BAlert>
         <div class="h4 clearfix mb-3">
-            <b>Workflow: {{ model.name }}</b>
+            <b>Workflow: {{ model.name }}</b> <i>(version: {{ model.runData.version + 1 }})</i>
             <ButtonSpinner
                 id="run-workflow"
                 class="float-right"
@@ -231,6 +231,7 @@ export default {
                 // the user is already warned if tool versions are wrong,
                 // they can still choose to invoke the workflow anyway.
                 require_exact_tool_versions: false,
+                version: this.model.runData.version,
             };
 
             console.debug("WorkflowRunForm::onExecute()", "Ready for submission.", jobDef);
diff --git a/client/src/components/Workflow/Run/WorkflowRunFormSimple.vue b/client/src/components/Workflow/Run/WorkflowRunFormSimple.vue
index 8296b9b7faa3..e7e45723ff16 100644
--- a/client/src/components/Workflow/Run/WorkflowRunFormSimple.vue
+++ b/client/src/components/Workflow/Run/WorkflowRunFormSimple.vue
@@ -7,7 +7,7 @@
                     or send the results to a new one using the run settings ⚙️
                 </span>
             </BAlert>
-            <b>Workflow: {{ model.name }}</b>
+            <b>Workflow: {{ model.name }}</b> <i>(version: {{ model.runData.version + 1 }})</i>
             <ButtonSpinner
                 id="run-workflow"
                 :wait="waitingForRequest"
@@ -200,6 +200,7 @@ export default {
                 batch: true,
                 use_cached_job: this.useCachedJobs,
                 require_exact_tool_versions: false,
+                version: this.model.runData.version,
             };
             if (this.sendToNewHistory) {
                 data.new_history_name = this.model.name;
diff --git a/client/src/components/Workflow/Run/services.js b/client/src/components/Workflow/Run/services.js
index 192198436bd7..c6c841a09a79 100644
--- a/client/src/components/Workflow/Run/services.js
+++ b/client/src/components/Workflow/Run/services.js
@@ -10,9 +10,13 @@ import { rethrowSimple } from "utils/simple-error";
  * for implementation). This contains the data needed to render the UI for workflows.
  *
  * @param {String} workflowId - (Stored?) Workflow ID to fetch data for.
+ * @param {String} version - Version of the workflow to fetch.
  */
-export async function getRunData(workflowId) {
-    const url = `${getAppRoot()}api/workflows/${workflowId}/download?style=run`;
+export async function getRunData(workflowId, version = null) {
+    let url = `${getAppRoot()}api/workflows/${workflowId}/download?style=run`;
+    if (version) {
+        url += `&version=${version}`;
+    }
     try {
         const response = await axios.get(url);
         return response.data;
diff --git a/client/src/components/Workflow/WorkflowRunButton.vue b/client/src/components/Workflow/WorkflowRunButton.vue
index 461d37524c24..2b1957246cae 100644
--- a/client/src/components/Workflow/WorkflowRunButton.vue
+++ b/client/src/components/Workflow/WorkflowRunButton.vue
@@ -3,6 +3,7 @@ import { library } from "@fortawesome/fontawesome-svg-core";
 import { faPlay } from "@fortawesome/free-solid-svg-icons";
 import { FontAwesomeIcon } from "@fortawesome/vue-fontawesome";
 import { BButton } from "bootstrap-vue";
+import { computed } from "vue";
 
 library.add(faPlay);
 
@@ -11,9 +12,14 @@ interface Props {
     full?: boolean;
     title?: string;
     disabled?: boolean;
+    version?: number;
 }
 
-defineProps<Props>();
+const props = defineProps<Props>();
+
+const runPath = computed(
+    () => `/workflows/run?id=${props.id}${props.version !== undefined ? `&version=${props.version}` : ""}`
+);
 </script>
 
 <template>
@@ -25,7 +31,7 @@ defineProps<Props>();
         variant="primary"
         size="sm"
         :disabled="disabled"
-        :to="`/workflows/run?id=${id}`">
+        :to="runPath">
         <FontAwesomeIcon :icon="faPlay" fixed-width />
 
         <span v-if="full" v-localize>Run</span>
diff --git a/client/src/components/Workflow/workflows.services.ts b/client/src/components/Workflow/workflows.services.ts
index 2eb5b113ad47..e0c9c7d328c9 100644
--- a/client/src/components/Workflow/workflows.services.ts
+++ b/client/src/components/Workflow/workflows.services.ts
@@ -45,8 +45,12 @@ export async function updateWorkflow(id: string, changes: object): Promise<Workf
     return data;
 }
 
-export async function copyWorkflow(id: string, currentOwner: string): Promise<Workflow> {
-    const { data: workflowData } = await axios.get(withPrefix(`/api/workflows/${id}/download`));
+export async function copyWorkflow(id: string, currentOwner: string, version?: string): Promise<Workflow> {
+    let path = `/api/workflows/${id}/download`;
+    if (version) {
+        path += `?version=${version}`;
+    }
+    const { data: workflowData } = await axios.get(withPrefix(path));
 
     workflowData.name = `Copy of ${workflowData.name}`;
     const currentUsername = useUserStore().currentUser?.username;
diff --git a/client/src/components/WorkflowInvocationState/WorkflowInvocationState.vue b/client/src/components/WorkflowInvocationState/WorkflowInvocationState.vue
index 6620c5786f36..c71970e3691c 100644
--- a/client/src/components/WorkflowInvocationState/WorkflowInvocationState.vue
+++ b/client/src/components/WorkflowInvocationState/WorkflowInvocationState.vue
@@ -206,7 +206,7 @@ function getWorkflowName() {
                         size="sm"
                         variant="secondary"
                         :disabled="isDeletedWorkflow"
-                        :to="`/workflows/edit?id=${getWorkflowId()}`">
+                        :to="`/workflows/edit?id=${getWorkflowId()}&version=${workflowVersion}`">
                         <FontAwesomeIcon :icon="faEdit" />
                         <span v-localize>Edit</span>
                     </BButton>
@@ -218,7 +218,8 @@ function getWorkflowName() {
                                 : 'This workflow has been deleted.'
                         "
                         :disabled="isDeletedWorkflow"
-                        full />
+                        full
+                        :version="workflowVersion" />
                 </BButtonGroup>
             </div>
         </div>
diff --git a/client/src/entry/analysis/modules/Home.vue b/client/src/entry/analysis/modules/Home.vue
index dfc4432e008b..ecb9a82ac3f9 100644
--- a/client/src/entry/analysis/modules/Home.vue
+++ b/client/src/entry/analysis/modules/Home.vue
@@ -59,6 +59,7 @@ export default {
         },
         workflowParams() {
             const workflowId = this.query.workflow_id;
+            const version = this.query.version;
             let preferSimpleForm = this.config.simplified_workflow_run_ui == "prefer";
             const preferSimpleFormOverride = this.query.simplified_workflow_run_ui;
             if (preferSimpleFormOverride == "prefer") {
@@ -68,6 +69,7 @@ export default {
             const simpleFormUseJobCache = this.config.simplified_workflow_run_ui_job_cache == "on";
             return {
                 workflowId,
+                version,
                 preferSimpleForm,
                 simpleFormTargetHistory,
                 simpleFormUseJobCache,
diff --git a/client/src/entry/analysis/modules/WorkflowEditor.vue b/client/src/entry/analysis/modules/WorkflowEditor.vue
index 9ed4b55b3b9c..fb8ed6eea9d5 100644
--- a/client/src/entry/analysis/modules/WorkflowEditor.vue
+++ b/client/src/entry/analysis/modules/WorkflowEditor.vue
@@ -23,6 +23,7 @@ export default {
         return {
             storedWorkflowId: null,
             workflowId: null,
+            version: null,
             editorConfig: null,
             editorReloadKey: 0,
         };
@@ -46,6 +47,7 @@ export default {
 
             this.storedWorkflowId = Query.get("id");
             this.workflowId = Query.get("workflow_id");
+            this.version = Query.get("version");
 
             const params = {};
 
@@ -54,6 +56,9 @@ export default {
             } else if (this.storedWorkflowId) {
                 params.id = this.storedWorkflowId;
             }
+            if (this.version) {
+                params.version = this.version;
+            }
 
             this.editorConfig = await urlData({ url: "/workflow/editor", params });
 
diff --git a/client/src/entry/analysis/router.js b/client/src/entry/analysis/router.js
index 8f5772ea37c1..3b54544af220 100644
--- a/client/src/entry/analysis/router.js
+++ b/client/src/entry/analysis/router.js
@@ -653,7 +653,10 @@ export function getRouter(Galaxy) {
                         redirect: redirectAnon(),
                         props: (route) => ({
                             config: Galaxy.config,
-                            query: { workflow_id: route.query.id },
+                            query: {
+                                workflow_id: route.query.id,
+                                version: route.query.version,
+                            },
                         }),
                     },
                     {
diff --git a/lib/galaxy/jobs/runners/pulsar.py b/lib/galaxy/jobs/runners/pulsar.py
index 634e20675440..556d049f0b9d 100644
--- a/lib/galaxy/jobs/runners/pulsar.py
+++ b/lib/galaxy/jobs/runners/pulsar.py
@@ -322,7 +322,12 @@ def check_watched_item_state(self, job_state):
 
     def _update_job_state_for_status(self, job_state, pulsar_status, full_status=None):
         log.debug("(%s) Received status update: %s", job_state.job_id, pulsar_status)
-        if pulsar_status in ["complete", "cancelled"] or job_state.job_wrapper.get_state() == model.Job.states.STOPPED:
+        if pulsar_status in ["complete", "cancelled"]:
+            self.mark_as_finished(job_state)
+            return None
+        if job_state.job_wrapper.get_state() == model.Job.states.STOPPED:
+            client = self.get_client_from_state(job_state)
+            client.kill()
             self.mark_as_finished(job_state)
             return None
         if pulsar_status in ["failed", "lost"]:
diff --git a/lib/galaxy/managers/users.py b/lib/galaxy/managers/users.py
index 5ebaa450789b..820354bb8857 100644
--- a/lib/galaxy/managers/users.py
+++ b/lib/galaxy/managers/users.py
@@ -200,7 +200,7 @@ def purge(self, user, flush=True):
         private_role = self.app.security_agent.get_private_user_role(user)
         if private_role is None:
             raise exceptions.InconsistentDatabase(
-                "User '%s' private role is missing while attempting to purge deleted user." % user.email
+                f"User {user.email} private role is missing while attempting to purge deleted user."
             )
         # Delete History
         for active_history in user.active_histories:
@@ -667,23 +667,11 @@ def get_or_create_remote_user(self, remote_user_email):
                     self.app.security_agent.user_set_default_permissions(user)
                     self.app.security_agent.user_set_default_permissions(user, history=True, dataset=True)
         elif user is None:
-            username = remote_user_email.split("@", 1)[0].lower()
             random.seed()
             user = self.app.model.User(email=remote_user_email)
             user.set_random_password(length=12)
             user.external = True
-            # Replace invalid characters in the username
-            for char in [x for x in username if x not in f"{string.ascii_lowercase + string.digits}-."]:
-                username = username.replace(char, "-")
-            # Find a unique username - user can change it later
-            stmt = select(self.app.model.User).filter_by(username=username).limit(1)
-            if self.session().scalars(stmt).first():
-                i = 1
-                stmt = select(self.app.model.User).filter_by(username=f"{username}-{str(i)}").limit(1)
-                while self.session().scalars(stmt).first():
-                    i += 1
-                username += f"-{str(i)}"
-            user.username = username
+            user.username = username_from_email(self.session(), remote_user_email, self.app.model.User)
             self.session().add(user)
             with transaction(self.session()):
                 self.session().commit()
@@ -877,3 +865,31 @@ def _add_parsers(self):
         )
 
         self.fn_filter_parsers.update({})
+
+
+def username_from_email(session, email, model_class=User):
+    """Get next available username generated based on email"""
+    username = email.split("@", 1)[0].lower()
+    username = filter_out_invalid_username_characters(username)
+    if username_exists(session, username, model_class):
+        username = generate_next_available_username(session, username, model_class)
+    return username
+
+
+def filter_out_invalid_username_characters(username):
+    """Replace invalid characters in username"""
+    for char in [x for x in username if x not in f"{string.ascii_lowercase + string.digits}-."]:
+        username = username.replace(char, "-")
+    return username
+
+
+def username_exists(session, username: str, model_class=User):
+    return bool(get_user_by_username(session, username, model_class))
+
+
+def generate_next_available_username(session, username, model_class=User):
+    """Generate unique username; user can change it later"""
+    i = 1
+    while session.execute(select(model_class).where(model_class.username == f"{username}-{i}")).first():
+        i += 1
+    return f"{username}-{i}"
diff --git a/lib/galaxy/managers/workflows.py b/lib/galaxy/managers/workflows.py
index 35089bc5e4a3..7f57f698e5f2 100644
--- a/lib/galaxy/managers/workflows.py
+++ b/lib/galaxy/managers/workflows.py
@@ -919,6 +919,9 @@ def to_format_2(wf_dict, **kwds):
             raise exceptions.RequestParameterInvalidException(f"Unknown workflow style {style}")
         if version is not None:
             wf_dict["version"] = version
+            # If returning a run-form workflow for a specific version, use that version's name
+            if style == "run":
+                wf_dict["name"] = workflow.name
         else:
             wf_dict["version"] = len(stored.workflows) - 1
         return wf_dict
diff --git a/lib/galaxy/model/migrations/alembic/versions_gxy/c63848676caf_update_username_column_schema_and_data.py b/lib/galaxy/model/migrations/alembic/versions_gxy/c63848676caf_update_username_column_schema_and_data.py
new file mode 100644
index 000000000000..bd43e53bd443
--- /dev/null
+++ b/lib/galaxy/model/migrations/alembic/versions_gxy/c63848676caf_update_username_column_schema_and_data.py
@@ -0,0 +1,89 @@
+"""Update username column schema and data
+
+Revision ID: c63848676caf
+Revises: c14a3c93d66b
+Create Date: 2024-06-11 13:41:36.411803
+
+"""
+
+import string
+
+from alembic import op
+from sqlalchemy import (
+    or_,
+    select,
+    update,
+)
+
+from galaxy.model import User
+from galaxy.model.migrations.util import (
+    alter_column,
+    transaction,
+)
+
+# revision identifiers, used by Alembic.
+revision = "c63848676caf"
+down_revision = "c14a3c93d66b"
+branch_labels = None
+depends_on = None
+
+table_name = "galaxy_user"
+column_name = "username"
+
+
+def upgrade():
+    with transaction():
+        _generate_missing_usernames()
+        alter_column(table_name, column_name, nullable=False)
+
+
+def downgrade():
+    with transaction():
+        # The data migration is one-way: we can change back the database schema,
+        # but we can't remove the generated username values.
+        alter_column(table_name, column_name, nullable=True)
+
+
+def _generate_missing_usernames():
+    stmt = select(User.id, User.email).where(or_(User.username.is_(None), User.username == ""))
+    connection = op.get_bind()
+    users = connection.execute(stmt).all()
+    for id, email in users:
+        new_username = username_from_email(connection, email)
+        update_stmt = update(User).where(User.id == id).values(username=new_username)
+        connection.execute(update_stmt)
+
+
+# The code below is a near-duplicate of similar code in managers.users. The duplication is
+# intentional: we want to preserve this logic in the migration script. The only differences are:
+# (1) this code uses a Connection instead of a Session;
+# (2) the username_exists function inlines the Select statement from managers.users::get_user_by_username.
+
+
+def username_from_email(connection, email, model_class=User):
+    # This function is also called from database revision scripts, which do not provide a session.
+    username = email.split("@", 1)[0].lower()
+    username = filter_out_invalid_username_characters(username)
+    if username_exists(connection, username, model_class):
+        username = generate_next_available_username(connection, username, model_class)
+    return username
+
+
+def filter_out_invalid_username_characters(username):
+    """Replace invalid characters in username"""
+    for char in [x for x in username if x not in f"{string.ascii_lowercase + string.digits}-."]:
+        username = username.replace(char, "-")
+    return username
+
+
+def username_exists(connection, username: str, model_class=User):
+    stmt = select(model_class).filter(model_class.username == username).limit(1)
+    return bool(connection.execute(stmt).first())
+
+
+def generate_next_available_username(connection, username, model_class=User):
+    """Generate unique username; user can change it later"""
+    i = 1
+    while connection.execute(select(model_class).where(model_class.username == f"{username}-{i}")).first():
+        i += 1
+    return f"{username}-{i}"
diff --git a/lib/galaxy/model/migrations/alembic/versions_gxy/ddbdbc40bdc1_add_workflow_comment_table.py b/lib/galaxy/model/migrations/alembic/versions_gxy/ddbdbc40bdc1_add_workflow_comment_table.py
index b0cfac349b77..8b2fd0b23efa 100644
--- a/lib/galaxy/model/migrations/alembic/versions_gxy/ddbdbc40bdc1_add_workflow_comment_table.py
+++ b/lib/galaxy/model/migrations/alembic/versions_gxy/ddbdbc40bdc1_add_workflow_comment_table.py
@@ -1,4 +1,5 @@
 """add workflow_comment table
+
 Revision ID: ddbdbc40bdc1
 Revises: 92fb564c7095
 Create Date: 2023-08-14 13:41:59.442243
diff --git a/lib/galaxy/model/migrations/alembic/versions_gxy/eee9229a9765_.py b/lib/galaxy/model/migrations/alembic/versions_gxy/eee9229a9765_.py
new file mode 100644
index 000000000000..46eb08793c9a
--- /dev/null
+++ b/lib/galaxy/model/migrations/alembic/versions_gxy/eee9229a9765_.py
@@ -0,0 +1,21 @@
+"""Merge 2 head revisions after pulling 24.1 into dev
+
+Revision ID: eee9229a9765
+Revises: 570bce1e82f9, c63848676caf
+Create Date: 2024-06-13 11:50:03.226676
+
+"""
+
+# revision identifiers, used by Alembic.
+revision = "eee9229a9765"
+down_revision = ("570bce1e82f9", "c63848676caf")
+branch_labels = None
+depends_on = None
+
+
+def upgrade():
+    pass
+
+
+def downgrade():
+    pass
diff --git a/lib/galaxy/model/migrations/dbscript.py b/lib/galaxy/model/migrations/dbscript.py
index 58d83755e777..2e17c361d4f6 100644
--- a/lib/galaxy/model/migrations/dbscript.py
+++ b/lib/galaxy/model/migrations/dbscript.py
@@ -42,8 +42,8 @@
     "23.2": "8a19186a6ee7",
     "release_24.0": "55f02fd8ab6c",
     "24.0": "55f02fd8ab6c",
-    "release_24.1": "c14a3c93d66b",
-    "24.1": "c14a3c93d66b",
+    "release_24.1": "c63848676caf",
+    "24.1": "c63848676caf",
 }
 
 
diff --git a/lib/galaxy/schema/workflows.py b/lib/galaxy/schema/workflows.py
index cbc5379e49e6..f679fd47818d 100644
--- a/lib/galaxy/schema/workflows.py
+++ b/lib/galaxy/schema/workflows.py
@@ -53,6 +53,11 @@ class GetTargetHistoryPayload(Model):
 
 class InvokeWorkflowPayload(GetTargetHistoryPayload):
     # TODO - Are the descriptions correct?
+    version: Optional[int] = Field(
+        None,
+        title="Version",
+        description="The version of the workflow to invoke.",
+    )
     instance: Optional[bool] = Field(
         False,
         title="Is instance",
diff --git a/lib/galaxy/tools/__init__.py b/lib/galaxy/tools/__init__.py
index 9864f0ec58d4..680f26db1824 100644
--- a/lib/galaxy/tools/__init__.py
+++ b/lib/galaxy/tools/__init__.py
@@ -3236,7 +3236,9 @@ def check_dataset_state(state):
                     )
 
         for input_dataset in input_datasets.values():
-            check_dataset_state(input_dataset.state)
+            if input_dataset:
+                # None is a possible input for optional inputs
+                check_dataset_state(input_dataset.state)
 
         for input_dataset_collection_pairs in input_dataset_collections.values():
             for input_dataset_collection, _ in input_dataset_collection_pairs:
diff --git a/lib/galaxy/tools/build_list_1.2.0.xml b/lib/galaxy/tools/build_list_1.2.0.xml
index 78eec798044e..457ae2b471da 100644
--- a/lib/galaxy/tools/build_list_1.2.0.xml
+++ b/lib/galaxy/tools/build_list_1.2.0.xml
@@ -44,7 +44,7 @@ Description
 
 This tool combines individual datasets or collections into a new collection. The simplest scenario is building a new colection from individual datasets (case **A** in the image below). You can merge a collection with individual dataset(s). In this case (see **B** in the image below) the individual dataset(s) will be merged with each element of the input collection to create a nested collection. Finally, two or more collection can be merged together creating a nested collection (case **C** in the image below).
 
-.. class:: warningmark 
+.. class:: warningmark
 
 **Note**: When merging collections (e.g., case **C** below) the input collection **must** have equal number of elements.
 
@@ -77,6 +77,7 @@ This tool will create a new collection from your history datasets but your quota
     </test>
     <test>
       <repeat name="datasets">
+        <param name="input" value_json="null"/>
       </repeat>
       <output_collection name="output" type="list" count="0">
       </output_collection>
diff --git a/lib/galaxy/webapps/galaxy/services/workflows.py b/lib/galaxy/webapps/galaxy/services/workflows.py
index 570ad4fb1518..72414b169abf 100644
--- a/lib/galaxy/webapps/galaxy/services/workflows.py
+++ b/lib/galaxy/webapps/galaxy/services/workflows.py
@@ -130,7 +130,8 @@ def invoke_workflow(
         # Get workflow + accessibility check.
         by_stored_id = not payload.instance
         stored_workflow = self._workflows_manager.get_stored_accessible_workflow(trans, workflow_id, by_stored_id)
-        workflow = stored_workflow.latest_workflow
+        version = payload.version
+        workflow = stored_workflow.get_internal_version(version)
         run_configs = build_workflow_run_configs(trans, workflow, payload.model_dump(exclude_unset=True))
         is_batch = payload.batch
         if not is_batch and len(run_configs) != 1: