

def _can_be_retried(self, tstate):
    'Inherit doc.\n\n    Only shard with output per shard can be retried.\n    '
    output_sharding = tstate._get_output_sharding(mapper_spec=tstate.mapreduce_spec.mapper)
    if (output_sharding == self.OUTPUT_SHARDING_INPUT_SHARDS):
        return True
    return False

dataset/ETHPy150Open AppScale/appscale/AppServer/google/appengine/ext/mapreduce/output_writers.py FileOutputWriterBase._can_be_retried/VarMisuse@16/56 `self`->`tstate`