Packages

condukt

0.16.4
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
10 Dependencies
Dependants
Files
Activity
condukt lib mix tasks condukt.workflows.serve.ex
Raw

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

defmodule Mix.Tasks.Condukt.Workflows.Serve do

  @shortdoc "Serves Condukt workflows"



  @moduledoc """

  Starts a Condukt workflow runtime and blocks.

  """



  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, workflows: :string, port: :integer)

    rest == [] || Mix.raise("Unexpected arguments: #{Enum.join(rest, " ")}")



    root = root_from_opts(opts)

    project = Helpers.load_project!(root)

    port = Keyword.get(opts, :port, 4000)



    case Workflows.serve(project, port: port) do

      {:ok, _pid} ->

        Mix.shell().info("Serving #{map_size(project.workflows)} workflow(s) on port #{port}")

        Process.sleep(:infinity)



      {:error, reason} ->

        Mix.raise("Could not serve workflows: #{inspect(reason)}")

    end

  end



  defp root_from_opts(opts) do

    cond do

      opts[:root] ->

        Helpers.root(opts)



      opts[:workflows] ->

        workflows_root(opts[:workflows])



      true ->

        File.cwd!()

    end

  end



  defp workflows_root(path) do

    path = Path.expand(path)



    if Path.basename(path) == "workflows" do

      Path.dirname(path)

    else

      path

    end

  end

end