This is an automated email from the ASF dual-hosted git repository.
Yicong-Huang pushed a commit to branch release/v1.1.0-incubating
in repository https://gitbox.apache.org/repos/asf/texera.git
The following commit(s) were added to refs/heads/release/v1.1.0-incubating by
this push:
new 4867fc0c74 test(amber, 1.1): drop stale Thread.sleep(1000) after
COMPLETED state (#4874)
4867fc0c74 is described below
commit 4867fc0c74513f2501dae740ecc7935d24799464
Author: Yicong Huang <[email protected]>
AuthorDate: Sun May 3 14:12:47 2026 -0700
test(amber, 1.1): drop stale Thread.sleep(1000) after COMPLETED state
(#4874)
### What changes were proposed in this PR?
Backport [#4680](https://github.com/apache/texera/pull/4680) (commit
`598ed0f7f037b96ebe5549759158e46ba736b372` on `main`) onto
`release/v1.1.0-incubating`.
Removes the dead `Thread.sleep(1000)` + TODO inside the result-reading
block in `ReconfigurationSpec.scala` and `DataProcessingSpec.scala`,
matching what already landed on `main`.
### Any related issues, documentation, discussions?
Backports #4680. Unblocks the backport leg of #4871.
### How was this PR tested?
Cherry-pick of an already-reviewed and merged commit; applies cleanly.
CI on this PR exercises the change against the release branch's full
Python matrix.
### Was this PR authored or co-authored using generative AI tooling?
Generated-by: Claude Code (claude-opus-4-7)
Co-authored-by: Claude Opus 4.7 (1M context) <[email protected]>
---
.../scala/org/apache/texera/amber/engine/e2e/DataProcessingSpec.scala | 2 --
.../scala/org/apache/texera/amber/engine/e2e/ReconfigurationSpec.scala | 2 --
2 files changed, 4 deletions(-)
diff --git
a/amber/src/test/scala/org/apache/texera/amber/engine/e2e/DataProcessingSpec.scala
b/amber/src/test/scala/org/apache/texera/amber/engine/e2e/DataProcessingSpec.scala
index 69ee9c6a5f..f93909f53f 100644
---
a/amber/src/test/scala/org/apache/texera/amber/engine/e2e/DataProcessingSpec.scala
+++
b/amber/src/test/scala/org/apache/texera/amber/engine/e2e/DataProcessingSpec.scala
@@ -129,8 +129,6 @@ class DataProcessingSpec
uri.nonEmpty
})
.map(terminalOpId => {
- //TODO: remove the delay after fixing the issue of reporting
"completed" status too early.
- Thread.sleep(1000)
val uri = getResultUriByLogicalPortId(
workflowContext.executionId,
terminalOpId,
diff --git
a/amber/src/test/scala/org/apache/texera/amber/engine/e2e/ReconfigurationSpec.scala
b/amber/src/test/scala/org/apache/texera/amber/engine/e2e/ReconfigurationSpec.scala
index 92dfba19de..a125c1be00 100644
---
a/amber/src/test/scala/org/apache/texera/amber/engine/e2e/ReconfigurationSpec.scala
+++
b/amber/src/test/scala/org/apache/texera/amber/engine/e2e/ReconfigurationSpec.scala
@@ -132,8 +132,6 @@ class ReconfigurationSpec
uri.nonEmpty
})
.map(terminalOpId => {
- //TODO: remove the delay after fixing the issue of reporting
"completed" status too early.
- Thread.sleep(1000)
val uri = getResultUriByLogicalPortId(
workflow.context.executionId,
terminalOpId,
