-
Notifications
You must be signed in to change notification settings - Fork 4.5k
Closed
Description
At least one of the Python tests test_pardo_timers_clear uses timer clearing.
/home/rebo/sdk/go1.22.1/bin/go build ../go/cmd/prism/*.go && python3 -m pytest -v apache_beam/runners/portability/prism_runner_test.py::PrismRunnerTest::test_pardo_timers_clear --test-pipeline-options="--environment_type=LOOPBACK --prism_bin=/home/rebo/git/beam/sdks/python/prism"
Most of this should already exist, but it's not fully supported in prism yet. It should be a matter of indicating how to write the "cleared" timer to the element manager in triageTimers.