SAT-30393 - Skip recurring logic tasks if on prem is enabled

lib/foreman_inventory_upload/async/generate_all_reports_job.rb

@@ -2,7 +2,7 @@ module ForemanInventoryUpload
   module Async
     class GenerateAllReportsJob < ::Actions::EntryAction
       include ::Actions::RecurringAction
-      include ForemanInventoryUpload::Async::DelayedStart
+      #include ForemanInventoryUpload::Async::DelayedStart
 
       def plan
         unless Setting[:allow_auto_inventory_upload]
@@ -13,20 +13,30 @@ def plan
           return
         end
 
-        after_delay do
-          organizations = Organization.unscoped.all
+        # rubocop:disable Style/GuardClause
+        if !ForemanRhCloud.with_local_advisor_engine?
+          after_delay do
+            organizations = Organization.unscoped.all
 
-          organizations.map do |organization|
-            total_hosts = ForemanInventoryUpload::Generators::Queries.for_org(organization.id, use_batches: false).count
+            organizations.map do |organization|
+              total_hosts = ForemanInventoryUpload::Generators::Queries.for_org(organization.id, use_batches: false).count
 
-            if total_hosts <= ForemanInventoryUpload.max_org_size
-              disconnected = false
-              plan_generate_report(ForemanInventoryUpload.generated_reports_folder, organization, disconnected)
-            else
-              logger.info("Skipping automatic uploads for organization #{organization.name}, too many hosts (#{total_hosts}/#{ForemanInventoryUpload.max_org_size})")
-            end
-          end.compact
+              if total_hosts <= ForemanInventoryUpload.max_org_size
+                disconnected = false
+                plan_generate_report(ForemanInventoryUpload.generated_reports_folder, organization, disconnected)
+              else
+                logger.info("Skipping automatic uploads for organization #{organization.name}, too many hosts (#{total_hosts}/#{ForemanInventoryUpload.max_org_size})")
+              end
+            end.compact
+          end
+        else
+          plan_self
         end
+        # rubocop:enable Style/GuardClause
+      end
+
+      def run
+          output[:status] = _('The scheduled process is disabled because this Foreman is configured with the use_local_advisor_engine option.') if ForemanRhCloud.with_local_advisor_engine?
       end
 
       def rescue_strategy_for_self

lib/insights_cloud/async/insights_scheduled_sync.rb

@@ -13,9 +13,18 @@ def plan
           return
         end
 
-        after_delay do
-          plan_full_sync
+        # rubocop:disable Style/GuardClause
+        unless ForemanRhCloud.with_local_advisor_engine?
+          after_delay do
+            plan_full_sync
+          end
         end
+        # rubocop:enable Style/GuardClause
+        plan_self
+      end
+
+      def run
+        output[:status] = _('The scheduled process is disabled because this Foreman is configured with the use_local_advisor_engine option.') if ForemanRhCloud.with_local_advisor_engine?
       end
 
       def plan_full_sync

lib/inventory_sync/async/inventory_scheduled_sync.rb

@@ -13,23 +13,32 @@ def plan
           return
         end
 
-        after_delay do
-          # perform a sequence of sync then delete in parallel for all organizations
-          concurrence do
-            Organization.unscoped.each do |org|
-              sequence do
-                plan_org_sync(org)
-                plan_remove_insights_hosts(org.id) if Setting[:allow_auto_insights_mismatch_delete]
+        # rubocop:disable Style/GuardClause
+        unless ForemanRhCloud.with_local_advisor_engine?
+          after_delay do
+            # perform a sequence of sync then delete in parallel for all organizations
+            concurrence do
+              Organization.unscoped.each do |org|
+                sequence do
+                  plan_org_sync(org)
+                  plan_remove_insights_hosts(org.id) if Setting[:allow_auto_insights_mismatch_delete]
+                end
               end
             end
           end
         end
+        # rubocop:enable Style/GuardClause
+        plan_self
       end
 
       def plan_org_sync(org)
         plan_action InventoryFullSync, org
       end
 
+      def run
+        output[:status] = _('The scheduled process is disabled because this Foreman is configured with the use_local_advisor_engine option.') if ForemanRhCloud.with_local_advisor_engine?
+      end
+
       def plan_remove_insights_hosts(org_id)
         # plan a remove hosts action with search set to empty (all records)
         plan_action(ForemanInventoryUpload::Async::RemoveInsightsHostsJob, '', org_id)