Skip to content

Commit 369b30e

Browse files
elementl-devtoolselementl-devtools
committed
Release 1.11.3 (tracks 1932e6f8b6f152400c045f75c8207e18a6a9566b)
1 parent 5aff7b1 commit 369b30e

8 files changed

Lines changed: 21 additions & 108 deletions

File tree

‎dagster-cloud-examples/dagster_cloud_examples/version.py‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1 +1 @@
1-
__version__ = "1.11.2"
1+
__version__ = "1.11.3"

‎dagster-cloud-examples/pyproject.toml‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -19,7 +19,7 @@ classifiers = [
1919
"Operating System :: OS Independent",
2020
]
2121
dependencies = [
22-
"dagster-cloud==1.11.2",
22+
"dagster-cloud==1.11.3",
2323
]
2424

2525
[project.license]

‎dagster-cloud/dagster_cloud/agent/dagster_cloud_agent.py‎

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,11 @@
2121
from dagster._time import get_current_datetime, get_current_timestamp
2222
from dagster._utils.cached_method import cached_method
2323
from dagster._utils.container import retrieve_containerized_utilization_metrics
24-
from dagster._utils.error import SerializableErrorInfo, serializable_error_info_from_exc_info
24+
from dagster._utils.error import (
25+
SerializableErrorInfo,
26+
serializable_error_info_from_exc_info,
27+
truncate_serialized_error,
28+
)
2529
from dagster._utils.interrupts import raise_interrupts_as
2630
from dagster._utils.merger import merge_dicts
2731
from dagster._utils.typed_dict import init_optional_typeddict
@@ -45,7 +49,6 @@
4549
)
4650
from dagster_cloud.batching import Batcher
4751
from dagster_cloud.instance import DagsterCloudAgentInstance
48-
from dagster_cloud.util.errors import truncate_serialized_error
4952
from dagster_cloud.workspace.user_code_launcher import (
5053
DagsterCloudUserCodeLauncher,
5154
UserCodeLauncherEntry,

‎dagster-cloud/dagster_cloud/storage/event_logs/utils.py‎

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -11,9 +11,7 @@
1111
StepRetryData,
1212
)
1313
from dagster._core.events.log import EventLogEntry
14-
from dagster._utils.error import SerializableErrorInfo
15-
16-
from dagster_cloud.util.errors import truncate_serialized_error
14+
from dagster._utils.error import SerializableErrorInfo, truncate_serialized_error
1715

1816

1917
def _get_error_character_size_limit() -> int:

‎dagster-cloud/dagster_cloud/util/errors.py‎

Lines changed: 0 additions & 91 deletions
Original file line numberDiff line numberDiff line change
@@ -1,98 +1,7 @@
11
from collections.abc import Sequence
2-
from typing import Optional
32

4-
from dagster._serdes import serialize_value
53
from dagster._utils.error import SerializableErrorInfo
64

