Merge "Delete function named poll_until which never used."
This commit is contained in:
@@ -19,13 +19,11 @@
|
|||||||
import eventlet
|
import eventlet
|
||||||
import functools
|
import functools
|
||||||
import mimetypes
|
import mimetypes
|
||||||
import time
|
|
||||||
|
|
||||||
from oslo_concurrency import lockutils
|
from oslo_concurrency import lockutils
|
||||||
from oslo_concurrency import processutils
|
from oslo_concurrency import processutils
|
||||||
from oslo_context import context as common_context
|
from oslo_context import context as common_context
|
||||||
from oslo_log import log as logging
|
from oslo_log import log as logging
|
||||||
from oslo_service import loopingcall
|
|
||||||
from oslo_utils import strutils
|
from oslo_utils import strutils
|
||||||
import pecan
|
import pecan
|
||||||
import six
|
import six
|
||||||
@@ -216,37 +214,6 @@ def check_container_id(function):
|
|||||||
return decorated_function
|
return decorated_function
|
||||||
|
|
||||||
|
|
||||||
def poll_until(retriever, condition=lambda value: value,
|
|
||||||
sleep_time=1, time_out=None, success_msg=None,
|
|
||||||
timeout_msg=None):
|
|
||||||
"""Retrieves object until it passes condition, then returns it.
|
|
||||||
|
|
||||||
If time_out_limit is passed in, PollTimeOut will be raised once that
|
|
||||||
amount of time is elapsed.
|
|
||||||
"""
|
|
||||||
start_time = time.time()
|
|
||||||
|
|
||||||
def poll_and_check():
|
|
||||||
obj = retriever()
|
|
||||||
if condition(obj):
|
|
||||||
raise loopingcall.LoopingCallDone(retvalue=obj)
|
|
||||||
if time_out is not None and time.time() - start_time > time_out:
|
|
||||||
raise exception.PollTimeOut
|
|
||||||
|
|
||||||
try:
|
|
||||||
poller = loopingcall.FixedIntervalLoopingCall(
|
|
||||||
f=poll_and_check).start(sleep_time, initial_delay=False)
|
|
||||||
poller.wait()
|
|
||||||
LOG.info(success_msg)
|
|
||||||
except exception.PollTimeOut:
|
|
||||||
LOG.error(timeout_msg)
|
|
||||||
raise
|
|
||||||
except Exception as e:
|
|
||||||
LOG.exception("Unexpected exception occurred: %s",
|
|
||||||
six.text_type(e))
|
|
||||||
raise
|
|
||||||
|
|
||||||
|
|
||||||
def get_image_pull_policy(image_pull_policy, image_tag):
|
def get_image_pull_policy(image_pull_policy, image_tag):
|
||||||
if not image_pull_policy:
|
if not image_pull_policy:
|
||||||
if image_tag == 'latest':
|
if image_tag == 'latest':
|
||||||
|
|||||||
Reference in New Issue
Block a user