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 <[email protected]>
AuthorDate: Thu Sep 25 13:22:47 2025 +0200

    [YUNIKORN-3127] Flaky test TestApplicationHistoryTracking (#1031)
    
    Closes: #1031
    
    Signed-off-by: Peter Bacsko <[email protected]>
---
 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: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to