Skip to content

Commit b82e758

Browse files
authored
fix: PLT-866: Additional logging for async job creation (#8282)
Co-authored-by: triklozoid <[email protected]>
1 parent 4189c6d commit b82e758

File tree

1 file changed

+17
-6
lines changed

1 file changed

+17
-6
lines changed

label_studio/core/redis.py

Lines changed: 17 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -18,13 +18,24 @@
1818

1919
def _truncate_args_for_logging(args, kwargs, max_length=30):
2020
try:
21-
truncated_args = [repr(arg)[:max_length] + ('...' if len(repr(arg)) > max_length else '') for arg in args]
2221

23-
truncated_kwargs = {
24-
k: repr(v)[:max_length] + ('...' if len(repr(v)) > max_length else '')
25-
for k, v in kwargs.items()
26-
if k != 'on_failure'
27-
}
22+
def _truncate_scalar(value):
23+
v_repr = repr(value)
24+
return v_repr[:max_length] + ('...' if len(v_repr) > max_length else '')
25+
26+
def _truncate_top_level(value):
27+
# If dict at the top level, expand only one level of keys
28+
if isinstance(value, dict):
29+
parts = []
30+
for dk, dv in value.items():
31+
# Do NOT recurse: treat nested dicts as scalars
32+
parts.append(f'{repr(dk)}: {_truncate_scalar(dv)}')
33+
return '{' + ', '.join(parts) + '}'
34+
return _truncate_scalar(value)
35+
36+
truncated_args = [_truncate_top_level(arg) for arg in args]
37+
38+
truncated_kwargs = {k: _truncate_top_level(v) for k, v in kwargs.items() if k != 'on_failure'}
2839

2940
result = []
3041
if truncated_args:

0 commit comments

Comments
 (0)