Reflect change in signature of api_helper.receive_event_node

API helper function to get node and other information
from event has been changed to send `is_retry` flag.
This flag is useful to detect if the event was raised
to schedule a job retry.
Update pipeline services that use the helper function
accordingly.
Do not process retry events in KCIDB bridge service
to avoid sending the same parent node again. The
event is intended for scheduler service.

Signed-off-by: Jeny Sadadia <[email protected]>

Author: Jeny Sadadia

src/send_kcidb.py

@@ -698,7 +698,10 @@ def _run(self, context):
                 # Listen and wait for a node instead of processing the queue
                 node = None
                 try:
-                    node, is_hierarchy = self._api_helper.receive_event_node(context['sub_id'])
+                    node, is_hierarchy, is_retry = self._api_helper.receive_event_node(context['sub_id'])
+                    if is_retry:
+                        # Do not re-submit parent node when a node is submitted for a retry
+                        continue
                 except Exception as e:
                     self.log.error(f"Error receiving event: {e}, re-subscribing in 10 seconds")
                     time.sleep(10)

src/tarball.py

@@ -212,7 +212,7 @@ def _run(self, sub_id):
         while True:
             checkout_node = None
             try:
-                checkout_node, _ = self._api_helper.receive_event_node(sub_id)
+                checkout_node, _, _ = self._api_helper.receive_event_node(sub_id)
             except Exception as e:
                 self.log.error(f"Error receiving event: {e}, re-subscribing in 10 seconds")
                 time.sleep(10)