Merge pull request ManageIQ#17451 from lfu/log_worker_id_1535237

 Keep track of the server ids where the automate task has been processed.

app/models/miq_provision/state_machine.rb

@@ -121,6 +121,7 @@ def mark_as_completed
   end
 
   def finish
+    mark_execution_servers
     if status != 'Error'
       number_of_vms = get_option(:number_of_vms).to_i
       pass = get_option(:pass)

app/models/miq_request_task/state_machine.rb

@@ -69,6 +69,7 @@ def prematurely_finished?
   end
 
   def requeue_phase
+    mark_execution_servers
     save # Save current phase_context
     MiqQueue.put(
       :class_name     => self.class.name,

app/models/mixins/miq_request_mixin.rb

@@ -169,4 +169,10 @@ def request_dialog(action_name)
     dialog = ResourceActionWorkflow.new(values, get_user, ra, {}).dialog
     DialogSerializer.new.serialize(Array[dialog]).first
   end
+
+  def mark_execution_servers
+    options[:executed_on_servers] ||= []
+    options[:executed_on_servers] << MiqServer.my_server.id
+    update_attributes(:options => options)
+  end
 end

spec/models/service_template_provision_task_spec.rb

@@ -233,5 +233,23 @@ def service_resource_id(index, scaling_max)
         @task_1_2.update_and_notify_parent(:state => "finished", :status => "Ok", :message => "Test Message")
       end
     end
+
+    describe "#mark_execution_servers" do
+      let(:server) { FactoryGirl.create(:miq_server) }
+      before { allow(MiqServer).to receive(:my_server).and_return(server) }
+
+      it "with new server id" do
+        @task_0.mark_execution_servers
+        expect(@task_0.options[:executed_on_servers]).to eq([server.id])
+      end
+
+      it "with existing server id" do
+        @task_0.options[:executed_on_servers] = [server.id]
+        @task_0.save!
+
+        @task_0.mark_execution_servers
+        expect(@task_0.options[:executed_on_servers]).to eq([server.id, server.id])
+      end
+    end
   end
 end