

def run_GroupByKey(self, transform_node):
    input_tag = windowing.inputs[0].tag
    input_step = self._cache.get_pvalue(transform_node.inputs[0])
    step = self._add_step(TransformNames.GROUP, transform_node.full_label, transform_node)
    step.add_property(PropertyNames.PARALLEL_INPUT, {
        '@type': 'OutputReference',
        PropertyNames.STEP_NAME: input_step.proto.name,
        PropertyNames.OUTPUT_NAME: input_step.get_output(input_tag),
    })
    step.encoding = self._get_typehint_based_encoding(self._get_transform_type_hint(transform_node))
    step.add_property(PropertyNames.OUTPUT_INFO, [{
        PropertyNames.USER_NAME: ('%s.%s' % (transform_node.full_label, PropertyNames.OUT)),
        PropertyNames.ENCODING: step.encoding,
        PropertyNames.OUTPUT_NAME: PropertyNames.OUT,
    }])
    windowing = transform_node.transform.get_windowing(transform_node.inputs)
    step.add_property(PropertyNames.SERIALIZED_FN, pickler.dumps(windowing))

dataset/ETHPy150Open GoogleCloudPlatform/DataflowPythonSDK/google/cloud/dataflow/runners/dataflow_runner.py DataflowPipelineRunner.run_GroupByKey/VarMisuse@14/23 `transform_node`->`windowing`