Sha256: 6f5e1eb894a1e597b530218e82810ead6d6aeda0ccaba76bac30822776dd384d
Contents?: true
Size: 1.32 KB
Versions: 26
Compression:
Stored size: 1.32 KB
Contents
require 'ruby_fly'
require_relative '../tasklib'
module RakeFly
module Tasks
class UnpausePipeline < TaskLib
parameter :name, :default => :unpause_pipeline
parameter :argument_names, :default => []
parameter :target, :required => true
parameter :pipeline, :required => true
parameter :ensure_task, :default => :'fly:ensure'
def process_arguments(args)
self.name = args[0] if args[0]
end
def define
pipeline_name = pipeline.respond_to?(:call) ? "<derived>" : pipeline
target_name = target.respond_to?(:call) ? "<derived>" : target
desc "Unpause pipeline #{pipeline_name} for target #{target_name}"
task name, argument_names => [ensure_task] do |_, args|
derived_target = target.respond_to?(:call) ?
target.call(*[args].slice(0, target.arity)) :
target
derived_pipeline = pipeline.respond_to?(:call) ?
pipeline.call(*[args].slice(0, pipeline.arity)) :
pipeline
puts "Unpausing pipeline #{derived_pipeline} for target #{derived_target}..."
RubyFly.unpause_pipeline(
target: derived_target,
pipeline: derived_pipeline)
end
end
end
end
end
Version data entries
26 entries across 26 versions & 1 rubygems