Skip to content

Commit 3b8409b

Browse files
committed
Remove dsl_source and keep udf_source as SSoT for LazyUDF serialization
1 parent 46f46ee commit 3b8409b

1 file changed

Lines changed: 0 additions & 4 deletions

File tree

src/blosc2/b2objects.py

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -93,7 +93,6 @@ def encode_b2object_payload(obj) -> dict[str, Any] | None:
9393
"dsl_version": _B2OBJECT_DSL_VERSION,
9494
"name": udf_name,
9595
"udf_source": udf_source,
96-
"dsl_source": obj.func.dsl_source,
9796
"dtype": np.dtype(obj.dtype).str,
9897
"shape": list(obj.shape),
9998
"operands": {f"o{i}": encode_operand_reference(value) for i, value in enumerate(obj.inputs)},
@@ -181,9 +180,6 @@ def decode_structured_lazyudf(payload, *, carrier_path=None):
181180
func = local_ns[name]
182181
if not isinstance(func, DSLKernel):
183182
func = DSLKernel(func)
184-
dsl_source = payload.get("dsl_source")
185-
if dsl_source is not None and func.dsl_source is None:
186-
func.dsl_source = dsl_source
187183

188184
operands = tuple(
189185
decode_operand_reference(operands_payload[f"o{n}"], base_path=carrier_path)

0 commit comments

Comments
 (0)