tomerfiliba / plumbum / 22105423083

86%

push

github

feat: support async mode (#768)

* feat: support async mode

Now we can use Python's `async`/`await` syntax.

The implementation uses **delegation over inheritance** to maximize code reuse,
given async and sync code are incompatible.

Fix https://github.com/tomerfiliba/plumbum/issues/530

@moduon MT-6769

* fix(async): pipefail mode

Before this change, async pipelines were just a system shell with pipes.
This could have side effects, like problems in escaping arguments, or
systems with different default shells or versions.

To circumvent this issue, now async pipelines just execute the sync
version in another async thread.

Fixes https://github.com/tomerfiliba/plumbum/pull/768#discussion_r2733092592.

* test: flaky test can fail on race conditions

* fix(async): handle timeout exceptions correctly in async commands and pipelines

When async commands timeout, ProcessTimedOut was not being converted to
asyncio.TimeoutError, causing tests to fail. Additionally, when pipelines
timeout, source processes receive SIGPIPE when downstream processes are
killed, resulting in ProcessExecutionError(-13) instead of the expected
timeout exception.

Changes:
- Convert ProcessTimedOut to asyncio.TimeoutError in AsyncCommandMixin.run()
- Check for _timed_out flag in pipeline verification before validating
  return codes to properly detect timeouts across all pipeline stages
- Prevents SIGPIPE errors from masking timeout conditions in pipelines

Fixes test_timeout and test_pipeline_timeout in tests/test_async_local.py

1056 of 1513 branches covered (69.8%)

196 of 219 new or added lines in 7 files covered. (89.5%)

4679 of 5493 relevant lines covered (85.18%)

11.15 hits per line