Stop any worker records for failed systemd units

If a systemd unit is failed but there is still a miq_worker record
associated with it we should mark that worker record as stopped.  This
will then be cleaned up by the subsequent `clean_worker_records` method.

app/models/miq_server/worker_management/systemd.rb

@@ -32,6 +32,11 @@ def cleanup_failed_systemd_services
 
     _log.info("Disabling failed unit files: [#{service_names.join(", ")}]")
     systemd_stop_services(service_names)
+
+    _log.info("Stopping worker records for failed units: [#{service_names.join(", ")}]")
+    MiqWorker.find_current_or_starting.where(:system_uid => service_names).each do |w|
+      w.update!(:status => MiqWorker::STATUS_STOPPED)
+    end
   end
 
   private

spec/models/miq_server/worker_management/systemd_spec.rb

@@ -26,6 +26,7 @@
     context "with failed services" do
       let(:service_name) { "[email protected]" }
       let(:units) { [{:name => service_name, :description => "ManageIQ Generic Worker", :load_state => "loaded", :active_state => "failed", :sub_state => "plugged", :job_id => 0, :job_type => "", :job_object_path => "/"}] }
+      let!(:worker) { FactoryBot.create(:miq_generic_worker, :miq_server => server, :status => "creating", :system_uid => service_name) }
 
       it "calls DisableUnitFiles with the service name" do
         expect(systemd_manager).to receive(:StopUnit).with(service_name, "replace")
@@ -34,6 +35,16 @@
 
         server.worker_manager.cleanup_failed_systemd_services
       end
+
+      it "marks any active workers as stopped" do
+        expect(systemd_manager).to receive(:StopUnit).with(service_name, "replace")
+        expect(systemd_manager).to receive(:ResetFailedUnit).with(service_name)
+        expect(systemd_manager).to receive(:DisableUnitFiles).with([service_name], false)
+
+        server.worker_manager.cleanup_failed_systemd_services
+
+        expect(worker.reload.status).to eq("stopped")
+      end
     end
   end