Skip to content

Commit

Permalink
Merge branch 'qps-merger' of gitlab.mobileye.com:rem-cloud/rem-applic…
Browse files Browse the repository at this point in the history
…ations/spark-operator-code

# Conflicts:
#	charts/spark-operator-chart/README.md
#	pkg/controller/sparkapplication/controller_test.go
  • Loading branch information
ben-tzionlmb committed Jun 19, 2024
2 parents a1da547 + c40cdc4 commit 4e06330
Showing 1 changed file with 5 additions and 5 deletions.
10 changes: 5 additions & 5 deletions pkg/controller/sparkapplication/controller_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -96,16 +96,16 @@ func TestOnAdd(t *testing.T) {
Status: v1beta2.SparkApplicationStatus{},
}
// Initiated now ts
before := time.Now()
before := time.Now()

ctrl.onAdd(app)
after := time.Now()
after := time.Now()
m := ctrl.GetRelevantMap(app.Name)
// Check that m is not nil.
assert.NotNil(t, m)
// Check that m.appQueueMap[appName].Queue is not nil.
assert.NotNil(t, m.appQueueMap[app.Name])
// Check that m.appQueueMap[appName].LastUpdateTs is higer than now.
// Check that m.appQueueMap[appName].LastUpdateTs is higer than now.
// print last update ts
fmt.Println(m.appQueueMap[app.Name])
fmt.Println(before)
Expand Down Expand Up @@ -185,7 +185,7 @@ func TestOnUpdate(t *testing.T) {
ctrl.onUpdate(appTemplate, copyWithSpecUpdate)

// Verify App was enqueued.

item, _ = q.Get()
key, ok = item.(string)
assert.True(t, ok)
Expand Down Expand Up @@ -327,7 +327,7 @@ func TestSyncSparkApplication_SubmissionFailed(t *testing.T) {
if err != nil {
t.Fatal(err)
}

err, shouldDelete = ctrl.syncSparkApplication("default/foo")
assert.Equal(t, false, shouldDelete)

Expand Down

0 comments on commit 4e06330

Please sign in to comment.