Packages

condukt

0.21.0
1.7.0 1.6.3 1.6.2 1.6.1 1.6.0 1.5.1 1.5.0 1.4.1 1.4.0 1.3.0 1.2.1 1.2.0 1.1.0 1.0.0 0.21.0 0.20.0 0.19.0 0.18.0 0.17.0 0.16.6 0.16.5 0.16.4 0.16.3 0.16.2 0.16.1 0.16.0 0.15.1 0.15.0 0.14.2 0.14.1 0.14.0 0.13.1 0.13.0 0.12.0 0.11.0 0.10.0 0.9.0 0.8.0 0.7.2 0.7.1 0.7.0 0.6.1 0.6.0 0.5.0

A framework for building AI agents in Elixir

HexDocs

Current section

Files

Jump to
Readme
44 Versions
11 Dependencies
Dependants
Files
Activity
condukt lib mix tasks condukt.workflows.run.ex
Raw

lib/mix/tasks/condukt.workflows.run.ex 

defmodule Mix.Tasks.Condukt.Workflows.Run do

  @shortdoc "Runs a Condukt workflow"



  @moduledoc """

  Runs one Condukt workflow from a project.

  """



  use Mix.Task



  alias Condukt.Workflows

  alias Mix.Tasks.Condukt.Workflows.Helpers



  @requirements ["app.start"]

  @impl Mix.Task

  def run(args) do

    {opts, rest} = Helpers.parse!(args, root: :string, input: :string)



    name =

      case rest do

        [name] -> name

        [] -> Mix.raise("Expected workflow name")

        _ -> Mix.raise("Expected exactly one workflow name")

      end



    project =

      opts

      |> Helpers.root()

      |> Helpers.load_project!()



    input = Helpers.decode_input!(opts[:input])



    case Workflows.run(project, name, input) do

      {:ok, result} -> Mix.shell().info(Helpers.format_result(result))

      {:error, reason} -> Mix.raise("Workflow run failed: #{inspect(reason)}")

    end

  end

end