fix ci

streamnative · Jan 8, 2024 · 864a7e2 · 864a7e2
1 parent 9da8d4e
commit 864a7e2
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 5 deletions.
diff --git a/pulsar/resource_pulsar_sink_test.go b/pulsar/resource_pulsar_sink_test.go
@@ -142,8 +142,8 @@ func testSinkImported() resource.ImportStateCheckFunc {
 			return fmt.Errorf("expected %d states, got %d: %#v", 1, len(s), s)
 		}
 
-		if len(s[0].Attributes) != 27 {
-			return fmt.Errorf("expected %d attrs, got %d: %#v", 24, len(s[0].Attributes), s[0].Attributes)
+		if len(s[0].Attributes) != 30 {
+			return fmt.Errorf("expected %d attrs, got %d: %#v", 30, len(s[0].Attributes), s[0].Attributes)
 		}
 
 		return nil
@@ -173,7 +173,7 @@ func createSampleSink(name string) error {
 
 	config := &utils.SinkConfig{
 		CleanupSubscription:        false,
-		RetainOrdering:             false,
+		RetainOrdering:             true,
 		AutoAck:                    true,
 		Parallelism:                1,
 		Tenant:                     "public",
@@ -223,7 +223,7 @@ resource "pulsar_sink" "test" {
   max_redeliver_count = 5
   negative_ack_redelivery_delay_ms = 3000
   retain_key_ordering = false 
-	retain_ordering = false
+	retain_ordering = true
   secrets ="{\"SECRET1\": {\"path\": \"sectest\", \"key\": \"hello\"}}"
 
   processing_guarantees = "EFFECTIVELY_ONCE"

diff --git a/pulsar/resource_pulsar_source_test.go b/pulsar/resource_pulsar_source_test.go
@@ -159,7 +159,7 @@ func testSourceImported() resource.ImportStateCheckFunc {
 			return fmt.Errorf("expected %d states, got %d: %#v", 1, len(s), s)
 		}
 
-		count := 20
+		count := 19
 		if len(s[0].Attributes) != count {
 			return fmt.Errorf("expected %d attrs, got %d: %#v", count, len(s[0].Attributes), s[0].Attributes)
 		}