You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@yunikorn.apache.org by pb...@apache.org on 2025/09/25 11:22:59 UTC
(yunikorn-core) branch master updated: [YUNIKORN-3127] Flaky test TestApplicationHistoryTracking (#1031)
This is an automated email from the ASF dual-hosted git repository.
pbacsko pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/yunikorn-core.git
The following commit(s) were added to refs/heads/master by this push:
new f6c1e41f [YUNIKORN-3127] Flaky test TestApplicationHistoryTracking (#1031)
f6c1e41f is described below
commit f6c1e41f5bb3f6e52c5a58f1a44b52a0b792892d
Author: Peter Bacsko <ba...@gmail.com>
AuthorDate: Thu Sep 25 13:22:47 2025 +0200
[YUNIKORN-3127] Flaky test TestApplicationHistoryTracking (#1031)
Closes: #1031
Signed-off-by: Peter Bacsko <ba...@gmail.com>
---
pkg/scheduler/tests/application_tracking_test.go | 11 +++++++----
1 file changed, 7 insertions(+), 4 deletions(-)
diff --git a/pkg/scheduler/tests/application_tracking_test.go b/pkg/scheduler/tests/application_tracking_test.go
index 11d6a943..8385f0ce 100644
--- a/pkg/scheduler/tests/application_tracking_test.go
+++ b/pkg/scheduler/tests/application_tracking_test.go
@@ -159,14 +159,17 @@ func TestApplicationHistoryTracking(t *testing.T) {
// make sure app transitions to Completing
app := ms.getApplication(appID1)
- err = common.WaitForCondition(time.Millisecond*10, time.Second, func() bool {
+ err = common.WaitForCondition(time.Millisecond*10, 5*time.Second, func() bool {
return app.IsCompleting()
})
assert.NilError(t, err, "timeout waiting for app state Completing")
- eventsDao, err = client.GetBatchEvents()
- assert.NilError(t, err)
- assert.Equal(t, 18, len(eventsDao.EventRecords), "number of events generated")
+ err = common.WaitForCondition(time.Millisecond*10, 5*time.Second, func() bool {
+ eventsDao, err = client.GetBatchEvents()
+ assert.NilError(t, err)
+ return len(eventsDao.EventRecords) == 18
+ })
+ assert.NilError(t, err, "number of events generated")
verifyAllocationCancelledEvents(t, eventsDao.EventRecords[13:])
events, _ = getEventsFromStream(t, false, stream, 4)
assert.NilError(t, err)
---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscribe@yunikorn.apache.org
For additional commands, e-mail: issues-help@yunikorn.apache.org