diff --git a/packages/import-handler/src/index.ts b/packages/import-handler/src/index.ts index 3333d56df..ded094b5d 100644 --- a/packages/import-handler/src/index.ts +++ b/packages/import-handler/src/index.ts @@ -166,7 +166,6 @@ const sendSavePageMutation = async (userId: string, input: unknown) => { 'Content-Type': 'application/json', }, }) - console.log('save page response: ', response) /* eslint-disable @typescript-eslint/no-unsafe-member-access */ return !!response.data.data.savePage @@ -256,7 +255,12 @@ export const importHandler = Sentry.GCPFunction.wrapHttpFunction( const pubSubMessage = req.body.message.data as string const obj = getStorageEvent(pubSubMessage) if (obj) { - await handleEvent(obj) + try { + await handleEvent(obj) + } catch (err) { + console.log('error handling event', { err, obj }) + throw err + } } } else { console.log('no pubsub message') diff --git a/packages/import-handler/src/task.ts b/packages/import-handler/src/task.ts index 16f66b08d..f4873376d 100644 --- a/packages/import-handler/src/task.ts +++ b/packages/import-handler/src/task.ts @@ -29,15 +29,6 @@ export const createCloudTask = async ( const serviceAccountEmail = `${project}@appspot.gserviceaccount.com` const parent = cloudTask.queuePath(project, location, queue) - console.log(`Task creation options: `, { - project, - location, - queue, - taskHandlerUrl, - serviceAccountEmail, - payload, - }) - const convertedPayload = JSON.stringify(payload) const body = Buffer.from(convertedPayload).toString('base64') const task: protos.google.cloud.tasks.v2.ITask = {