Diederik has uploaded a new change for review.
https://gerrit.wikimedia.org/r/59842
Change subject: Make sure that a lock is always released.
......................................................................
Make sure that a lock is always released.
Change-Id: Ifbd7972a738381d23d23a62cd645a7c25b8f32df
---
M user_metrics/api/engine/request_manager.py
1 file changed, 10 insertions(+), 7 deletions(-)
git pull ssh://gerrit.wikimedia.org:29418/analytics/E3Analysis
refs/changes/42/59842/1
diff --git a/user_metrics/api/engine/request_manager.py
b/user_metrics/api/engine/request_manager.py
index cd421fa..3d39aff 100644
--- a/user_metrics/api/engine/request_manager.py
+++ b/user_metrics/api/engine/request_manager.py
@@ -615,8 +615,9 @@
except Empty:
logging.error(__name__ + ' :: req_cb_get_url -'
' Block time expired.')
- return ''
- lock.release()
+ val = ''
+ finally:
+ lock.release()
return val
@@ -629,8 +630,9 @@
except Empty:
logging.error(__name__ + ' :: req_cb_get_cache_keys -'
' Block time expired.')
- return []
- lock.release()
+ val = []
+ finally:
+ lock.release()
return val
@@ -643,8 +645,9 @@
except Empty:
logging.error(__name__ + ' :: req_cb_get_is_running -'
' Block time expired.')
- return False
- lock.release()
+ val = False
+ finally:
+ lock.release()
return val
@@ -657,4 +660,4 @@
def req_cb_flag_job_complete(key, lock):
lock.acquire()
req_notification_queue_in.put([1, key], True)
- lock.release()
\ No newline at end of file
+ lock.release()
--
To view, visit https://gerrit.wikimedia.org/r/59842
To unsubscribe, visit https://gerrit.wikimedia.org/r/settings
Gerrit-MessageType: newchange
Gerrit-Change-Id: Ifbd7972a738381d23d23a62cd645a7c25b8f32df
Gerrit-PatchSet: 1
Gerrit-Project: analytics/E3Analysis
Gerrit-Branch: master
Gerrit-Owner: Diederik <[email protected]>
_______________________________________________
MediaWiki-commits mailing list
[email protected]
https://lists.wikimedia.org/mailman/listinfo/mediawiki-commits
