Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
1 change: 1 addition & 0 deletions gooddata-pipelines/pyproject.toml
Original file line number Diff line number Diff line change
Expand Up @@ -33,6 +33,7 @@ moto = ">=5.1.6,<6.0.0"
pytest = ">=8.3.5,<9.0.0"
pytest-mock = ">=3.14.0,<4.0.0"
ruff = ">=0.11.2,<0.12.0"
orjson = "^3.11.3"

[build-system]
requires = ["hatchling"]
Expand Down
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
# (C) 2025 GoodData Corporation
import json
from typing import Literal

import orjson
import pytest
from gooddata_api_client.exceptions import ( # type: ignore[import]
NotFoundException,
Expand Down Expand Up @@ -455,7 +455,7 @@ def test_permission_provisioner(
f"{TEST_DATA_SUBDIR}/existing_upstream_permissions.json"
)
with open(EXISTING_UPSTREAM_PERMISSIONS_PATH, "r") as f:
raw_existing_upstream_permissions = json.load(f)
raw_existing_upstream_permissions = orjson.loads(f.read())

existing_upstream_permissions = parse_expected_permissions(
raw_existing_upstream_permissions
Expand All @@ -477,11 +477,11 @@ def mock_get_declarative_permissions(

# Load source data
with open(f"{TEST_DATA_SUBDIR}/{source_data_path}", "r") as f:
source_data = json.load(f)
source_data = orjson.loads(f.read())

# Load and parse expected data
with open(f"{TEST_DATA_SUBDIR}/{expected_data_path}", "r") as f:
raw_expected_result = json.load(f)
raw_expected_result = orjson.loads(f.read())

expected_result = parse_expected_permissions(raw_expected_result)

Expand Down
Original file line number Diff line number Diff line change
@@ -1,8 +1,8 @@
# (C) 2025 GoodData Corporation
import json
from dataclasses import dataclass
from typing import Literal, Optional

import orjson
import pytest
from gooddata_api_client.exceptions import NotFoundException # type: ignore
from gooddata_sdk.catalog.user.entity_model.user import (
Expand Down Expand Up @@ -225,15 +225,15 @@ def test_user_provisioning(

# Load input data
with open(f"{TEST_DATA_SUBDIR}/{input_path}", "r") as f:
input_data = json.load(f)
input_data = orjson.loads(f.read())

# Load expected data
with open(f"{TEST_DATA_SUBDIR}/{expected_path}", "r") as f:
raw_expected_data = json.load(f)
raw_expected_data = orjson.loads(f.read())

# Load and patch "existing users"
with open(f"{TEST_DATA_SUBDIR}/existing_upstream_users.json", "r") as f:
raw_upstream_users = json.load(f)
raw_upstream_users = orjson.loads(f.read())

upstream_users = parse_user_data(raw_upstream_users)

Expand Down
Original file line number Diff line number Diff line change
@@ -1,8 +1,8 @@
# (C) 2025 GoodData Corporation

import json
from typing import Any

import orjson
import pytest
from pydantic import ValidationError
from requests import Response
Expand Down Expand Up @@ -67,7 +67,7 @@ def test_get_wdf_settings_for_workspace_valid_payload(

payload = WDF_VALID_PAYLOAD

mock_response._content = json.dumps(payload).encode("utf-8")
mock_response._content = orjson.dumps(payload)

mocker.patch.object(
mock_gooddata_api,
Expand Down Expand Up @@ -102,7 +102,7 @@ def test_get_wdf_settings_for_workspace_invalid_payload(
]
}

mock_response._content = json.dumps(payload).encode("utf-8")
mock_response._content = orjson.dumps(payload)

mocker.patch.object(
mock_gooddata_api,
Expand Down
Original file line number Diff line number Diff line change
@@ -1,6 +1,5 @@
# (C) 2025 GoodData Corporation
import json

import orjson
import pytest

from gooddata_pipelines.ldm_extension.models.analytical_object import (
Expand All @@ -20,7 +19,7 @@
)
def test_analytical_object_model_with_metrics(file_path):
with open(file_path, "r") as file:
data = json.load(file)
data = orjson.loads(file.read())
analytical_objects = AnalyticalObjects(**data)
assert isinstance(analytical_objects, AnalyticalObjects)
assert isinstance(analytical_objects.data, list)
Expand Down
Loading