Searched refs:_get_input_readers (Results 1 – 1 of 1) sorted by relevance
1387 readers, serialized_readers_entity = self._get_input_readers(state)1404 readers, _ = self._get_input_readers(state)1435 def _get_input_readers(self, state): member in KickOffJobHandler