carloea2 opened a new pull request, #8433: URL: https://github.com/apache/texera/pull/8433
### What changes were proposed in this PR? Add a typed Cloudpickle codec for values crossing generated Python workflow boundaries. A boundary payload records the selected field contract separately from the fields present on a particular execution path, while a workflow envelope groups canonical boundary payloads under one execution key. The codec validates boundary identities, field ordering, payload shape, duplicate boundaries, field-contract mismatches, and cross-key fan-in. It serializes only explicitly supplied values and preserves aliases and cycles within a boundary payload. ### Any related issues, documentation, discussions? Related to #8319. ### How was this PR tested? ```text python -m pytest -q src/test/python/pytexera/workflow/test_codec.py 5 passed in 1.20s ``` ```text python -m ruff check src/main/python/pytexera/workflow/codec.py src/test/python/pytexera/workflow/test_codec.py python -m ruff format --check src/main/python/pytexera/workflow/codec.py src/test/python/pytexera/workflow/test_codec.py All checks passed; 2 files already formatted ``` ### Was this PR authored or co-authored using generative AI tooling? Generated-by: OpenAI Codex -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
