#832 uploading zip for benchmark (upload failed)

core/systems/assignment/_director.ex

@@ -27,8 +27,7 @@ defmodule Systems.Assignment.Director do
   def authorization_context(tool, user) do
     {member, _} = search_subject(tool, user)
 
-    tool_ref = Workflow.Public.get_tool_ref_by_tool(tool)
-    item = Workflow.Public.get_item_by_tool_ref(tool_ref)
+    item = Workflow.Public.get_item_by_tool(tool)
     assignment = Assignment.Public.get_by_tool(tool)
 
     task =

core/systems/workflow/_public.ex

@@ -37,7 +37,7 @@ defmodule Systems.Workflow.Public do
     |> Repo.get!(id)
   end
 
-  def get_tool_ref_by_tool(%{id: id} = tool, preload \\ []) do
+  def get_item_by_tool(%{id: id} = tool, preload \\ []) do
     field = Workflow.ToolRefModel.tool_id_field(tool)
     get_item_by_tool!(field, id, preload)
   end

core/systems/workflow/_switch.ex

@@ -4,10 +4,25 @@ defmodule Systems.Workflow.Switch do
   alias Frameworks.Signal
   alias Systems.Workflow
 
+  @impl true
+  def intercept(
+        {:instruction_tool, _} = signal,
+        %{instruction_tool: tool} = message
+      ) do
+    workflow_item = Workflow.Public.get_item_by_tool(tool, [:workflow, :tool_ref])
+
+    dispatch!(
+      {:workflow_item, signal},
+      Map.merge(message, %{workflow_item: workflow_item})
+    )
+
+    :ok
+  end
+
   @impl true
   def intercept(
         {:tool_ref, _} = signal,
-        %{tool_ref: %Workflow.ToolRefModel{} = tool_ref} = message
+        %{tool_ref: tool_ref} = message
       ) do
     workflow_item = Workflow.Public.get_item_by_tool_ref(tool_ref, [:workflow, :tool_ref])