Calling from the DCinside Worker

from rtb_api.client import RTBClient

# Supply these from the integration configuration agreed by both teams.
client = RTBClient(
    base_url=rehearsal_base_url,
    api_key=secret_manager.get("RTB_API_KEY"),
    timeout_s=30,
    total_timeout_s=60,
    max_retries=1,
)

# New rehearsal candidates require a known queue-entry clock.
# The helper also validates RFC 3339 formatting and an explicit timezone.
for candidate in cycle_payload["candidates"]:
    if candidate.get("extracted_at") is None:
        raise ValueError("Rehearsal candidate has no queue-entry timestamp")

response = client.post_cycle(cycle_payload)
# The worker checks the deadline, cycle identity and freshness before
# logging would-be picks. It does not publish during rehearsal.
for row in response["results"]:
    score = row.get("score") if row["status"] == "scored" else None

# Optional dedup rankings never replace the complete score rows above.
dedup = response.get("deduplication")
if dedup:
    main = dedup["tiers"]["main"]
    # Only confirmed duplicates are excluded. Unchecked is diagnostic:
    # do not subtract it from ranked or treat eligibility as proof of uniqueness.
    eligible_main_candidates = main["ranked"]

# When receipt is uncertain, recovery is separate from the decision deadline.
recovered = client.get_scores(cycle_payload["cycle_id"])

candidate = {
    "gall_id": "example", "post_no": 10, "title": "Example post",
    "created_at": None, "extracted_at": "2026-10-15T09:01:00+09:00",
    "source": "unknown", "manual_flag": 0, "images_in_post": 0,
}
# Keep the hidden label and its original 09:02 decision time client-side.
# Send candidate in the 09:05 cycle with removals=[].
# Send this post's current engagement in every subsequent five-minute cycle.
# The first eligible boundary is 09:20 (09:01 + 15 minutes, rounded up).
# First scoring, passing 25 minutes, or an operator label does not end retention.
# On deletion or the client's 24-hour age expiry, send a removal:
removal = {
    "gall_id": "example", "post_no": 10, "reason": "aged_out",
    "decided_at": age_expiry_at.isoformat(),  # actual expiry event, not hidden time
}