Searched refs:replica_ctx (Results 1 – 3 of 3) sorted by relevance
53 def __init__(self, replica_ctx): argument54 _ThreadMode.__init__(self, replica_ctx.strategy, None, replica_ctx)
143 replica_ctx = ds_context.get_replica_context()144 self.assertIs(ds_context._get_default_replica_context(), replica_ctx)145 self.assertEqual("foo_bar", replica_ctx.merge_call(merge_fn, args=("bar",)))
125 def require_replica_context(replica_ctx): argument128 if context.replica_context is replica_ctx: return132 if context.strategy is replica_ctx.strategy:137 (context.strategy, replica_ctx.strategy))