Switch to untracked api where appropriate

examples/chunked_output_benchmark.rb

@@ -12,7 +12,7 @@ def main_loop
     if output[:current] < input[:limit]
       consumed = yield
       output[:current] += consumed
-      plan_event(nil)
+      plan_event(nil, untracked: true)
       suspend
     end
   end

examples/orchestrate.rb

@@ -1,6 +1,8 @@
 #!/usr/bin/env ruby
 # frozen_string_literal: true
 
+require_relative 'example_helper'
+
 example_description = <<DESC
   Orchestrate Example
   ===================
@@ -21,7 +23,6 @@
 
 DESC
 
-require_relative 'example_helper'
 
 module Orchestrate
 

examples/orchestrate_evented.rb

@@ -75,7 +75,7 @@ def run(event = nil)
                # do nothing
              end),
             (on nil do
-               suspend { |suspended_action| world.clock.ping suspended_action, rand(1), Finished }
+               suspend { |suspended_action| world.clock.ping suspended_action, rand(1), Finished, untracked: true }
              end))
     end
 

lib/dynflow/action/polling.rb

@@ -91,7 +91,7 @@ def resume_external_action
     end
 
     def suspend_and_ping
-      plan_event(Poll, poll_interval)
+      plan_event(Poll, poll_interval, untracked: true)
       suspend
     end
 

lib/dynflow/action/timeouts.rb

@@ -8,7 +8,7 @@ def process_timeout
     end
 
     def schedule_timeout(seconds, optional: false)
-      plan_event(Timeout, seconds, optional: optional)
+      plan_event(Timeout, seconds, optional: optional, untracked: true)
     end
  end
 end

lib/dynflow/action/with_bulk_sub_plans.rb

@@ -70,7 +70,7 @@ def run_progress
     def spawn_plans
       super
     ensure
-      plan_event(PlanNextBatch)
+      plan_event(PlanNextBatch, untracked: true)
     end
 
     def cancel!(force = false)

lib/dynflow/action/with_polling_sub_plans.rb

@@ -70,5 +70,9 @@ def recalculate_counts
                     :failed_count  => failed - output.fetch(:resumed_count, 0),
                     :success_count => success)
     end
+
+    def can_fire_and_forget_sub_plans?
+      true
+    end
   end
 end

lib/dynflow/action/with_sub_plans.rb

@@ -81,7 +81,8 @@ def trigger(action_class, *args)
       if uses_concurrency_control
         trigger_with_concurrency_control(action_class, *args)
       else
-        world.trigger { world.plan_with_options(action_class: action_class, args: args, caller_action: self) }
+        method = can_fire_and_forget_sub_plans? ? :trigger_untracked : :trigger
+        world.public_send(:trigger) { world.plan_with_options(action_class: action_class, args: args, caller_action: self) }
       end
     end
 
@@ -234,5 +235,9 @@ def check_for_errors!
     def uses_concurrency_control
       @uses_concurrency_control = input.key? :concurrency_control
     end
+
+    def can_fire_and_forget_sub_plans?
+      false
+    end
   end
 end