def process()

in sdap/processors/callncpdq.py [0:0]

• 13 lines of code
• 2 McCabe index (conditional complexity)

    def process(self, input_data):
        """
        input_data: Path to input netCDF file

        If environment variable `PERMUTE_VARIABLE` is not set:
            Calls ``ncpdq -a ${DIMENSION_ORDER} in_path ${OUTPUT_PREFIX}in_path``
        Otherwise:
            Calls ``ncpdq -v ${PERMUTE_VARIABLE} -a ${DIMENSION_ORDER} in_path ${OUTPUT_PREFIX}in_path``
        """

        output_filename = self.output_prefix + os.path.basename(input_data)
        output_path = os.path.join(os.path.dirname(input_data), output_filename)

        command = ['ncpdq', '-a', ','.join(self.dimension_order)]

        if self.permute_variable:
            command.append('-v')
            command.append(self.permute_variable)

        command.append(input_data)
        command.append(output_path)

        logging.debug('Calling command %s' % ' '.join(command))
        retcode = call(command)
        logging.debug('Command returned exit code %d' % retcode)

        yield output_path