using generic handler rather than creating new files.

Author: syedhaseebahmed

components/site-workflows/sensors/sensor-ironic-oslo-inspecting-event.yaml

@@ -76,7 +76,7 @@ spec:
                   steps:
                   - - name: oslo-events
                       templateRef:
-                        name: update-nautobot-on-openstack-oslo-event
+                        name: openstack-oslo-event
                         template: main
                       arguments:
                         parameters:

docs/operator-guide/openstack-ironic-nautobot-device-interfaces-sync.md

@@ -70,11 +70,11 @@ Server Enrollment → Redfish Inspection → Oslo Event Bus → Argo Events Sens
 
 5. **Workflow Trigger**
    - Sensor creates an Argo Workflow named `update-nautobot-*`
-   - Workflow uses template `update-nautobot-on-openstack-oslo-event`
+   - Workflow uses template `openstack-oslo-event`
    - Event data is passed as workflow parameter
 
 6. **Data Processing**
-   - Workflow executes `update-nautobot-on-openstack-oslo-event` script
+   - Workflow executes `openstack-oslo-event` script
    - Script fetches full inventory data from Ironic API using node UUID
    - Inventory data is parsed and transformed into Nautobot format
 
@@ -99,11 +99,11 @@ The sensor configuration defines:
 
 ### Workflow Template
 
-**File:** `workflows/argo-events/workflowtemplates/update-nautobot-on-openstack-oslo-event.yaml`
+**File:** `workflows/argo-events/workflowtemplates/openstack-oslo-event.yaml`
 
 The workflow template:
 
-- Runs the `update-nautobot-on-openstack-oslo-event` command
+- Runs the `openstack-oslo-event` command
 - Mounts Nautobot token and OpenStack credentials
 - Passes event JSON as input file
 - Uses service account with appropriate permissions
@@ -271,7 +271,7 @@ openstack baremetal node show <node-uuid> -f json > node.json
 
 # Submit workflow manually
 argo -n argo-events submit \
