Packages
journey
0.10.48
0.10.58
0.10.57
0.10.56
0.10.55
0.10.54
0.10.53
0.10.52
0.10.51
0.10.50
0.10.49
0.10.48
0.10.47
0.10.46
0.10.45
0.10.44
0.10.43
0.10.41
0.10.40
0.10.39
0.10.38
0.10.37
0.10.36
0.10.35
0.10.34
0.10.33
0.10.32
0.10.31
0.10.30
0.10.29
0.10.28
0.10.27
0.10.26
0.10.25
0.10.24
0.10.23
0.10.22
0.0.9
retired
0.0.8
0.0.7
0.0.6
0.0.5
0.0.3
0.0.2
Journey is a library for defining and running durable workflows with persistence, reliability, and scalability.
Current section
Files
Jump to
Current section
Files
lib/journey/persistence/values.ex
defmodule Journey.Persistence.Values do
@moduledoc false
import Ecto.Query
alias Journey.Persistence.Schema.Execution.Value
def load_from_db(execution_id, repo) do
from(v in Value, where: v.execution_id == ^execution_id)
|> repo.all()
|> Enum.map(&convert_node_name_to_atom/1)
end
def convert_node_name_to_atom(%Value{node_name: node_name} = val) when is_binary(node_name) do
%Value{val | node_name: String.to_atom(node_name)}
end
end