async def METHOD_NAME(
    self,
    organization_id: OrganizationID,
    author: DeviceID,
    realm_id: RealmID,
    encryption_revision: int,
    per_participant_message: Dict[UserID, bytes],
    timestamp: DateTime,
) -> None:
    async with self.dbh.pool.acquire() as conn:
        await query_start_reencryption_maintenance(
            conn,
            organization_id,
            author,
            realm_id,
            encryption_revision,
            per_participant_message,
            timestamp,
        )