def METHOD_NAME(self, es):
    transform, aggregation = find_applicable_primitives(self.primitive)
    primitive_instantiate = self.primitive()
    transform.append(primitive_instantiate)
    valid_dfs(es, aggregation, transform, self.primitive)