From 3d5f1aa3bcd7e5fe106c56496195e76785e8fabe Mon Sep 17 00:00:00 2001
From: Lluis Gifre Renom <lluis.gifre@cttc.es>
Date: Thu, 21 Mar 2024 23:54:23 +0000
Subject: [PATCH] CI/CD pipeline - OFC'22
---
src/common/tools/mutex_queues/MutexQueues.py | 2 ++
1 file changed, 2 insertions(+)
diff --git a/src/common/tools/mutex_queues/MutexQueues.py b/src/common/tools/mutex_queues/MutexQueues.py
index b80dd1a9c..c29194ca8 100644
--- a/src/common/tools/mutex_queues/MutexQueues.py
+++ b/src/common/tools/mutex_queues/MutexQueues.py
@@ -55,6 +55,8 @@ class MutexQueues:
self.mutex_queues[queue_name_b] = self.mutex_queues[queue_name_a]
elif queue_name_b in self.mutex_queues and queue_name_a not in self.mutex_queues:
self.mutex_queues[queue_name_a] = self.mutex_queues[queue_name_b]
+ elif queue_name_b not in self.mutex_queues and queue_name_a not in self.mutex_queues:
+ self.mutex_queues[queue_name_b] = self.mutex_queues.setdefault(queue_name_a, Queue())
def wait_my_turn(self, queue_name : str) -> None:
LOGGER.warning('[wait_my_turn] begin queue_name={:s}'.format(str(queue_name)))
--
GitLab