iNecas

git filter-branch -f --env-filter '
          export GIT_AUTHOR_NAME="$ME";
          export GIT_COMMITTER_NAME="$ME";
          export GIT_AUTHOR_EMAIL="$MY_MAIL";
          export GIT_COMMITTER_EMAIL="$MY_MAIL";
      ' HEAD
git push origin --force

iNecas

class Hash {
  public static void main(String[] args) {
    System.out.println(Integer.toString("Hello World!".hashCode()));
  }
}

// $ java Hash
// $ -969099747
// $ java Hash
// $ -969099747

iNecas

{ :invalid_system => 20, 
  :invalid_values => 21, 
  :manifest_error => 22, 
  :no_answer_file => 23, 
  :unknown_module => 24, 
  :defaults_error => 25 }

iNecas

diff --git a/app/models/katello/concerns/organization_extensions.rb b/app/models/katello/concerns/organization_extensions.rb
index 39a6480..294097d 100644
--- a/app/models/katello/concerns/organization_extensions.rb
+++ b/app/models/katello/concerns/organization_extensions.rb
@@ -19,7 +19,11 @@ module Katello
 
         ALLOWED_DEFAULT_INFO_TYPES = %w(system distributor)
 
-        include ForemanTasks::Concerns::ActionSubject
+        # We need this to be able to scratch build in koji

iNecas

cat <<EOF | foreman-rake console
@world = ForemanTasks.dynflow.world
@persistence = @world.persistence

def reset_pulp_task(uuid)
  execution_plan = @persistence.load_execution_plan(uuid)
  raise 'execution plan #{execution_plan} is not paused' unless execution_plan.state == :paused
  active_steps = execution_plan.steps_in_state(:running, :suspended, :error)
  active_steps.each do |step|
    action = step.action(execution_plan)

iNecas

gem 'smart_proxy_dynflow', :git => 'git@github.com:iNecas/smart_proxy_dynflow.git', :branch => 'integrate-foreman-tasks-core'
gem 'smart_proxy_dynflow_core', :git => 'git@github.com:iNecas/smart_proxy_dynflow.git', :branch => 'integrate-foreman-tasks-core'
gem 'foreman-tasks-core', :git => 'git@github.com:iNecas/foreman-tasks.git', :branch => 'foreman-tasks-core'
gem 'smart_proxy_ansible', :git => 'git@github.com:iNecas/smart_proxy_ansible.git', :branch => 'ansible-run-rebase'
gem 'foreman_ansible_core', :git => 'git@github.com:iNecas/foreman_ansible.git', :branch => 'run-via-proxy'

iNecas

diff --git a/app/lib/actions/remote_execution/run_hosts_job.rb b/app/lib/actions/remote_execution/run_hosts_job.rb
index 40dd320..c146ea8 100644
--- a/app/lib/actions/remote_execution/run_hosts_job.rb
+++ b/app/lib/actions/remote_execution/run_hosts_job.rb
@@ -25,7 +25,7 @@ module Actions
         job_invocation = JobInvocation.find(input[:job_invocation_id])
         proxy_selector = RemoteExecutionProxySelector.new
 
-        ::Host.where(:id => current_batch).map do |host|
+        current_batch.map do |host|

iNecas

diff --git a/lib/dynflow/action/with_bulk_sub_plans.rb b/lib/dynflow/action/with_bulk_sub_plans.rb
index dbff3a2..9dae0e2 100644
--- a/lib/dynflow/action/with_bulk_sub_plans.rb
+++ b/lib/dynflow/action/with_bulk_sub_plans.rb
@@ -9,6 +9,17 @@ module Dynflow
       raise NotImplementedError
     end
 
+    PlanNextBatch = Algebrick.atom
+

iNecas

# Usage:
# 1. edit the TASK_SEARCH and AFTER values
# 2. run `foreman-rake console < sat61_tasks_cleaner.rb`

TASK_SEARCH=''
AFTER='30d'

module ForemanTasks
  # Represents the cleanup mechanism for tasks
  class Cleaner

iNecas

cat <<EOF > /usr/share/foreman/config/initializers/foreman_tasks_workers_bump.rb
workers_count = 10
Rails.logger.info("Bumping the number of dynflow worksers to #{workers_count}")
ForemanTasks.dynflow.config.pool_size = workers_count
ForemanTasks.dynflow.config.db_pool_size = workers_count + 5
EOF
service foreman-tasks restart