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