Packages

gust

0.1.36
0.1.37 0.1.36 0.1.35 0.1.34 0.1.33 0.1.32 0.1.31 0.1.30 0.1.29 0.1.28 0.1.27 0.1.26 0.1.25 0.1.24 0.1.23 0.1.22 0.1.21 0.1.20 0.1.19 0.1.18 0.1.17 0.1.16 0.1.15 0.1.14 0.1.13 0.1.12 0.1.11 0.1.10 0.1.9 0.1.8 0.1.7 0.1.6 0.1.5 0.1.4 0.1.2 0.1.1 0.1.0

A DAG-Based Workflow Orchestration Engine for Elixir

HexDocs

Current section

Files

Jump to
Readme
37 Versions
8 Dependencies
Dependants
Files
Activity
gust lib gust dag task_waiter.ex
Raw

lib/gust/dag/task_waiter.ex 

defmodule Gust.DAG.TaskWaiter do

  @moduledoc """

  Behaviour for resuming tasks that are parked on external wait events.



  This module delegates to the configured implementation module:



      config :gust, :dag_task_waiter, Gust.DAG.TaskWaiter.Repo



  The configured module must implement this behaviour.

  """



  @type task :: term()

  @type resume_opts :: keyword()



  @callback resume(term(), resume_opts()) :: {:ok, [task()]} | {:error, term()}

  @callback clear_wait(task()) :: task()

  @callback fail(task()) :: {:ok, task()} | {:error, term()}



  def resume(waiting_for, opts) when is_list(opts), do: impl().resume(waiting_for, opts)

  def clear_wait(task), do: impl().clear_wait(task)

  def fail(task), do: impl().fail(task)



  def impl, do: Application.get_env(:gust, :dag_task_waiter, Gust.DAG.TaskWaiter.Repo)

end