job.current_step = VideoMetadataJobStep.SUMMARIZE
job.save(update_fields=["current_step", "updated_at"])
generate_and_apply_metadata(job)

def _assemble_prompt(ctx: MetadataGenerateContext) -> str:
    guidance = _duration_guidance(ctx.duration_seconds)
    return "".join(
        [
            prompt_parts.metadata_persona_generate(),
            prompt_parts.video_header(ctx.video_name, ctx.duration_seconds),
            prompt_parts.korean_output_rule_metadata_generate(),
            prompt_parts.metadata_field_spec_sentence(prompt_parts.ALL_METADATA_AREAS),
            prompt_parts.description_output_surface_rule(),
            prompt_parts.no_timeline_heading_rule_generate(),
            prompt_parts.video_name_immutable_rule(),
            f"{guidance}\n",
            f"{prompt_parts.prompt_version_line(ctx.prompt_version)}\n",
            prompt_parts.transcript_block(ctx.transcript_chunks),
        ]
    )

def _problems_field_guidance(p_lo: int, p_hi: int) -> str:
    return (
        f"- problems: {p_lo}~{p_hi}개. 생략하지 마세요. "
        "단일 정답 객관식, 보기 정확히 4개, is_correct는 문항당 정확히 1개.\n"
        "  - 이론(개념, 정의, 원리)과 코드(출력, 버그, API/문법 선택)를 섞으세요.\n"
        "  - 자막에 코드, API, 문법이 없으면 이론만. "
        "강의에 없는 샘플 코드를 창작하지 마세요.\n"
        "  - 강의에서 다룬 일반적인 개념은 공식 문서 등 외부 자료로 "
        "정의, 반례, 함정을 보강하세요.\n"
        "  - is_correct는 실제로 옳은 보기에만 true. "
        "explanation은 그 정답 보기를 가리키며 왜 맞는지 정확히 쓰세요.\n"
        "  - 오답별 해설은 넣지 마세요. 보기는 서로 구별되게."
    )

def _problem_range_for_duration(duration_seconds: int) -> tuple[int, int]:
    duration = max(0, int(duration_seconds or 0))
    band = _duration_band(duration)
    if band == "short":
        lo, hi = 2, 3
    elif band == "medium":
        lo = max(2, duration // 500)
        hi = max(lo, min(4, max(3, duration // 350)))
    elif band == "standard":
        lo = max(3, duration // 700)
        hi = max(lo, min(5, max(4, duration // 500)))
    else:
        lo = max(4, duration // 1200)
        hi = max(lo, duration // 900)

lo = max(_PROBLEM_COUNT_MIN, min(_PROBLEM_COUNT_MAX, lo))
hi = max(_PROBLEM_COUNT_MIN, min(_PROBLEM_COUNT_MAX, hi))
return lo, hi

{
  "stem": "다음 중 장고 미들웨어의 역할로 옳은 것은?",
  "explanation": "요청과 응답 처리를 감싸는 역할을 합니다.",
  "choices": [
    {"body": "요청을 처리한다.", "is_correct": true},
    {"body": "파이썬 코드를 컴파일한다.", "is_correct": false},
    {"body": "인덱스를 생성한다.", "is_correct": false},
    {"body": "CSS를 수정한다.", "is_correct": false}
  ]
}

def pending_newsletter_courses(*, now=None):
    cutoff = nine_am_today_seoul(now=now)
    return Course.objects.filter(
        publication_status=CoursePublicationStatus.PUBLISHED,
        newsletter_sent_at__isnull=True,
        published_at__lt=cutoff,
    ).order_by("published_at", "id")

course_ids = [item.course.id for item in items]
with transaction.atomic():
    Course.objects.filter(pk__in=course_ids).update(newsletter_sent_at=timezone.now())