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