x/tobiko
Code Issues Proposed changes

Merge "Lock changes in shelves files"

Browse Source
This commit is contained in:
Zuul
2025-08-07 07:33:13 +00:00
committed by Gerrit Code Review
parent 3d4513ccfd bbb4a7e493
commit b962a27290
1 changed files with 5 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
tobiko/common/_shelves.py
View File

@@ -20,6 +20,7 @@ import shelve
from oslo_log import log from oslo_log import log
import tobiko import tobiko
from tobiko.common import _lockutils
LOG = log.getLogger(__name__) LOG = log.getLogger(__name__)
@@ -37,6 +38,7 @@ def get_shelf_path(shelf):
return os.path.join(get_shelves_dir(), shelf) return os.path.join(get_shelves_dir(), shelf)
@_lockutils.interworker_synched('shelves')
def addme_to_shared_resource(shelf, resource): def addme_to_shared_resource(shelf, resource):
shelf_path = get_shelf_path(shelf) shelf_path = get_shelf_path(shelf)
# this is needed for unit tests # this is needed for unit tests
@@ -59,6 +61,7 @@ def addme_to_shared_resource(shelf, resource):
raise raise
@_lockutils.interworker_synched('shelves')
def removeme_from_shared_resource(shelf, resource): def removeme_from_shared_resource(shelf, resource):
shelf_path = get_shelf_path(shelf) shelf_path = get_shelf_path(shelf)
# this is needed for unit tests # this is needed for unit tests
@@ -105,6 +108,7 @@ def remove_test_from_shelf_resources(testcase_id, shelf):
raise raise
@_lockutils.interworker_synched('shelves')
def remove_test_from_all_shared_resources(testcase_id): def remove_test_from_all_shared_resources(testcase_id):
LOG.debug(f'Removing test {testcase_id} from all shelf resources') LOG.debug(f'Removing test {testcase_id} from all shelf resources')
shelves_dir = get_shelves_dir() shelves_dir = get_shelves_dir()
@@ -113,6 +117,7 @@ def remove_test_from_all_shared_resources(testcase_id):
remove_test_from_shelf_resources(testcase_id, filename) remove_test_from_shelf_resources(testcase_id, filename)
@_lockutils.interworker_synched('shelves')
def initialize_shelves(): def initialize_shelves():
shelves_dir = get_shelves_dir() shelves_dir = get_shelves_dir()
shelf_path = os.path.join(shelves_dir, TEST_RUN_SHELF) shelf_path = os.path.join(shelves_dir, TEST_RUN_SHELF)