Contents

require 'celluloid/autostart'
require_relative "../celluloid/rake_worker"
module CapistranoMulticonfigParallel
  class ExtensionHelper
    class << self
      def inside_job?
        job_id.present?
      end

      def job_id
        ENV[CapistranoMulticonfigParallel::ENV_KEY_JOB_ID]
      end
      

      def rake_actor_id
        ENV['count_rake'].present? ? "rake_worker_#{job_id}_count" : "rake_worker_#{job_id}"
      end

      def actor
       CapistranoMulticonfigParallel::RakeWorker.supervise_as(rake_actor_id,
        actor_id: rake_actor_id,
        job_id: job_id) if Celluloid::Actor[rake_actor_id].blank?
       Celluloid::Actor[rake_actor_id]
     end

     def run_the_actor(task, &block)
      actor.work(ENV, task: task)
      actor.wait_execution until actor.task_approved
      return unless actor.task_approved
      CapistranoMulticonfigParallel::InputStream.hook(actor)
      CapistranoMulticonfigParallel::OutputStream.hook(actor)
      block.call
      CapistranoMulticonfigParallel::InputStream.unhook
      CapistranoMulticonfigParallel::OutputStream.unhook
    end

    



    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
capistrano_multiconfig_parallel-0.9.0	lib/capistrano_multiconfig_parallel/extensions/extension_helper.rb