Merge "Stop using eventlet for action heartbeat threads"
This commit is contained in:
commit
e08d3f8938
@ -13,7 +13,7 @@
|
|||||||
# limitations under the License.
|
# limitations under the License.
|
||||||
|
|
||||||
import datetime
|
import datetime
|
||||||
import eventlet
|
import threading
|
||||||
import time
|
import time
|
||||||
|
|
||||||
from mistral import context as auth_ctx
|
from mistral import context as auth_ctx
|
||||||
@ -137,7 +137,7 @@ def start():
|
|||||||
|
|
||||||
_stopped = False
|
_stopped = False
|
||||||
|
|
||||||
eventlet.spawn_after(wait_time, _loop)
|
threading.Timer(wait_time, _loop).start()
|
||||||
|
|
||||||
|
|
||||||
def stop(graceful=False):
|
def stop(graceful=False):
|
||||||
|
@ -12,7 +12,7 @@
|
|||||||
# See the License for the specific language governing permissions and
|
# See the License for the specific language governing permissions and
|
||||||
# limitations under the License.
|
# limitations under the License.
|
||||||
|
|
||||||
import eventlet
|
import threading
|
||||||
import time
|
import time
|
||||||
|
|
||||||
from oslo_config import cfg
|
from oslo_config import cfg
|
||||||
@ -101,7 +101,7 @@ def start():
|
|||||||
|
|
||||||
_stopped = False
|
_stopped = False
|
||||||
|
|
||||||
eventlet.spawn(_loop)
|
threading.Thread(target=_loop).start()
|
||||||
|
|
||||||
|
|
||||||
def stop(graceful=False):
|
def stop(graceful=False):
|
||||||
|
Loading…
x
Reference in New Issue
Block a user