class DTK::State::Workflow

Constants

WORKFLOW_CRD_VERSION

Attributes

assembly[R]
attribute_type_info[R]
name[R]
namespace[R]
references[R]
workflow[R]

Public Class Methods

get(namespace, name, opts = {}) click to toggle source
# File lib/state/workflow.rb, line 20
def self.get(namespace, name, opts = {})
  opts[:apiVersion] = WORKFLOW_CRD_VERSION
  workflow = ::DTK::CrdClient.get_kubeclient(opts).get_workflow(name, namespace)
  Workflow.new(namespace, name, workflow)
end
new(namespace, name, crd_content) click to toggle source
# File lib/state/workflow.rb, line 9
def initialize(namespace, name, crd_content)
  @name      = name
  @namespace = namespace

  @references = crd_content.references
  @assembly   = @references.assembly
  @workflow   = crd_content.spec.workflow || {}

  @attribute_type_info = ::DTK::State::WorkflowInstance::AttributeTypeInfo.create_from_kube_hash(crd_content.spec.attributes.to_h || {})
end