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