Skip to content

Commit 815bb62

Browse files
committed
fix
1 parent c0c61ec commit 815bb62

File tree

3 files changed

+18
-3
lines changed

3 files changed

+18
-3
lines changed

.github/workflows/helm-test-workflow.yml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -101,7 +101,7 @@ jobs:
101101
- name: Install kuttl
102102
run: |
103103
sudo curl -LO https://github.com/kudobuilder/kuttl/releases/download/v0.22.0/kuttl_0.22.0_linux_x86_64.tar.gz
104-
sudo tar -xvzf kuttl_0.12.0_linux_x86_64.tar.gz
104+
sudo tar -xvzf kuttl_0.22.0_linux_x86_64.tar.gz
105105
sudo chmod +x kubectl-kuttl
106106
sudo mv kubectl-kuttl /usr/local/bin/kubectl-kuttl
107107
- name: Install Python

test/index_and_ingestion_separation/index_and_ingestion_separation_suite_test.go

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -14,6 +14,8 @@
1414
package indingsep
1515

1616
import (
17+
"os"
18+
"path/filepath"
1719
"testing"
1820
"time"
1921

@@ -141,6 +143,11 @@ var (
141143
"remote_queue.sqs_smartbus.retry_policy = max_count",
142144
"remote_queue.max_count.sqs_smartbus.max_retries_per_part = 4"}
143145
outputsShouldNotContain = append(inputs, "remote_queue.sqs_smartbus.send_interval = 5s")
146+
147+
testS3Bucket = os.Getenv("TEST_INDEXES_S3_BUCKET")
148+
appListV1 = []string{}
149+
currDir, _ = os.Getwd()
150+
downloadDirV1 = filepath.Join(currDir, "s1appfwV1-"+testenv.RandomDNSName(4))
144151
)
145152

146153
// TestBasic is the main entry point

test/index_and_ingestion_separation/index_and_ingestion_separation_test.go

Lines changed: 10 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -59,8 +59,10 @@ var _ = Describe("indingsep test", func() {
5959
},
6060
},
6161
}
62-
s3TestDir = "s1appfw-" + testenv.RandomDNSName(4)
62+
63+
s3TestDir = "icappfw-" + testenv.RandomDNSName(4)
6364
appSourceVolumeName = "appframework-test-volume-" + testenv.RandomDNSName(3)
65+
appListV1 = testenv.BasicApps
6466
})
6567

6668
AfterEach(func() {
@@ -131,6 +133,12 @@ var _ = Describe("indingsep test", func() {
131133
testcaseEnvInst.Log.Info("Create Service Account")
132134
testcaseEnvInst.CreateServiceAccount(serviceAccountName)
133135

136+
// Upload apps to S3
137+
testcaseEnvInst.Log.Info("Upload apps to S3")
138+
appFileList := testenv.GetAppFileList(appListV1)
139+
_, err := testenv.UploadFilesToS3(testS3Bucket, s3TestDir, appFileList, downloadDirV1)
140+
Expect(err).To(Succeed(), "Unable to upload V1 apps to S3 test directory for IngestorCluster")
141+
134142
// Deploy Ingestor Cluster with additional configurations (similar to standalone app framework test)
135143
appSourceName := "appframework-" + enterpriseApi.ScopeLocal + testenv.RandomDNSName(3)
136144
appFrameworkSpec := testenv.GenerateAppFrameworkSpec(ctx, testcaseEnvInst, appSourceVolumeName, enterpriseApi.ScopeLocal, appSourceName, s3TestDir, 60)
@@ -176,7 +184,7 @@ var _ = Describe("indingsep test", func() {
176184
}
177185

178186
testcaseEnvInst.Log.Info("Deploy Ingestor Cluster with additional configurations")
179-
_, err := deployment.DeployIngestorClusterWithAdditionalConfiguration(ctx, ic)
187+
_, err = deployment.DeployIngestorClusterWithAdditionalConfiguration(ctx, ic)
180188
Expect(err).To(Succeed(), "Unable to deploy Ingestor Cluster")
181189

182190
// Ensure that Ingestor Cluster is in Ready phase

0 commit comments

Comments
 (0)