Our replication job has a downstream job that is defined as:

foo_replication = define_asset_job(
    "foo_replication",
    selection=AssetSelection.groups("payments_backend_replication").downstream(),
)