diff --git a/awx/main/models/inventory.py b/awx/main/models/inventory.py
index 1d0b82c4c1..c0d6af6a28 100644
--- a/awx/main/models/inventory.py
+++ b/awx/main/models/inventory.py
@@ -1278,6 +1278,7 @@ class InventoryUpdate(UnifiedJob, InventorySourceOptions, JobNotificationMixin):
 
     def websocket_emit_data(self):
         websocket_data = super(InventoryUpdate, self).websocket_emit_data()
+        websocket_data.update(dict(inventory_source_id=self.inventory_source.pk))
 
         if self.inventory_source.inventory is not None:
             websocket_data.update(dict(inventory_id=self.inventory_source.inventory.pk))