Merge pull request #2760 from coreos-inc/ericavonb/QUAY-636-v22-queueworker

refactor(queueworker): remove unused function and import
This commit is contained in:
Erica 2017-07-10 15:04:22 -04:00 committed by GitHub
commit d5b32dd6fa

View file

@ -4,7 +4,6 @@ import json
from threading import Event, Lock
from app import app
from data.model import db
from data.database import CloseForLongOperation
from workers.worker import Worker
@ -57,11 +56,6 @@ class QueueWorker(Worker):
""" Function that gets run once every watchdog_period_seconds. """
pass
def _close_db_handle(self):
if not db.is_closed():
logger.debug('Disconnecting from database.')
db.close()
def extend_processing(self, seconds_from_now, updated_data=None):
with self._current_item_lock:
if self.current_queue_item is not None: