Packages

gust

0.1.25
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
9 Dependencies
Dependants
Files
Activity
gust lib gust dag terminator process.ex
Raw

lib/gust/dag/terminator/process.ex 

defmodule Gust.DAG.Terminator.Process do

  @moduledoc false

  @behaviour Gust.DAG.Terminator



  alias Gust.Registry, as: GustReg



  def kill_task(task, status) do

    stage_pid = lookup("stage_run_#{task.run_id}")

    task_pid = lookup("task_#{task.id}")



    true = Process.exit(task_pid, :kill)



    send(stage_pid, {:task_result, nil, task.id, status})

  end



  def cancel_timer(task, status) do

    stage_pid = lookup("stage_run_#{task.run_id}")

    send(stage_pid, {:cancel_timer, task.id, status})

  end



  defp lookup(key) do

    [{pid, _val}] = Registry.lookup(GustReg, key)

    pid

  end

end