Commit 2b6b9505 authored by Dimitrios Gogos's avatar Dimitrios Gogos Committed by Paris Stentoumis
Browse files

fix: minor fixes in tests

parent a6dfa65a

tests/integration/test_repositories.py

+8 −2
Changes for tests/integration/test_repositories.py: 8 added lines, 2 removed lines.
Original line number Diff line number Diff line
@@ -698,11 +698,17 @@ async def test_service_instance_update_state_persists( 
    order = await SqlServiceOrderRepository(db_session).create(_service_order(zone.id))

    repo = SqlServiceInstanceRepository(db_session)

    saved = await repo.create(_service_instance(spec.id, order.id, zone.id))

    terminated_at = datetime(2026, 7, 7, 12, 30, tzinfo=timezone.utc)



    updated = await repo.update_state(saved.id, ServiceInstanceState.ACTIVE)

    updated = await repo.update_state(

        saved.id,

        ServiceInstanceState.TERMINATED,

        terminated_at=terminated_at,

    )

    reloaded = await repo.get_by_id(saved.id)



    assert updated.state == ServiceInstanceState.ACTIVE

    assert updated.state == ServiceInstanceState.TERMINATED

    assert updated.terminated_at == terminated_at

    assert reloaded == updated

tests/unit/test_terminate_service_use_case.py

+5 −0
Changes for tests/unit/test_terminate_service_use_case.py: 5 added lines, 0 removed lines.
Original line number Diff line number Diff line
@@ -217,6 +217,10 @@ async def test_complete_terminates_child_capabilities_then_service_and_order() - 
    service_instances.get_by_id.return_value = service_instance

    capability_instances = AsyncMock()

    publisher = AsyncMock()

    calls: list[str] = []

    capability_instances.update_state.side_effect = lambda *a, **k: calls.append("capability")

    service_instances.update_state.side_effect = lambda *a, **k: calls.append("service_instance")

    service_orders.update_state.side_effect = lambda *a, **k: calls.append("service_order")



    completed_event = await _use_case(

        service_orders=service_orders,
@@ -256,6 +260,7 @@ async def test_complete_terminates_child_capabilities_then_service_and_order() - 
            "status": "completed",

        }

    ]

    assert calls == ["capability", "service_instance", "service_order"]





async def test_accept_replays_completed_event_when_completed_operation_order_exists() -> None: