|
@@ -1,11 +1,12 @@
|
|
|
import queue
|
|
import queue
|
|
|
import warnings
|
|
import warnings
|
|
|
-import eventlet
|
|
|
|
|
|
|
|
|
|
from threading import Lock
|
|
from threading import Lock
|
|
|
from time import sleep
|
|
from time import sleep
|
|
|
from time import time
|
|
from time import time
|
|
|
|
|
|
|
|
|
|
+import eventlet
|
|
|
|
|
+
|
|
|
from eventlet import spawn_n
|
|
from eventlet import spawn_n
|
|
|
from eventlet import tpool
|
|
from eventlet import tpool
|
|
|
|
|
|
|
@@ -112,7 +113,6 @@ class PipelineCache:
|
|
|
break
|
|
break
|
|
|
except queue.Empty:
|
|
except queue.Empty:
|
|
|
eventlet.sleep(0.2)
|
|
eventlet.sleep(0.2)
|
|
|
- pass
|
|
|
|
|
|
|
|
|
|
if entry is None:
|
|
if entry is None:
|
|
|
# closing pipeline cache
|
|
# closing pipeline cache
|
