def METHOD_NAME(source_entity, target_entity):
    column_lineages = []
    for source_column in source_entity.columns:
        for target_column in target_entity.columns:
            if source_column.name == target_column.name:
                column_lineages.append(
                    ColumnLineage(
                        fromColumns=[source_column.fullyQualifiedName.__root__],
                        toColumn=target_column.fullyQualifiedName.__root__,
                    )
                )
                break
    return column_lineages