

def process_input(self, input, baton):
    loader = json.loads
    if hasattr(input, 'read'):
        loader = json.load
    return loader(input, cls=self.json_decoder)

dataset/ETHPy150Open foundit/Piped/piped/processors/json_processors.py JsonDecoder.process_input/original