Skip to content

Commit af89780

Browse files
committed
changes
1 parent 828d772 commit af89780

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/lib/snapshotQueue.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -290,7 +290,7 @@ export default class Queue {
290290
if (!drop) {
291291
let { processedSnapshot, warnings } = await processSnapshot(snapshot, this.ctx);
292292

293-
if(this.ctx.build.useKafkaFlow) {
293+
if(this.ctx.build && this.ctx.build.useKafkaFlow) {
294294
const snapshotUuid = uuidv4();
295295
const presignedResponse = await this.ctx.client.getS3PresignedURLForSnapshotUpload(this.ctx, processedSnapshot.name, snapshotUuid);
296296
const uploadUrl = presignedResponse.data.url;

0 commit comments

Comments
 (0)