7-
ERROR_CLASS_NAME_SIZE_LIMIT = 1000
8-
9-
10-
def unwrap_user_code_error(error_info: SerializableErrorInfo) -> SerializableErrorInfo:
11-
"""Extracts the underlying error from the passed error, if it is a DagsterUserCodeLoadError."""
12-
if error_info.cls_name == "DagsterUserCodeLoadError":
13-
return unwrap_user_code_error(error_info.cause)
14-
return error_info
15-
16-
17-
def truncate_serialized_error(
18-
error_info: SerializableErrorInfo,
19-
field_size_limit: int,
20-
max_depth: int,
21-
truncations: Optional[list[str]] = None,
22-
):
23-
truncations = [] if truncations is None else truncations
24-
25-
if error_info.cause:
26-
if max_depth == 0:
27-
truncations.append("cause")
28-
new_cause = (
29-
error_info.cause
30-
if len(serialize_value(error_info.cause)) <= field_size_limit
31-
else SerializableErrorInfo(
32-
message="(Cause truncated due to size limitations)",
33-
stack=[],
34-
cls_name=None,
35-
)
36-
)
37-
else:
38-
new_cause = truncate_serialized_error(
39-
error_info.cause,
40-
field_size_limit,
41-
max_depth=max_depth - 1,
42-
truncations=truncations,
43-
)
44-
error_info = error_info._replace(cause=new_cause)
45-
46-
if error_info.context:
47-
if max_depth == 0:
48-
truncations.append("context")
49-
new_context = (
50-
error_info.context
51-
if len(serialize_value(error_info.context)) <= field_size_limit
52-
else SerializableErrorInfo(
53-
message="(Context truncated due to size limitations)",
54-
stack=[],
55-
cls_name=None,
56-
)
57-
)
58-
else:
59-
new_context = truncate_serialized_error(
60-
error_info.context,
61-
field_size_limit,
62-
max_depth=max_depth - 1,
63-
truncations=truncations,
64-
)
65-
error_info = error_info._replace(context=new_context)
66-
67-
stack_size_so_far = 0
68-
truncated_stack = []
69-
for stack_elem in error_info.stack:
70-
stack_size_so_far += len(stack_elem)
71-
if stack_size_so_far > field_size_limit:
72-
truncations.append("stack")
73-
truncated_stack.append("(TRUNCATED)")
74-
break
75-
76-
truncated_stack.append(stack_elem)
77-
78-
error_info = error_info._replace(stack=truncated_stack)
79-
80-
msg_len = len(error_info.message)
81-
if msg_len > field_size_limit:
82-
truncations.append(f"message from {msg_len} to {field_size_limit}")
83-
error_info = error_info._replace(
84-
message=error_info.message[:field_size_limit] + " (TRUNCATED)"
85-
)
86-
87-
if error_info.cls_name and len(error_info.cls_name) > ERROR_CLASS_NAME_SIZE_LIMIT:
88-
truncations.append("cls_name")
89-
error_info = error_info._replace(
90-
cls_name=error_info.cls_name[:ERROR_CLASS_NAME_SIZE_LIMIT] + " (TRUNCATED)"
91-
)
92-
93-
return error_info
94-
95-
965
DAGSTER_FRAMEWORK_SUBSTRINGS = [
976
"/site-packages/dagster/",
987
"/python_modules/dagster/dagster",

‎dagster-cloud/dagster_cloud/version.py‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1 +1 @@
1-
__version__ = "1.11.2"
1+
__version__ = "1.11.3"

‎dagster-cloud/dagster_cloud/workspace/user_code_launcher/user_code_launcher.py‎

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -45,7 +45,11 @@
4545
whitelist_for_serdes,
4646
)
4747
from dagster._time import get_current_timestamp
48-
from dagster._utils.error import SerializableErrorInfo, serializable_error_info_from_exc_info
48+
from dagster._utils.error import (
49+
SerializableErrorInfo,
50+
serializable_error_info_from_exc_info,
51+
truncate_serialized_error,
52+
)
4953
from dagster._utils.merger import merge_dicts
5054
from dagster._utils.typed_dict import init_optional_typeddict
5155
from dagster_cloud_cli.core.errors import raise_http_error
@@ -91,7 +95,6 @@
9195
ShutdownPexServerArgs,
9296
)
9397
from dagster_cloud.util import diff_serializable_namedtuple_map
94-
from dagster_cloud.util.errors import truncate_serialized_error
9598

9699
DEFAULT_SERVER_PROCESS_STARTUP_TIMEOUT = 180
97100
DEFAULT_MAX_TTL_SERVERS = 25

‎dagster-cloud/pyproject.toml‎

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@ build-backend = "setuptools.build_meta"
66

77
[project]
88
name = "dagster-cloud"
9-
requires-python = ">=3.9,<3.13"
9+
requires-python = ">=3.9,<3.14"
1010
dynamic = [
1111
"version",
1212
]
@@ -29,9 +29,9 @@ classifiers = [
2929
"Operating System :: OS Independent",
3030
]
3131
dependencies = [
32-
"dagster==1.11.2",
33-
"dagster-shared==1.11.2",
34-
"dagster-cloud-cli==1.11.2",
32+
"dagster==1.11.3",
33+
"dagster-shared==1.11.3",
34+
"dagster-cloud-cli==1.11.3",
3535
"opentelemetry-api>=1.27.0,<2",
3636
"opentelemetry-sdk>=1.27.0,<2",
3737
"opentelemetry-exporter-otlp-proto-grpc>=1.27.0,<2",
@@ -90,14 +90,14 @@ insights = [
9090
]
9191
docker = [
9292
"docker",
93-
"dagster-docker==0.27.2",
93+
"dagster-docker==0.27.3",
9494
]
9595
kubernetes = [
9696
"kubernetes",
97-
"dagster-k8s==0.27.2",
97+
"dagster-k8s==0.27.3",
9898
]
9999
ecs = [
100-
"dagster-aws==0.27.2",
100+
"dagster-aws==0.27.3",
101101
"boto3",
102102
]
103103
sandbox = [

0 commit comments

Comments
 (0)