Searched refs:transient_shard_state (Results 1 – 1 of 1) sorted by relevance
607 def _process_datum(self, data, input_reader, ctx, transient_shard_state): argument624 handler = transient_shard_state.handler639 output_writer = transient_shard_state.output_writer