@@ -27,7 +27,7 @@ class PipelineCache:
self.__queue = Queue()
self.__lock = Lock()
- self._cache_time = cache_time or CLOSE_TIMER
+ self._cache_time = cache_time or self.CLOSE_TIMER
print(f"Initialized Pipeline cache (pipelines are closed after {self._cache_time:.3f} sec)")
def start(self):
