`angee.nexus.tasks`

Celery task wrappers for the nexus recompute pass.

recompute_ties

python

@shared_task(
    name="nexus.recompute_ties",
    autoretry_for=(Exception, ),
    retry_backoff=True,
    retry_kwargs={"max_retries": 3},
)
def recompute_ties(timestamp: int | None = None) -> int

Recompute every derived party-pair edge.