-  --from workflowtemplate/update-nautobot-on-openstack-oslo-event \
+  --from workflowtemplate/openstack-oslo-event \
   -p event-json "$(cat node.json)"
 ```
 

python/understack-workflows/pyproject.toml

@@ -40,7 +40,6 @@ sync-network-segment-range = "understack_workflows.main.sync_ucvni_group_range:m
 openstack-oslo-event = "understack_workflows.main.openstack_oslo_event:main"
 netapp-create-svm = "understack_workflows.main.netapp_create_svm:main"
 netapp-configure-interfaces = "understack_workflows.main.netapp_configure_net:main"
-update-nautobot-on-openstack-oslo-event = "understack_workflows.main.update_nautobot:main"
 
 [dependency-groups]
 test = [

python/understack-workflows/understack_workflows/main/openstack_oslo_event.py

@@ -18,6 +18,7 @@
 from understack_workflows.oslo_event import keystone_project
 from understack_workflows.oslo_event import neutron_network
 from understack_workflows.oslo_event import neutron_subnet
+from understack_workflows.oslo_event import update_nautobot
 
 logger = setup_logger(__name__)
 
@@ -62,12 +63,16 @@ class NoEventHandlerError(Exception):
 # Type alias for event handler functions
 EventHandler = Callable[[Connection, NautobotApi, dict[str, Any]], int]
 
-# add the event_type here and the function that should be called
-_event_handlers: dict[str, EventHandler] = {
+# add the event_type here and the function(s) that should be called
+# each event type can have a single handler or a list of handlers
+_event_handlers: dict[str, EventHandler | list[EventHandler]] = {
     "baremetal.port.create.end": ironic_port.handle_port_create_update,
     "baremetal.port.update.end": ironic_port.handle_port_create_update,
     "baremetal.port.delete.end": ironic_port.handle_port_delete,
-    "baremetal.node.provision_set.end": ironic_node.handle_provision_end,
+    "baremetal.node.provision_set.end": [
+        ironic_node.handle_provision_end,
+        update_nautobot.handle_provision_end,
+    ],
     "identity.project.created": keystone_project.handle_project_created,
     "identity.project.updated": keystone_project.handle_project_updated,
     "identity.project.deleted": keystone_project.handle_project_deleted,
@@ -179,14 +184,20 @@ def main() -> int:
 
     logger.info("Processing event type: %s", event_type)
 
-    # look up the event handler
-    event_handler = _event_handlers.get(event_type)
-    if event_handler is None:
+    # look up the event handler(s)
+    event_handlers = _event_handlers.get(event_type)
+    if event_handlers is None:
         logger.error("No event handler for event type: %s", event_type)
         logger.debug("Available event handlers: %s", list(_event_handlers.keys()))
         sys.exit(_EXIT_NO_EVENT_HANDLER)
 
-    logger.debug("Found event handler for event type: %s", event_type)
+    # normalize to list for consistent processing
+    if not isinstance(event_handlers, list):
+        event_handlers = [event_handlers]
+
+    logger.debug(
+        "Found %d handler(s) for event type: %s", len(event_handlers), event_type
+    )
 
     # get a connection to OpenStack and to Nautobot
     try:
@@ -195,17 +206,21 @@ def main() -> int:
         logger.exception("Client initialization failed")
         sys.exit(_EXIT_CLIENT_ERROR)
 
-    # execute the event handler
-    logger.info("Executing event handler for event type: %s", event_type)
-    try:
-        ret = event_handler(conn, nautobot, event)
-    except Exception:
-        logger.exception("Event handler failed")
-        sys.exit(_EXIT_HANDLER_ERROR)
-
-    logger.info("Event handler completed successfully with return code: %s", ret)
-
-    # exit if the event handler provided a return code or just with success
-    if isinstance(ret, int):
-        return ret
-    return _EXIT_SUCCESS
+    # execute all event handlers
+    last_ret = _EXIT_SUCCESS
+    for idx, event_handler in enumerate(event_handlers, 1):
+        handler_name = event_handler.__name__
+        logger.info(
+            "Executing handler %d/%d: %s", idx, len(event_handlers), handler_name
+        )
+        try:
+            ret = event_handler(conn, nautobot, event)
+            if isinstance(ret, int):
+                last_ret = ret
+            logger.info("Handler %s completed with return code: %s", handler_name, ret)
+        except Exception:
+            logger.exception("Handler %s failed", handler_name)
+            sys.exit(_EXIT_HANDLER_ERROR)
+
+    logger.info("All handlers completed successfully")
+    return last_ret

python/understack-workflows/understack_workflows/main/update_nautobot.py

@@ -0,0 +1,33 @@
+from openstack.connection import Connection
+from pynautobot.core.api import Api as Nautobot
+
+from understack_workflows import nautobot_device
+from understack_workflows.bmc_chassis_info import ChassisInfo
+from understack_workflows.helpers import setup_logger
+from understack_workflows.ironic.client import IronicClient
+from understack_workflows.ironic.inventory import get_device_info
+from understack_workflows.openstack.client import get_ironic_client
+
+logger = setup_logger(__name__)
+
+
+def handle_provision_end(conn: Connection, nautobot: Nautobot, event_data: dict) -> int:
+    """Handle Ironic node provisioning END event."""
+    payload = event_data.get("payload", {})
+    payload_data = payload.get("ironic_object.data")
+
+    if not payload_data:
+        raise ValueError("Missing 'ironic_object.data' in event payload")
+
+    cloud_name = getattr(conn.config, "name", None) if hasattr(conn, "config") else None
+    ironic_raw_client = get_ironic_client(cloud=cloud_name)
+    ironic_client = IronicClient(ironic_raw_client)
+
+    node_inventory = ironic_client.get_node_inventory(
+        node_ident=str(payload_data["uuid"])
+    )
+    device_info: ChassisInfo = get_device_info(node_inventory)
+    nb_device = nautobot_device.find_or_create(device_info, nautobot)
+
+    logger.info("Updated Nautobot device: %s", nb_device)
+    return 0

python/understack-workflows/understack_workflows/oslo_event/update_nautobot.py

@@ -24,7 +24,6 @@ resources:
   - sensors/alertmanager-webhook-sensor.yaml
   - eventsources/alertmanager-webhook-eventsource.yaml
   - workflowtemplates/alert-automation-neutron-agent-down.yaml
-  - workflowtemplates/update-nautobot-on-openstack-oslo-event.yaml
 
 helmCharts:
   - name: nautobot-token