스케줄러 작업이 5주 동안 조용히 실패하고 있었다

async def _weekly_optimizer_handler() -> None:
    # ...전제 조건 확인...

    try:
        optimizer = StrategyOptimizer(market_client, _session_factory)
        status = await optimizer.run_session(50, 100)

        if not status.best_params:
            logger.info("weekly_optimizer_no_best_params")
            return

        logger.info(
            "weekly_optimizer_session_completed",
            extra={
                "n_experiments": status.completed_experiments,  # <-- 존재하지 않는 속성
                "best_score": status.best_score,
            },
        )

        # ... _apply_best_params 호출 ...

    except Exception:
        logger.exception("weekly_optimizer_handler_failed")

async def run_session(self, n_experiments: int, days: int) -> OptimizerStatus:
    # ...
    try:
        # 50번 실험 루프
        for exp_no in range(1, n_experiments + 1):
            # ...
    except Exception as e:
        logger.error("optimizer_session_error", extra={"error": str(e)}, exc_info=True)
        self._status.last_error = str(e)   # 오류를 상태 객체에 담아 반환
    finally:
        self._status.is_running = False
        logger.info("optimizer_session_done", ...)

    return self._status  # 예외가 발생해도 항상 반환

status = await optimizer.run_session(50, 100)

# best_params 유무만 확인한다
if not status.best_params:
    logger.info("weekly_optimizer_no_best_params")
    return

# best_params가 있으면 "세션 완료"로 간주하고 진행
logger.info("weekly_optimizer_session_completed", ...)

# 수정 전
"n_experiments": status.completed_experiments,

# 수정 후
"n_experiments": status.current_experiment,

status = await optimizer.run_session(50, 100)

# 세션이 오류로 종료됐거나 실험을 완주하지 못한 경우
if status.last_error or status.current_experiment != status.total_experiments:
    logger.warning(
        "weekly_optimizer_session_incomplete",
        extra={
            "last_error": status.last_error,
            "current_experiment": status.current_experiment,
            "total_experiments": status.total_experiments,
        },
    )
    return   # 불완전한 세션의 결과는 적용하지 않는다

if not status.best_params:
    logger.info("weekly_optimizer_no_best_params")
    return

# 여기까지 왔으면 세션이 정상 완주됐다
logger.info("weekly_optimizer_session_completed", ...)

@pytest.mark.asyncio
async def test_weekly_optimizer_handler_does_not_apply_incomplete_session(
    monkeypatch,
    caplog,
) -> None:
    """내부 오류로 실패한 세션은 완료 처리되거나 파라미터에 적용되지 않는다."""
    status = OptimizerStatus(
        current_experiment=5,   # 50회 중 5회만 완료
        total_experiments=50,
        best_params={"oversold": 35.0},
        last_error="AttributeError: 'OptimizerStatus' object has no attribute 'completed_experiments'",
    )

    # ... FakeStrategyOptimizer 패치 ...

    with caplog.at_level(logging.WARNING, logger="..."):
        await _weekly_optimizer_handler()

    # 세션 완료 로그가 찍히지 않아야 한다
    assert not any(
        record.message == "weekly_optimizer_session_completed"
        for record in caplog.records
    )
    # 미완주 경고 로그가 찍혀야 한다
    incomplete_record = next(
        record for record in caplog.records
        if record.message == "weekly_optimizer_session_incomplete"
    )
    assert incomplete_record.last_error == status.last_error
    # _apply_best_params는 호출되지 않아야 한다
    apply_best_params.assert_not_awaited()

# 이런 패턴을 사용한다면
class TaskResult:
    success: bool
    data: Any
    error: str = ""

async def run_task() -> TaskResult:
    try:
        result = await do_something()
        return TaskResult(success=True, data=result)
    except Exception as e:
        return TaskResult(success=False, error=str(e))  # 예외 대신 오류 필드

status = await run_session(...)

# 확인 없이 진행하지 않는다
if status.last_error:
    logger.warning("session_failed", extra={"error": status.last_error})
    return  # 또는 raise

if status.current_experiment != status.total_experiments:
    logger.warning(
        "session_incomplete",
        extra={
            "completed": status.current_experiment,
            "expected": status.total_experiments,
        },
    )
    return

except Exception as exc:
    logger.exception("weekly_optimizer_handler_failed")
    try:
        await send_telegram_message(
            f"[경고] weekly optimizer 실패: {type(exc).__name__}: {exc}"
        )
    except Exception:
        pass  # 알림 실패가 원래 실패를 가리게 하지 않는다

async def run_session(self, ...) -> OptimizerStatus:
    """
    최적화 세션을 실행합니다.

    내부 예외는 catch되어 OptimizerStatus.last_error에 담깁니다.
    호출자는 반드시 last_error를 확인해야 합니다.
    """