The GitHub Actions job "Comment commands" on texera.git/main has succeeded.
Run started by GitHub user Ma77Ball (triggered by Ma77Ball).

Head commit for run:
471e53cfc1d5f96748a7ec6b7563561239229e5e / carloea2 <[email protected]>
fix(pyamber): preserve channel marker ports (#8432)

### What changes were proposed in this PR?

Bind channel markers to the input port resolved by their control
handler. Lifecycle callbacks use that port instead of the last data
tuple's port. Reject invalid markers before entering the executor.

### Any related issues, documentation, discussions?

Related to #8319.

### How was this PR tested?

>From amber, on Python 3.12:

```text
python -m pytest --tb=short -q 
src/test/python/core/architecture/handlers/control/test_channel_marker_handlers.py
 src/test/python/core/runnables/test_data_processor.py 
src/test/python/core/runnables/test_main_loop.py
66 passed
python -m ruff check src/main/python src/test/python
All checks passed
python -m ruff format --check src/main/python src/test/python
215 files already formatted
```

The new handler-to-processor cases cover an empty port 1 finishing after
a tuple on port 0, and port 1 starting before any tuple. Both fail when
marker routing is reverted to the current data port. Invalid-marker
tests failed before adding the type guard.

The full run, `python -m pytest --tb=no -q`, finished with 1320 passed,
1 xfailed, and 1 failed. The failure is the unchanged
`test_rest_catalog_round_trip` integration test, which targets a
Lakekeeper service at localhost:8181. The full suite is not green.
Excluding integration tests, `python -m pytest --tb=no -q -m "not
integration"` passes: 1320 passed, 1 deselected, 1 xfailed.

### Was this PR authored or co-authored using generative AI tooling?

Generated-by: OpenAI Codex

Co-authored-by: Meng Wang <[email protected]>

Report URL: https://github.com/apache/texera/actions/runs/35270848905

With regards,
GitHub Actions via GitBox

Reply via email to