Fix failing tests

MaterializeInc · Mar 23, 2023 · f26b1e0 · f26b1e0
1 parent 2986df2
commit f26b1e0
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 4 deletions.
diff --git a/.github/workflows/integration.yaml b/.github/workflows/integration.yaml
@@ -36,16 +36,16 @@ jobs:
         run: docker exec datagen datagen -s /tests/schema.json -f avro -n 3 --record-size 100 -d -w 100 -p json
 
       - name: Produce to Kafka from Avro Schema in Avro Format
-        run: docker exec datagen datagen -s /tests/schema.avsc -f avro -n 3 --record-size 100 -d -w 100 -p sql
+        run: docker exec datagen datagen -s /tests/schema.avsc -f avro -n 3 --record-size 100 -d -w 100 -p avro
 
       - name: Clean Kafka topic
         run: docker exec datagen datagen -s /tests/schema2.sql -f json -d --clean
 
       - name: Clean Kafka topic with prefix
-        run: docker exec datagen datagen -s /tests/schema2.sql -f json -d --clean --prefix test
+        run: docker exec datagen datagen -s /tests/schema2.sql -f json -d --clean --prefix json
 
       - name: Clean Kafka topic and schema registry
-        run: docker exec datagen datagen -s /tests/schema.avsc -f avro -d --clean
+        run: docker exec datagen datagen -s /tests/schema.avsc -f avro -d --clean --prefix avro
 
       - name: Docker Compose Down
         run: docker compose down -v
diff --git a/datagen.ts b/datagen.ts
@@ -49,7 +49,7 @@ if (!fs.existsSync(options.schema)) {
         name: `Schema file ${options.schema} does not exist!`,
         msg: ``
     });
-    process.exit();
+    process.exit(1);
 }
 
 global.debug = options.debug;

diff --git a/src/kafka/cleanKafka.ts b/src/kafka/cleanKafka.ts
@@ -25,6 +25,7 @@ async function deleteSchemaSubjects(topics: any): Promise<void> {
             .catch((error) => {
                 console.error(error.response.status);
                 console.error(error.response.data.message);
+                process.exit(1);
             });
     }
 }