Merge branch 'dockerbuild' of https://bitbucket.org/yackob03/quay into dockerbuild
This commit is contained in:
commit
ab2385d909
3 changed files with 16 additions and 1 deletions
|
@ -65,7 +65,7 @@
|
||||||
</div>
|
</div>
|
||||||
|
|
||||||
<div class="repo-content" ng-show="!currentTag.image && repo.is_building">
|
<div class="repo-content" ng-show="!currentTag.image && repo.is_building">
|
||||||
<div class="empty-message">Your build is currently processing, if this takes longer than an hour, please contact quay support</div>
|
<div class="empty-message">Your build is currently processing, if this takes longer than an hour, please contact <a href="mailto:support@quay.io">Quay.io support</a></div>
|
||||||
</div>
|
</div>
|
||||||
|
|
||||||
<!-- Content view -->
|
<!-- Content view -->
|
||||||
|
|
|
@ -7,6 +7,7 @@ import argparse
|
||||||
from apscheduler.scheduler import Scheduler
|
from apscheduler.scheduler import Scheduler
|
||||||
|
|
||||||
from data.queue import image_diff_queue
|
from data.queue import image_diff_queue
|
||||||
|
from data.database import db as db_connection
|
||||||
from endpoints.registry import process_image_changes
|
from endpoints.registry import process_image_changes
|
||||||
|
|
||||||
|
|
||||||
|
@ -37,6 +38,10 @@ def process_work_items():
|
||||||
|
|
||||||
logger.debug('No more work.')
|
logger.debug('No more work.')
|
||||||
|
|
||||||
|
if not db_connection.is_closed():
|
||||||
|
logger.debug('Closing thread db connection.')
|
||||||
|
db_connection.close()
|
||||||
|
|
||||||
|
|
||||||
def start_worker():
|
def start_worker():
|
||||||
logger.debug("Scheduling worker.")
|
logger.debug("Scheduling worker.")
|
||||||
|
|
|
@ -15,6 +15,7 @@ from requests.exceptions import ConnectionError
|
||||||
from data.queue import dockerfile_build_queue
|
from data.queue import dockerfile_build_queue
|
||||||
from data.userfiles import UserRequestFiles
|
from data.userfiles import UserRequestFiles
|
||||||
from data import model
|
from data import model
|
||||||
|
from data.database import db as db_connection
|
||||||
from app import app
|
from app import app
|
||||||
|
|
||||||
|
|
||||||
|
@ -201,6 +202,11 @@ def babysit_builder(request):
|
||||||
logger.exception('Exception processing job: %s' % outer_ex.message)
|
logger.exception('Exception processing job: %s' % outer_ex.message)
|
||||||
return False
|
return False
|
||||||
|
|
||||||
|
finally:
|
||||||
|
if not db_connection.is_closed():
|
||||||
|
logger.debug('Closing thread db connection.')
|
||||||
|
db_connection.close()
|
||||||
|
|
||||||
|
|
||||||
def process_work_items(pool):
|
def process_work_items(pool):
|
||||||
logger.debug('Getting work item from queue.')
|
logger.debug('Getting work item from queue.')
|
||||||
|
@ -231,6 +237,10 @@ def process_work_items(pool):
|
||||||
|
|
||||||
logger.debug('No more work.')
|
logger.debug('No more work.')
|
||||||
|
|
||||||
|
if not db_connection.is_closed():
|
||||||
|
logger.debug('Closing thread db connection.')
|
||||||
|
db_connection.close()
|
||||||
|
|
||||||
|
|
||||||
def start_worker():
|
def start_worker():
|
||||||
pool = ThreadPool(3)
|
pool = ThreadPool(3)
|
||||||
|
|
Reference in a new issue