class Pione::RuleEngine::Task

Public Instance Methods

digest() click to toggle source

Return digest string of the task.

# File lib/pione/rule-engine/flow-handler.rb, line 151
def digest
  @__digest__ ||= Util::TaskDigest.generate(rule.package_id, rule.name, inputs, param_set)
end
inspect() click to toggle source
# File lib/pione/rule-engine/flow-handler.rb, line 167
def inspect
  args = [self.class, rule.package_id, rule.name, inputs, param_set, order]
  "#<%s package_id=%s, name=%s, inputs=%s, param_set=%s, order=%s>" % args
end
Also aliased as: to_s
make_task_process_record() click to toggle source

Return task process record of the task.

# File lib/pione/rule-engine/flow-handler.rb, line 156
def make_task_process_record
  Log::TaskProcessRecord.new.tap do |record|
    record.name = digest
    record.package_id = rule.package_id
    record.rule_name = rule.name
    record.rule_type = rule_definition.rule_type
    record.inputs = inputs.flatten.map{|input| input.name}.join(",")
    record.parameters = param_set.textize
  end
end
make_tuple(caller_id) click to toggle source

Make a task tuple from the application.

# File lib/pione/rule-engine/flow-handler.rb, line 134
def make_tuple(caller_id)
  features = rule_condition.features.inject(Lang::FeatureSequence.new) do |f, expr|
    f + expr.eval(env)
  end
  TupleSpace::TaskTuple.new(
    digest,
    rule.package_id,
    rule.name,
    inputs,
    param_set,
    features,
    domain_id,
    caller_id
  )
end
to_s()
Alias for: inspect