Packages
journey
0.10.24
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/schema/execution/computation.ex
defmodule Journey.Persistence.Schema.Execution.Computation do
@moduledoc false
use Journey.Persistence.Schema.Base
alias Journey.Persistence.Schema.Execution.ComputationState
alias Journey.Persistence.Schema.Execution.ComputationType
@primary_key {:id, :string, autogenerate: {Journey.Helpers.Random, :object_id, ["CMP"]}}
schema "computations" do
belongs_to(:execution, Journey.Persistence.Schema.Execution)
field(:node_name, :string)
field(:computation_type, Ecto.Enum, values: ComputationType.values())
field(:state, Ecto.Enum, values: ComputationState.values())
field(:ex_revision_at_start, :integer, default: nil)
field(:ex_revision_at_completion, :integer, default: nil)
field(:scheduled_time, :integer, default: nil)
field(:start_time, :integer, default: nil)
field(:completion_time, :integer, default: nil)
field(:deadline, :integer, default: nil)
field(:error_details, :string, default: nil)
# revisions of the upstream nodes used to compute this value – e.g. %{upstream_node1: 6, upstream_node2: 9}
field(:computed_with, :map, default: nil)
timestamps()
end
end