def METHOD_NAME(
        entity_type: str,
        entity_urn: str,
        upstreams: List[UpstreamClass],
        timestamp_millis: int,
        run_id: str = "",
) -> MetadataChangeProposalWrapper:
    print(f"Creating upstreamLineage aspect for {entity_urn}")
    timestamp_millis: int = int(datetime.datetime.now().timestamp() * 1000)
    mcp = MetadataChangeProposalWrapper(
        entityType=entity_type,
        entityUrn=entity_urn,
        changeType=ChangeTypeClass.UPSERT,
        aspectName="upstreamLineage",
        aspect=UpstreamLineage(upstreams=upstreams),
        systemMetadata={
            "lastObserved": timestamp_millis,
            "runId": run_id,
        },
    )
    return mcp