|
6 | 6 | from datetime import UTC, datetime |
7 | 7 | from decimal import Decimal |
8 | 8 |
|
9 | | -# # Remove the environment variable |
10 | | -# if "RESOURCE_USAGE_TRACKER_S3" in os.environ: |
11 | | -# monkeypatch.delenv("RESOURCE_USAGE_TRACKER_S3") |
12 | 9 | import sqlalchemy as sa |
13 | 10 | from models_library.api_schemas_resource_usage_tracker.licensed_items_purchases import ( |
14 | 11 | LicensedItemPurchaseGet, |
|
31 | 28 | ] |
32 | 29 |
|
33 | 30 |
|
34 | | -_USER_ID = 1 |
35 | | - |
36 | | - |
37 | | -# @pytest.fixture |
38 | | -# async def mocked_export(mocker: MockerFixture) -> AsyncMock: |
39 | | -# return mocker.patch( |
40 | | -# "simcore_service_resource_usage_tracker.services.service_runs.service_runs_db.export_service_runs_table_to_s3", |
41 | | -# autospec=True, |
42 | | -# ) |
43 | | - |
44 | | - |
45 | | -# @pytest.fixture |
46 | | -# async def mocked_presigned_link(mocker: MockerFixture) -> AsyncMock: |
47 | | -# return mocker.patch( |
48 | | -# "simcore_service_resource_usage_tracker.services.service_runs.SimcoreS3API.create_single_presigned_download_link", |
49 | | -# return_value=TypeAdapter(AnyUrl).validate_python("https://www.testing.com/"), |
50 | | -# ) |
51 | | - |
52 | | - |
53 | | -# @pytest.fixture |
54 | | -# async def enable_resource_usage_tracker_s3( |
55 | | -# mock_env: EnvVarsDict, |
56 | | -# mocked_aws_server: ThreadedMotoServer, |
57 | | -# mocked_s3_server_envs: EnvVarsDict, |
58 | | -# mocked_s3_server_settings: S3Settings, |
59 | | -# s3_client: S3Client, |
60 | | -# monkeypatch: pytest.MonkeyPatch, |
61 | | -# ) -> None: |
62 | | -# # Create bucket |
63 | | -# await s3_client.create_bucket(Bucket=mocked_s3_server_settings.S3_BUCKET_NAME) |
64 | | - |
65 | | - |
66 | 31 | async def test_rpc_licensed_items_purchases_workflow( |
67 | | - # enable_resource_usage_tracker_s3: None, |
68 | 32 | mocked_redis_server: None, |
69 | 33 | postgres_db: sa.engine.Engine, |
70 | 34 | rpc_client: RabbitMQRPCClient, |
71 | | - # mocked_export: Mock, |
72 | | - # mocked_presigned_link: Mock, |
73 | 35 | ): |
74 | 36 | result = await licensed_items_purchases.get_licensed_items_purchases_page( |
75 | 37 | rpc_client, product_name="osparc", wallet_id=1 |
|
0 commit comments