trigger.py: Check latest commit nodes owned by token owner

We might have several different instances, and owners should not interfere with each other. Signed-off-by: Denys Fedoryshchenko <[email protected]>
JenySadadia · Dec 20, 2023 · 3ff83ae · 3ff83ae
1 parent da52a66
commit 3ff83ae
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/src/trigger.py b/src/trigger.py
@@ -28,14 +28,17 @@ class Trigger(Service):
     def __init__(self, configs, args):
         super().__init__(configs, args, 'trigger')
         self._build_configs = configs['build_configs']
+        self._current_user = self._api.whoami()
 
     def _log_revision(self, message, build_config, head_commit):
         self.log.info(f"{message:32s} {build_config.name:32s} {head_commit}")
 
     def _run_trigger(self, build_config, force, timeout):
         head_commit = kernelci.build.get_branch_head(build_config)
+
         node_count = self._api.count_nodes({
             "revision.commit": head_commit,
+            "owner": self._current_user['username'],
         })
 
         if node_count > 0: