Skip to content

Instantly share code, notes, and snippets.

Avatar
💭
Happy hacking 👨 ⌨️ 💻

Ivan Necas iNecas

💭
Happy hacking 👨 ⌨️ 💻
View GitHub Profile
@iNecas
iNecas / dynflow_increase_workers.sh
Last active May 10, 2017
Increase number of workers for dynflow in Foreman
View dynflow_increase_workers.sh
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
@iNecas
iNecas / dynflow_throughput_monitor.rb
Last active Aug 23, 2017
dynflow message throughput monitor
View dynflow_throughput_monitor.rb
# usage
#
# 1) copy the monitory to be loaded by satellite
#
# cp dynflow_throughput_monitor.rb /usr/share/foreman/config/initializers
# service foreman-tasks restart
#
# 2) grab the collected data to be shared with engineering:
#
# tar cvf dynflow_thoughput_monitor.tar /var/log/foreman/dynflow_throughput_monitor.log*
@iNecas
iNecas / sat61_tasks_cleaner.rb
Created Mar 8, 2017
sat61_tasks_cleaner.rb
View sat61_tasks_cleaner.rb
# 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
View more-frequent-updates.patch
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
+
View rex-in-batch.patch
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|
View dynflow-csv
#!/usr/bin/env bash
function export-csv () {
echo "Exporting $2"
echo "COPY ($1) TO STDOUT WITH CSV;" | su - postgres -c '/usr/bin/psql -d foreman' > $2
}
function import-csv () {
echo "Importing $2"
su - postgres -c "/usr/bin/psql -d $IMPORT_DATABASE -c 'COPY $1 FROM STDIN WITH CSV'" <$2
@iNecas
iNecas / bundler.d-Gemfile.local.rb
Last active Sep 6, 2016
smart-proxy-ansible devel setup
View bundler.d-Gemfile.local.rb
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
iNecas / resume_missing_pulp_task.rb
Created May 5, 2016
resume_missing_pulp_task.rb
View resume_missing_pulp_task.rb
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
iNecas / event_per_file_log.py
Last active Oct 24, 2021
Ansible callback plugin to save events into files
View event_per_file_log.py
import os
from datetime import datetime
import json
import uuid
TIME_FORMAT="%Y-%m-%d_%H%M%S_%f"
FILE_NAME_FORMAT="%(now)s-%(host)s.json"
MSG_FORMAT='{"host":"%(host)s","timestamp":"%(now)s", "category":"%(category)s", "data": %(data)s}' + "\n"
LOG_DIR="/tmp/ansible/events"
AGGREGATION_KEY = uuid.uuid4().hex
View gist:4324536a0b1fd81d3c66
Vagrant.configure("2") do |config|
config.vm.define "my-db-fedora" do |vm|
vm.box = "chef/fedora-21"
vm.provision "ansible" do
ansible.groups = { 'ha' => 'my-ha-fedora' }
ansible.playbook = "my-db.yml"
end
end
config.vm.define "my-ha-fedora" do |vm|