class InsightsCloud::Async::CloudConnectorAnnounceTask
Public Class Methods
connector_feature_id()
click to toggle source
# File lib/insights_cloud/async/cloud_connector_announce_task.rb, line 8 def self.connector_feature_id @connector_feature_id ||= RemoteExecutionFeature.feature!(ForemanRhCloud::CloudConnector::CLOUD_CONNECTOR_FEATURE).id end
subscribe()
click to toggle source
# File lib/insights_cloud/async/cloud_connector_announce_task.rb, line 4 def self.subscribe Actions::RemoteExecution::RunHostsJob end
Public Instance Methods
connector_feature_id()
click to toggle source
# File lib/insights_cloud/async/cloud_connector_announce_task.rb, line 35 def connector_feature_id self.class.connector_feature_id end
connector_playbook_job?(job_invocation)
click to toggle source
# File lib/insights_cloud/async/cloud_connector_announce_task.rb, line 31 def connector_playbook_job?(job_invocation) job_invocation&.remote_execution_feature_id == connector_feature_id end
finalize()
click to toggle source
# File lib/insights_cloud/async/cloud_connector_announce_task.rb, line 18 def finalize Organization.unscoped.each do |org| presence = ForemanRhCloud::CloudPresence.new(org, logger) presence.announce_to_sources rescue StandardError => ex logger.warn(ex) end end
logger()
click to toggle source
# File lib/insights_cloud/async/cloud_connector_announce_task.rb, line 39 def logger action_logger end
plan(job_invocation)
click to toggle source
# File lib/insights_cloud/async/cloud_connector_announce_task.rb, line 12 def plan(job_invocation) return unless connector_playbook_job?(job_invocation) plan_self end
rescue_strategy_for_self()
click to toggle source
# File lib/insights_cloud/async/cloud_connector_announce_task.rb, line 27 def rescue_strategy_for_self Dynflow::Action::Rescue::Skip end