def __init__(self, *args, **kwargs):
super(StreamingReplicatedPostgresqlContainer, self).__init__(
*args, **kwargs)
self.master_obtained = multiprocessing.Event()
self.master_lock = multiprocessing.Lock()
self.multiprocessing_data = data = multiprocessing.Manager().Namespace()
data.db_exists = False
data.exception = None
self.instances = multiprocessing.JoinableQueue()
评论列表
文章目录