Searched refs:shard_ctx (Results 1 – 3 of 3) sorted by relevance
79 def create(cls, shard_ctx): argument98 def commit_output(cls, shard_ctx, iterator): argument114 shard_ctx._state.writer_state["outs"] = outs
26 def begin_shard(self, shard_ctx): argument37 def end_shard(self, shard_ctx): argument
379 shard_ctx=None, slice_ctx=None): argument395 shard_context = shard_ctx or self.shard_context