Skip to content
GitLab
Projects
Groups
Snippets
Help
Loading...
Help
Help
Support
Community forum
Keyboard shortcuts
?
Submit feedback
Contribute to GitLab
Sign in
Toggle navigation
gms_preprocessing
Project overview
Project overview
Details
Activity
Releases
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Issues
29
Issues
29
List
Boards
Labels
Service Desk
Milestones
Merge Requests
0
Merge Requests
0
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Operations
Operations
Incidents
Environments
Packages & Registries
Packages & Registries
Container Registry
Analytics
Analytics
CI / CD
Repository
Value Stream
Wiki
Wiki
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
geomultisens
gms_preprocessing
Commits
59570fdc
Commit
59570fdc
authored
Nov 25, 2020
by
Daniel Scheffler
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
Fixed missing log messages regarding released locks.
Signed-off-by:
Daniel Scheffler
<
danschef@gfz-potsdam.de
>
parent
7c200e32
Changes
2
Hide whitespace changes
Inline
Side-by-side
Showing
2 changed files
with
8 additions
and
4 deletions
+8
-4
HISTORY.rst
HISTORY.rst
+6
-0
gms_preprocessing/misc/locks.py
gms_preprocessing/misc/locks.py
+2
-4
No files found.
HISTORY.rst
View file @
59570fdc
...
...
@@ -2,6 +2,12 @@
History
=======
0.18.12 (coming soon)
---------------------
* Fixed missing log messages regarding released locks.
0.18.11 (2020-11-03)
--------------------
...
...
gms_preprocessing/misc/locks.py
View file @
59570fdc
...
...
@@ -96,8 +96,9 @@ class MultiSlotLock(Semaphore):
self
.
client
.
delete
(
self
.
grabbed_key
)
def
__exit__
(
self
,
exc_type
,
exc_val
,
exc_tb
):
exitcode
=
super
(
MultiSlotLock
,
self
).
__exit__
(
exc_type
,
exc_val
,
exc_tb
)
self
.
logger
.
close
()
return
super
(
MultiSlotLock
,
self
).
__exit__
(
exc_type
,
exc_val
,
exc_tb
)
return
exitcode
class
SharedResourceLock
(
MultiSlotLock
):
...
...
@@ -134,7 +135,6 @@ class SharedResourceLock(MultiSlotLock):
self
.
client
.
delete
(
self
.
grabbed_key_jobID
)
def
__exit__
(
self
,
exc_type
,
exc_val
,
exc_tb
):
self
.
logger
.
close
()
return
super
(
SharedResourceLock
,
self
).
__exit__
(
exc_type
,
exc_val
,
exc_tb
)
...
...
@@ -146,7 +146,6 @@ class IOLock(SharedResourceLock):
super
(
IOLock
,
self
).
__init__
(
name
=
'IOLock'
,
allowed_slots
=
allowed_slots
,
logger
=
logger
,
**
kwargs
)
def
__exit__
(
self
,
exc_type
,
exc_val
,
exc_tb
):
self
.
logger
.
close
()
return
super
(
IOLock
,
self
).
__exit__
(
exc_type
,
exc_val
,
exc_tb
)
...
...
@@ -158,7 +157,6 @@ class ProcessLock(SharedResourceLock):
super
(
ProcessLock
,
self
).
__init__
(
name
=
'ProcessLock'
,
allowed_slots
=
allowed_slots
,
logger
=
logger
,
**
kwargs
)
def
__exit__
(
self
,
exc_type
,
exc_val
,
exc_tb
):
self
.
logger
.
close
()
return
super
(
ProcessLock
,
self
).
__exit__
(
exc_type
,
exc_val
,
exc_tb
)
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
.
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment