add non retriable error

lib/inngest/router/invoke.ex

@@ -113,6 +113,9 @@ defmodule Inngest.Router.Invoke do
           {400, error}
       end
     rescue
+      non_retry in Inngest.NonRetriableError ->
+        {400, non_retry.message}
+
       err ->
         {400, err.message}
     catch

test/support/cases/non_retry_error.ex

@@ -0,0 +1,23 @@
+defmodule Inngest.Test.Case.NonRetriableError do
+  @moduledoc false
+
+  use Inngest.Function
+  alias Inngest.{FnOpts, Trigger}
+
+  @func %FnOpts{id: "non-retry-fn", name: "Non Retriable Function"}
+  @trigger %Trigger{event: "test/plug.no-retry"}
+
+  @impl true
+  def exec(ctx, %{step: step} = _args) do
+    _success = step.run(ctx, "should-work", fn -> "foobar" end)
+
+    _fail =
+      step.run(ctx, "should-fail", fn ->
+        raise Inngest.NonRetriableError, message: "not retrying!"
+      end)
+
+    _ = step.run(ctx, "should-not-run", fn -> "yolo" end)
+
+    {:ok, "completed"}
+  end
+end