From 70e8c2127de7739962c2ec479ba981e245548145 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Ond=C5=99ej=20Ezr?= Date: Wed, 23 Jun 2021 12:56:13 +0200 Subject: [PATCH] Refs #32534 - dont use SmartProxyDynflowCore Remove usage of SmartProxyDynflowCore. --- lib/smart_proxy_dynflow/action/batch_callback.rb | 2 +- lib/smart_proxy_dynflow/action/batch_runner.rb | 2 +- lib/smart_proxy_dynflow/action/shareable.rb | 4 ++-- 3 files changed, 4 insertions(+), 4 deletions(-) diff --git a/lib/smart_proxy_dynflow/action/batch_callback.rb b/lib/smart_proxy_dynflow/action/batch_callback.rb index e8ac0d3..43ee1ab 100644 --- a/lib/smart_proxy_dynflow/action/batch_callback.rb +++ b/lib/smart_proxy_dynflow/action/batch_callback.rb @@ -6,7 +6,7 @@ def plan(input_hash, results) def run payload = format_payload(input['targets'], input['results']) - SmartProxyDynflowCore::Callback::Request.new.callback({ :callbacks => payload }.to_json) + Proxy::Dynflow::Callback::Request.new.callback({ :callbacks => payload }.to_json) end private diff --git a/lib/smart_proxy_dynflow/action/batch_runner.rb b/lib/smart_proxy_dynflow/action/batch_runner.rb index 0d1730a..e3ae864 100644 --- a/lib/smart_proxy_dynflow/action/batch_runner.rb +++ b/lib/smart_proxy_dynflow/action/batch_runner.rb @@ -7,7 +7,7 @@ def plan(launcher, input) end def initiate_runner - launcher = SmartProxyDynflowCore::TaskLauncherRegistry.fetch(input[:operation]) + launcher = Proxy::Dynflow::TaskLauncherRegistry.fetch(input[:operation]) launcher.runner_class.new(input[:targets], suspended_action: suspended_action) end end diff --git a/lib/smart_proxy_dynflow/action/shareable.rb b/lib/smart_proxy_dynflow/action/shareable.rb index 151a237..3745655 100644 --- a/lib/smart_proxy_dynflow/action/shareable.rb +++ b/lib/smart_proxy_dynflow/action/shareable.rb @@ -12,14 +12,14 @@ def plan(input) planned_action = plan_self(input) # code only applicable, when run with SmartProxyDynflowCore in place if on_proxy? && callback - plan_action(SmartProxyDynflowCore::Callback::Action, callback, planned_action.output) + plan_action(Proxy::Dynflow::Callback::Action, callback, planned_action.output) end end private def on_proxy? - defined?(SmartProxyDynflowCore::Callback) + defined?(Proxy::Dynflow::Callback) end end end