def METHOD_NAME(self) -> Iterator[GraphNode]:
    """
    Create watermark nodes
    :return:
    """
    for part in self.parts:
        part_node = GraphNode(
            key=self.get_watermark_model_key(),
            label=Watermark.LABEL,
            attributes={
                'partition_key': part[0],
                'partition_value': part[1],
                'create_time': self.create_time
            }
        )
        yield part_node